如果其他人失败,Python将跳过任务



我的工作流程中有两个任务A和B,如果任务失败,我想跳过B,你知道吗?@任务A((:通过B((:通过流量("(作为流量:

如果上游任务A失败,预取的默认行为是不运行任务B。但这些任务必须通过upstream_tasks关键字显式地或通过在彼此之间传递数据隐式地相互依赖。您也可以使用触发器来控制这种行为。

如何设置依赖关系的示例:

from prefect import task, Flow
@task
def task_1():
pass
@task
def task_2():
pass
@task
def task_3():
pass
with Flow("flow_with_dependencies") as flow:
t1 = task_1()
t2 = task_2(upstream_tasks=[t1])
t3 = task_3(upstream_tasks=[t2])

最新更新