Python 如果其他人失败了，则完美跳过任务

Question

我的工作流程中有两个任务 A 和 B，如果任务失败，我想跳过 B，有什么想法吗？ @任务一种（）：经过乙（）：经过流（“”）作为流：

Answer 1

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

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

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])

Python 如果其他人失败了，则完美跳过任务

Python prefect skip task if others failed

prefect