0

环境:1.8.2

气流元数据库表:dag_run 列:end_date 列 end_date
的 99% 值:为空 列 end_date 的 1% 值:不为空

问:为什么?有什么想法/设置来解决这种情况吗?

4

1 回答 1

0

看起来代码中只有两个地方设置了 dag 运行结束日期。当 dag 运行超时并且您在 UI 中将 dag 运行设置为失败/成功时

如果你想解决这个问题,我会查看 DagRun 类的update_state方法,如果运行被设置为终止状态,则设置结束日期。当然,您应该将您的更改提交到 github 的 PR!

于 2018-02-11T23:15:45.710 回答