Vamsi Reddy
02/08/2022, 12:08 AMKevin Kho
idempotency_key
when you create a flow run because a call with a key that has already ran will not trigger a new flow runVamsi Reddy
02/08/2022, 3:26 PMKevin Kho
Vamsi Reddy
02/08/2022, 3:33 PMKevin Kho
Vamsi Reddy
02/08/2022, 3:54 PMKevin Kho
Vamsi Reddy
02/08/2022, 4:09 PMidempotency_key
in create_flow_run i get this error :
TypeError: got an unexpected keyword argument 'idempotency_key'
File "/Users/vamsi/git_repo/automation/Automation/flows/SIE_flow.py", line 536, in <module>
idempotency_key=f'SPE_flow_{company_bucket}' + datetime.datetime.now().strftime("_%m-%d-%Y_%H")
File "/Users/vamsi/opt/anaconda3/envs/python37/lib/python3.7/site-packages/prefect/core/task.py", line 634, in __call__
*args, mapped=mapped, upstream_tasks=upstream_tasks, flow=flow, **kwargs
File "/Users/vamsi/opt/anaconda3/envs/python37/lib/python3.7/site-packages/prefect/core/task.py", line 674, in bind
callargs = dict(signature.bind(*args, **kwargs).arguments) # type: Dict
File "/Users/vamsi/opt/anaconda3/envs/python37/lib/python3.7/inspect.py", line 3015, in bind
return args[0]._bind(args[1:], kwargs)
File "/Users/vamsi/opt/anaconda3/envs/python37/lib/python3.7/inspect.py", line 3006, in _bind
arg=next(iter(kwargs))))
TypeError: got an unexpected keyword argument 'idempotency_key'
Kevin Kho
Vamsi Reddy
02/10/2022, 2:32 PMKevin Kho
Vamsi Reddy
02/10/2022, 2:36 PM