Kevin
11/23/2021, 8:28 PMKevin
11/23/2021, 8:29 PMAnna Geller
from prefect import Flow, task
from prefect.tasks.prefect import RenameFlowRun
import prefect
def rename_handler(obj, new_state, old_state):
if new_state.is_running():
param = prefect.context.parameters.get("your_parameter_name")
RenameFlowRun().run(flow_run_name=f"new_name_{param}")
return
@task
def first_task():
return 1
with Flow("test-flow", state_handlers=[rename_handler]) as flow:
first_task()
Kevin
11/23/2021, 8:37 PMKevin
11/23/2021, 8:40 PMAnna Geller
with Flow("your-flow-name") as flow:
Kevin
11/23/2021, 8:47 PM