python - Airflow 1.9.0 无法对任务进行排队

标签 python python-3.x airflow

我遇到一个问题,任务将成功完成,但下游任务无法识别这一事实,因此不会排队。

图表 A:任务成功

Task says success

附件 B:stage_photos 未排队:

enter image description here

这是一个已知问题吗?有人有什么建议吗?这似乎是从 1.8 升级到 1.9 开始的,并且也仅适用于某些类型的任务(传感器、返回值的 python 运算符)。

最佳答案

我猜测您多次运行 DAG 均未成功,这就是为什么它无法在 depends_on_past 设置为 True 的情况下运行。

来自官方docs :depends_on_past( bool 值),当设置为 True 时,如果任务的先前计划未成功,则防止触发任务。

如果根据我的猜测,上一次运行尚未达到其最终状态,且 stage_photos 在上一次运行中已成功,则这在当前运行中将不起作用。

关于python - Airflow 1.9.0 无法对任务进行排队,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/52545295/

相关文章:

python - 计算可以从字符串组成的唯一字符串的数量

python - 将一个表面位 block 传输到另一个表面上而不合并 alpha

airflow - 如何检查 Airflow 测试的输出?

google-cloud-platform - 访问 Cloud Composer 的 Airflow Rest API 时收到 HTTP 401

python - 在保持值(value)的同时在循环内进行比较

python - 与 Airflow 的集成测试

python - 创建随机数据库并将其从 numpy 转换为 pandas

Python - 将数据附加到文件,Line.split

javascript - 基于地理编码的 IP 居中谷歌地图

python - 在 linux 上升级 python3 中使用的 SQLite3 版本?