Jon
11/01/2022, 6:43 PMwith prefect.Flow(
name="SOME_DYNAMIC_NAME" # instead of hardcoding this, i want to pass a value when registering / calling it
Bianca Hoch
11/01/2022, 8:01 PMrun_name
which is applied when the run is executed.Jon
11/01/2022, 8:10 PMNate
11/01/2022, 8:38 PMJon
11/01/2022, 8:49 PMIsmail Cenik
01/27/2023, 8:44 PMNate
01/27/2023, 9:22 PMIsmail Cenik
01/27/2023, 10:23 PMNate
01/27/2023, 10:40 PM@flow(name="My Flow")
def my_flow():
pass
⢠name a flow that is already defined
# using above example
my_new_named_flow = my_flow.with_options(name="My New Named Flow")
# `my_new_named_flow` can now be called just like any other flow
is there a different way in which you're trying to name a flow?Ismail Cenik
01/27/2023, 10:46 PMwith Flow(flow_name, storage=storageObj, result=s3_backup,
run_config=KubernetesRun(job_template_path=JOB_TEMPLATE_FILE),
executor=LocalDaskExecutor(scheduler="threads", num_workers=1)) as flow:
in prefect v2, how can I set it before running the flow? This is a parametric info for us and changing env (DEV, QA, CM, PROD), so how can I set it?