环境:1.8.2
气流元数据库表:dag_run 列:end_date 列 end_date
的 99% 值:为空 列 end_date 的 1% 值:不为空
问:为什么?有什么想法/设置来解决这种情况吗?
环境:1.8.2
气流元数据库表:dag_run 列:end_date 列 end_date
的 99% 值:为空 列 end_date 的 1% 值:不为空
问:为什么?有什么想法/设置来解决这种情况吗?
看起来代码中只有两个地方设置了 dag 运行结束日期。当 dag 运行超时并且您在 UI 中将 dag 运行设置为失败/成功时。
如果你想解决这个问题,我会查看 DagRun 类的update_state方法,如果运行被设置为终止状态,则设置结束日期。当然,您应该将您的更改提交到 github 的 PR!