Ben Muller
02/25/2022, 3:52 AMcreate_flow_run.run(
flow_name="advanced_cleaning",
project_name="modelling",
run_name=f"data_update={data_update}",
parameters=dict(data_update=data_update),
)
When I run this it is called multiple times, but only one sometimes two flows are triggered in the cloud, is this a possible bug?
Do run names need to be unique?
This is being called from within a task fyiKevin Kho
02/25/2022, 4:11 AMBen Muller
02/25/2022, 4:28 AMKevin Kho
02/25/2022, 4:34 AMBen Muller
02/25/2022, 5:18 AMError during execution of task: TypeError("create_flow_run() got an unexpected keyword argument 'idempotency_key'")
Locally I am using prefect 0.15.5
and my prefect core version is the same on the UI.
Any ideas?Kevin Kho
02/28/2022, 8:37 PMBen Muller
02/28/2022, 8:38 PMKevin Kho
02/28/2022, 8:39 PMBen Muller
02/28/2022, 8:39 PMKevin Kho
02/28/2022, 8:40 PMBen Muller
02/28/2022, 8:40 PMKevin Kho
02/28/2022, 8:41 PMBen Muller
02/28/2022, 8:41 PM