Skip to main content

Workflow orchestration and management.

Project description

Orion

A development repo for Prefect Orion; reference documentation can be found at https://orion-docs.prefect.io/.

Welcome!

Prefect Orion is the second-generation workflow orchestration engine from Prefect, now available as a technical preview.

Orion has been designed from the ground up to handle the dynamic, scalable workloads that the modern data stack demands. Powered by a brand-new, asynchronous rules engine, it represents an enormous amount of research, development, and dedication to a simple idea:

You should love your workflows again.

Read the docs, run the code, or host the UI. Join thousands of community members in our Slack community to share your thoughts and feedback. Thanks for being part of the mission to build a new kind of workflow system and, of course, happy engineering!

"Don't Panic"

Prefect Orion is under active development and may change rapidly. For production use, we recommend Prefect Core.


Hello, Orion!

Prefect is the easiest way to transform any function into a unit of work that can be observed and governed by orchestration rules.

Add workflow features like retries, distributed execution, scheduling, caching, and much more, with minimal changes to your code. Every activity is tracked and becomes visible in the Orion Dashboard.

Decorate functions to automatically retry them on failure while providing complete visibility in the Orion Dashboard.

from prefect import flow, task
from typing import List
import httpx


@task(retries=3)
def get_stars(repo: str):
    url = f"https://api.github.com/repos/{repo}"
    count = httpx.get(url).json()["stargazers_count"]
    print(f"{repo} has {count} stars!")


@flow(name="Github Stars")
def github_stars(repos: List[str]):
    for repo in repos:
        get_stars(repo)


# run the flow!
github_stars(["PrefectHQ/Prefect", "PrefectHQ/miter-design"])

After running any running some flows, fire up the UI to gain insight into their execution:

prefect orion start

From here, you can continue to use Prefect interactively or set up automated deployments.

Next steps

Orion was designed to be incrementally adopted into your workflows, and our documentation is organized to support your exploration as much as possible. It is organized into four main sections whose applicability will depend on your objectives and comfort level.

Getting started

Begin by installing Orion on your machine, then follow one of our friendly tutorials to learn by example. See the Getting Started overview for more.

Concepts

Learn more about Orion's features and design by reading our in-depth concept docs. These are intended to introduce the building blocks of Orion, build up to orchestration and deployment, and finally cover some of the advanced use cases that Orion makes possible.

Frequently asked questions

Orion represents a fundamentally new way of building and orchestrating data workflows. Learn more about the project by reading our FAQ.

API reference

Orion provides a number of programmatic workflow interfaces, each of which is documented in the API Reference. This is where you can learn how a specific function works, or see the expected payload for a REST endpoint.

Join the community

Orion was made possible by the fastest-growing community of data engineers. The Prefect Slack community is a fantastic place to learn more, ask questions, or get help with workflow design. Join us and thousands of friendly data engineers to help build a new kind of workflow system.

Project details


Release history Release notifications | RSS feed

Download files

Download the file for your platform. If you're not sure which to choose, learn more about installing packages.

Source Distribution

prefect-2.0a2.tar.gz (1.4 MB view details)

Uploaded Source

Built Distribution

prefect-2.0a2-py3-none-any.whl (2.5 MB view details)

Uploaded Python 3

File details

Details for the file prefect-2.0a2.tar.gz.

File metadata

  • Download URL: prefect-2.0a2.tar.gz
  • Upload date:
  • Size: 1.4 MB
  • Tags: Source
  • Uploaded using Trusted Publishing? No
  • Uploaded via: twine/3.4.2 importlib_metadata/4.8.1 pkginfo/1.7.1 requests/2.26.0 requests-toolbelt/0.9.1 tqdm/4.62.3 CPython/3.8.5

File hashes

Hashes for prefect-2.0a2.tar.gz
Algorithm Hash digest
SHA256 258025f4d2cfbdd11f78b430d031e46a2190d114a2756e2732962b0c60d63466
MD5 cd6038cecb41d32cf4924f1040d132da
BLAKE2b-256 bbe00852076a11ccc29300fe380d65e90bd1552bf2dcc72e5e3d4fa41f62bec0

See more details on using hashes here.

File details

Details for the file prefect-2.0a2-py3-none-any.whl.

File metadata

  • Download URL: prefect-2.0a2-py3-none-any.whl
  • Upload date:
  • Size: 2.5 MB
  • Tags: Python 3
  • Uploaded using Trusted Publishing? No
  • Uploaded via: twine/3.4.2 importlib_metadata/4.8.1 pkginfo/1.7.1 requests/2.26.0 requests-toolbelt/0.9.1 tqdm/4.62.3 CPython/3.8.5

File hashes

Hashes for prefect-2.0a2-py3-none-any.whl
Algorithm Hash digest
SHA256 15c1753497116098fcdee55a28a8eb9e7cdc0bbb184733f18b670c9b6211f123
MD5 9d3b28b7d5e6c1f95f7737fd22637352
BLAKE2b-256 3a2740511d92e6ae979596c039508aed7aa58f92ae4fbc6d1c7fea18f5dc988b

See more details on using hashes here.

Supported by

AWS AWS Cloud computing and Security Sponsor Datadog Datadog Monitoring Fastly Fastly CDN Google Google Download Analytics Microsoft Microsoft PSF Sponsor Pingdom Pingdom Monitoring Sentry Sentry Error logging StatusPage StatusPage Status page