Airflow（kubernetes 执行器）- 由于 DAG 记录被锁定而跳过调度

Question

需要一些帮助来理解 DagRun 调度的锁定行为。

我们注意到，在几次 DagRun 后，后续运行不再被安排，并注意到日志中的以下内容。

{scheduler_job_runner.py:1426} 信息 - DAG dag-test 调度被跳过，可能是因为 DAG 记录被锁定。

我们目前正在运行一个调度程序 Pod。想要了解一般的锁定行为以及在什么情况下会删除锁定。

目前的解决方法是重新启动调度程序 Pod 并释放锁，但这对于生产来说并不理想。想了解 DagRun 一般何时释放锁？

感谢任何帮助/指示。

Answer 1

您是否尝试清理所有 DagRuns. 在 UI 中，转到浏览 -> DAG 运行 -> 选择所有 dag 运行 -> 操作 -> 删除/。