Wesley Jin
03/09/2022, 4:31 PMproject
a create_flow_run
call creates a Flow for depending on environment variables? Example in threadwith Flow("example flow") as flow:
load_task = ...
run_reporting_flow = create_flow_run(
flow_name="Example Reporting Flow Name",
project_name=f"reporting-{os.getenv(ENVIRONMENT)}",
task_args=dict(trigger=all_successful),
)
run_reporting_flow.set_upstream(load_task)
KeyError: 'Task slug create_flow_run-1 is not found in the current Flow. This is usually caused by a mismatch between the flow version stored in the Prefect backend and the flow that was loaded from storage.\n- Did you change the flow without re-registering it?\n- Did you register the flow without updating it in your storage location (if applicable)?'
Kevin Kho
03/09/2022, 4:32 PMWesley Jin
03/09/2022, 4:37 PMENVIRONMMENT
in CI registration & the execution environments are the sameKevin Kho
03/09/2022, 5:02 PMwith Flow...
constructs and than you do either flow.run()
or flow.register()
but if you don’t call it, that’s why nothing runs. It just gets builtWesley Jin
03/09/2022, 5:35 PMref
was being set (a branch that didn’t have the create_flow_run
call in the Flow was being referenced at Flow run time)Kevin Kho
03/09/2022, 5:43 PM