我有一个包含数万个任务的Apache AirflowDAG,在运行之后,我发现其中有几个任务失败了。 我修复了导致某些任务失败的错误,我只想重新运行失败的任务。这篇SO帖子建议使用图形用户界面“清除”失败的任务: How to restart a failed task on Airflow 如果您有少量失败的任务,则此方法有效。我想知道我们是否可以绕过GUI,通过命令行来做有问题的事情,比如: airflow_c
我试图在测试环境中使用多个任务来测试一个守护进程。我能够测试与dag关联的单个任务,但我希望在dag中创建多个任务,并启动第一个任务。用于测试我正在使用的dag中的一个任务。但是,当我在后台的下游有一个接一个的任务时,同样的情况就不起作用了。from airflow import DAG
from airflow.operators.bash_operator import Bas