Ricardo Portela
04/13/2021, 7:26 PMKevin Kho
Ricardo Portela
04/13/2021, 8:04 PMRicardo Portela
04/13/2021, 8:05 PM@task
def prevent_execution():
execution_date(today) = 13/04/2021
max_Date = 12/04/2021
last_execution_date = 12/10/2021
if last_execution_date < max_Date:
execute flow
else:
do nothing
Ricardo Portela
04/13/2021, 8:06 PMRicardo Portela
04/13/2021, 8:07 PMKevin Kho
SKIP
signal in your if statement.Kevin Kho
*prefect.client.client.Client.get_flow_run_info*(flow_run_id)
is what you need here.Ricardo Portela
04/13/2021, 8:11 PMKevin Kho
prefect.client.client.Client.create_flow_run
Jacob Hayes
04/13/2021, 8:12 PMidempotency_key
might help (docs). In addition to the API, that can be passed to StartFlowRun
too.Ricardo Portela
04/13/2021, 8:13 PMKevin Kho
Ricardo Portela
04/13/2021, 8:20 PMKevin Kho
Ricardo Portela
04/13/2021, 8:28 PM