Airflow - 创建在所有其他任务成功运行后运行的任务

Question

有没有办法添加一个任务，一旦所有其他任务在同一个 DAG 中成功运行，就可以运行，请参阅下面的我当前的 DAG。

例如，我当前的任务按以下顺序运行，但我想在以下所有任务运行后添加new_task。如果我把它留在下面，它就不会运行new_task：

for endpoint in ENDPOINTS:
      latest_only = (operator...)
      s3 = (operator...)
      etc ....


      latest_only >> s3 >> short_circuit
      short_circuit >> snowflake >> success
      short_circuit >> postgres >> success
      if endpoint.name == "io_lineitems":
        success >> il_io_lineitems_tables
copy_monthly_billing >> load_io_monthly_billing_to_snowflake
copy_monthly_billing >> load_io_monthly_billing_to_postgres
new_task

Answer 1

使用触发规则根据上游任务成功状态触发 trigger_rules