Prefect 2.0
Orion provides a flexible and highly customizable way of organizing your flows, tasks, and deployments through a concept of tags
. You can save dashboards that only include flows, tasks, flow runs, task runs, and deployments with certain tags.
To set tags, you can leverage the TagsContext context manager:
- setting tags for a task:
from prefect import flow, task, tags
@task
def my_task():
pass
@flow
def my_flow():
with tags("project_name", "team_name"):
my_task() # has tags: project_name, team_name
Alternatively, you can also leverage the tags
argument in a @task
decorator:
@task(tags=["project_name", "team_name"])
- setting tags for a flow:
from prefect import flow, task, tags
@task
def my_task():
pass
@flow
def my_flow():
my_task()
with tags("project_name", "team_name"):
my_flow() # has tags: project_name, team_name
- setting tags for a deployment:
from prefect.deployments import DeploymentSpec
DeploymentSpec(
flow_location="flow.py",
name="flow-deployment",
tags=["production", "data-engineering-team", "project-x"]
)
Prefect 1.0
You can deploy your flows to various projects. Each project
can refer to a different topic, team, environment, or business unit in your organization. You can create a project either from the UI or using the CLI:
prefect create project "project_name"