如何跳过该特定任务实例?
- 我不想对代码进行任何更改,因为我无权访问 Prod 代码,并且任务现在位于 Prod 环境中。
- 有什么方法可以使用命令行来做到这一点吗?
感谢对此的任何帮助。
您可以使用以下命令将不需要的任务标记为已成功run
命令。标记为成功的任务将不再运行。
假设有一个有ID的DAGa_dag
以及三个带有 ID 的任务dummy1
, dummy2
, dummy3
。我们想跳过dummy3
下一次 DAG 运行的任务。
首先,我们得到下一个执行日期:
$ airflow next_execution a_dag
2020-06-12T21:00:00+00:00
然后我们标记dummy3
在此执行日期成功:
$ airflow run -fAIim a_dag dummy3 '2020-06-12T21:00:00+00:00'
当然,我们可以检查任务状态。对于跳过的任务,它将是success
:
$ airflow task_state a_dag dummy3 '2020-06-12T21:00:00+00:00'
...
success
对于其余任务,状态将是None
:
$ airflow task_state a_dag dummy1 '2020-06-12T21:00:00+00:00'
...
None
本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)