小编Urt*_*hor的帖子

我目前正在编写一个运算符，如下所示在我的图表末尾运行

fail = DummyOperator(
    task_id=t_fail,
    default_args=args,
    trigger_rule='one_failed',
    on_success_callback=partial(dag_complete_notification,
    dag_success=reference.DagCompleteStatus.INCOMPLETE),
    dag=dag
)

理想情况下，我只会在其所有上游完成时触发操作员，并且如果其中一个失败。

Base_Operator不幸的是，只接受触发器规则的单个参数，即使我真的很想只写one_failed and all_complete.

有没有其他方法可以解决这个问题？

编辑：已过时，因为该问题适用于 Airflow 1.1.2。