我的气流调度程序中有两个 DAG,它们过去一直在工作。在需要重建运行气流的 docker 容器后,它们现在陷入了困境queued。在我的例子中,DAG 是通过 REST API 触发的,因此不涉及实际的调度。
由于有很多类似的帖子,我从一个类似的问题中浏览了这个答案的清单:
是的!
是的!
是的,两个 DAGS 都显示在 WebUI 中,并且没有显示任何错误。
是的,两个 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)
不,我通过 REST API 手动触发我的 DAG。
查找任务无法退出状态queued并运行的原因的最佳方法是什么?
编辑:
出于好奇,我尝试从 WebUI 内触发 DAG,现在两个运行都已执行(从 WebUI 触发的一个失败,但这是预期的,因为没有设置配置)

| 归档时间: |
|
| 查看次数: |
5479 次 |
| 最近记录: |