Cloud's beautiful UI lets you keep an eye on the health of your infrastructure.
Stream realtime state updates and logs, kick off new runs, and receive critical information exactly when you need it.
Every flow has a permissioned API for remote execution and monitoring.
Every Prefect flow is automatically versioned, so you're always up-to-date.
Invite users to your team and assign roles and permissions as appropriate.
Tasks run once and only once, no matter how many distributed execution environments you run.
The key to Cloud's Hybrid Execution model, agents are small open-source programs that can launch flows into any environment.
Projects are like directories for organizing flows.
Immediately jump to the information you need.
Give your flows access to sensitive information at runtime, like API keys or passwords.
The Prefect UI updates in realtime so you're never behind.
Prefect tasks can be started, paused, and resumed at any time, allowing manual steps like review and approval.
Stream, filter, and search logs from every flow and task run.
One fails tasks that crash unexpectedly; the other revives runs that get stuck.
Enforce global concurrency by assigning limits to individual task tags.
Link flows together to kick off new runs dynamically.
Tag a flow run to ensure it's only picked up by agents with matching tags.
Send the same flow to different environments on every run.
Emit events mid-run for analysis.
Audit the life cycle of your workflows and data.
from prefect import task, Flow @task def say_hello(): print("Hello, world!") with Flow("My First Flow") as flow: say_hello() flow.run() # "Hello, world!"