python - 是否可以根据同一个 dag 中另一个任务的状态在一个 dag 中运行一个任务？

Question

仅当任务 A 未处于运行状态时，我才需要获取任务“A”的状态并触发任务“B”。有没有可能在气流中做到这一点？

标签： pythondependenciestaskairflowdirected-acyclic-graphs

Answer 1

不，您只能在任务成功、失败（upstream_failed）甚至忽略其状态之后才能依赖任务，但您不能依赖任务的未运行状态，未运行意味着无、已调度、已排队、成功、失败、 upstream_failed，跳过，没有这个选项。