我有一个包含数万个任务的 Apache Airflow DAG,运行后发现其中少数任务失败了。
我修复了导致某些任务失败的错误,并且我想重新运行仅失败的任务。
这SO
帖子建议使用 GUI 来“清除”失败的任务:
如何在 Airflow 上重新启动失败的任务 https://stackoverflow.com/questions/43270820/how-to-restart-a-failed-task-on-airflow
如果您有少量失败的任务,则此方法有效。
我想知道我们是否可以绕过 GUI 并通过命令行来解决问题,例如:
airflow_clear_failed_tasks dag_id execution_data
仅清除失败任务的命令已更新。现在是(截至 2021 年 3 月的 Airflow 2.0):
airflow tasks clear [-s START_DATE] [-e END_DATE] --only-failed dag_id
本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)