Andreas Nord
09/06/2022, 3:12 PMfrom prefect import task, Flow
def foo(x):
return _foo(x, task_args=dict(name=x))
@task(task_run_name="{x}")
def _foo(x):
print(x)
with Flow("flow") as flow:
foo('a') # should be named 'a'
foo('b') # should be named 'b'
flow()
Nate
09/06/2022, 3:20 PM