A complete automation platform

for data scientists and engineers

Manage
/
Orchestrate
/
Monitor

A Platform for Automation

Prefect Cloud is a command center for your workflows. Deploy from Prefect Core and instantly gain complete oversight and control.

Cloud UI

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.

GraphQL for ETL

Use Cloud's GraphQL API to query your data any way you want. Join, filter, and sort to get exactly the information you need.

Hybrid Execution

With Prefect's Hybrid Model, your code and data remain on-prem while Prefect Cloud's managed orchestration keeps everything running smoothly.

It's so innovative, we patented it.

CLI

Love your terminal? Kick off and monitor runs without leaving it. Realtime state updates and logs are just a keystroke away

Cloud Scheduler

The Cloud scheduler service runs asynchronously to ensure your runs start on time, every time.

and more...

Auto-API

Every flow has a permissioned API for remote execution and monitoring.

Versioning

Every Prefect flow is automatically versioned, so you're always up-to-date.

Team Management

Invite users to your team and assign roles and permissions as appropriate.

State Locking

Tasks run once and only once, no matter how many distributed execution environments you run.

Agents

The key to Cloud's Hybrid Execution model, agents are small open-source programs that can launch flows into any environment.

Projects

Projects are like directories for organizing flows.

Global Search

Immediately jump to the information you need.

Secrets

Give your flows access to sensitive information at runtime, like API keys or passwords.

Realtime UI

The Prefect UI updates in realtime so you're never behind.

On-Demand

Prefect tasks can be started, paused, and resumed at any time, allowing manual steps like review and approval.

Logs

Stream, filter, and search logs from every flow and task run.

Zombie Killers & Lazarus

One fails tasks that crash unexpectedly; the other revives runs that get stuck.

New

Tag-Based Concurrency Limits

Enforce global concurrency by assigning limits to individual task tags.

New

Flow Affinity

Tag flows so they're only picked up by agents with matching labels, in order to easily support multiple environments.

Coming Soon

Flow-to-Flow Dependencies

Link flows together to kick off new runs dynamically.

Coming Soon

Per-Run Environments

Send the same flow to different environments on every run.

Coming Soon

Progress API

Emit events mid-run for analysis.

Coming Soon

Artifacts API

Output artifacts for assertions and visualization.

Coming Soon

SLAs

Define SLAs for execution start and duration times.

Coming Soon

Data Lineage

Audit the life cycle of your workflows and data.

1
2
3
4
5
6
7
8
9
10
11
12
13
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!"

An open-source automation and
scheduling engine

Join our Community

Our public Slack is full of helpful tips and support