【发布时间】:2020-12-29 20:08:38
【问题描述】:
我使用LatestOnlyOperator 作为我计划的 DAG 的第一个任务。
如何重新运行 不是最后一个的 dagrun?
【问题讨论】:
我使用LatestOnlyOperator 作为我计划的 DAG 的第一个任务。
如何重新运行 不是最后一个的 dagrun?
【问题讨论】:
LatestOnlyOperatorskips externally triggered dags.
转到Airflow UI中的Tree View,点击相关的dagrun(上面的圆圈,不是任何正方形),然后点击Edit,标记External Trigger 和 保存。
之后再次点击 dagrun 并选择 Clear。
# If the DAG Run is externally triggered, then return without # skipping downstream tasks
【讨论】: