Airflow 2.2.4 手动触发的 DAG 卡在“排队”状态

Rol*_*ain 8 airflow

我的气流调度程序中有两个 DAG,它们过去一直在工作。在需要重建运行气流的 docker 容器后,它们现在陷入了困境queued。在我的例子中,DAG 是通过 REST API 触发的,因此不涉及实际的调度。

由于有很多类似的帖子,我从一个类似的问题中浏览了这个答案的清单:

  • 您是否正在运行气流调度程序?

是的!

  • 您是否正在运行气流网络服务器?

是的!

  • 您是否检查过要运行的所有 DAG 是否在 Web UI 中设置为“打开”?

是的,两个 DAGS 都显示在 WebUI 中,并且没有显示任何错误。

  • 您想要运行的所有 DAG 的开始日期是否都是过去的日期?

是的,两个 DAG 的构造函数如下所示:

dag = DAG(
    dag_id='image_object_detection_dag',
    default_args=args,
    schedule_interval=None,
    start_date=days_ago(2),
    tags=['helloworld'],
)
Run Code Online (Sandbox Code Playgroud)
  • 您想要运行的所有 DAG 是否都有 Web UI 中显示的正确时间表?

不,我通过 REST API 手动触发我的 DAG。

  • 如果其他方法都不起作用,您可以使用 Web UI 单击 dag,然后单击“图形视图”。现在选择第一个任务并单击任务实例。在“任务实例详细信息”段落中,您将看到 DAG 正在等待或未运行的原因。

这是本段向我展示的内容的输出: 在此输入图像描述

查找任务无法退出状态queued并运行的原因的最佳方法是什么?

编辑:

出于好奇,我尝试从 WebUI 内触发 DAG,现在两个运行都已执行(从 WebUI 触发的一个失败,但这是预期的,因为没有设置配置) 在此输入图像描述