Thomas Opsomer
03/04/2022, 4:22 PMKevin Kho
03/04/2022, 4:25 PMThomas Opsomer
03/04/2022, 4:34 PMKevin Kho
03/04/2022, 4:45 PMThomas Opsomer
03/04/2022, 4:47 PMClick on confirm to restart the flow run _flow_run_name_ from this task run. This will restart your flow run and re-run task _task_name_ and its downstream dependents.
Kevin Kho
03/04/2022, 4:47 PMMarvin
03/04/2022, 4:48 PMThomas Opsomer
03/07/2022, 8:35 AMKevin Kho
03/07/2022, 2:00 PMfrom prefect import task, Flow
import prefect
import datetime
@task
def task_one():
<http://prefect.context.logger.info|prefect.context.logger.info>(datetime.datetime.now())
return 1
@task
def task_two(x):
<http://prefect.context.logger.info|prefect.context.logger.info>(datetime.datetime.now())
return x+1
@task
def task_three(x):
<http://prefect.context.logger.info|prefect.context.logger.info>(datetime.datetime.now())
return x+1
@task
def task_four(x):
<http://prefect.context.logger.info|prefect.context.logger.info>(datetime.datetime.now())
return x+1
with Flow("fail_propagate") as flow:
task_four(task_three(task_two(task_one())))
Thomas Opsomer
03/07/2022, 5:51 PMKevin Kho
03/07/2022, 5:53 PMThomas Opsomer
03/07/2022, 6:25 PMKevin Kho
03/07/2022, 7:18 PM