Tony Yun
task_run_name
@task(name="My Example Task", description="An example task for a tutorial.", task_run_name="hello-{name}-on-{date:%A}") def my_task(name, date): pass
Nate
dynamic_key
from prefect import flow, task from prefect.context import get_run_context def incremental_name(): return f"Run {get_run_context().task_run.dynamic_key}" # modify as needed @task(task_run_name=incremental_name) def foo(): pass @flow def someflow(): foo() foo() foo() someflow()
Bring your towel and join one of the fastest growing data communities. Welcome to our second-generation open source orchestration platform, a completely rethought approach to dataflow automation.