首页 > 解决方案 > Airflow DAG 在每小时计划中缺少运行

问题描述

我遇到了一个相当奇怪的问题,即每小时一次的 Dag 每天都错过了预定的跑步。

这个每小时 dag 计划为 0 * * * *,但它不会生成 0500 小时的运行

在此处输入图像描述

我有另一个每日 Dag,它对该每小时 dag 中的任务具有交叉依赖关系。每日 dag 计划为 0 5 * * *

我不知道是什么导致 Airflow 跳过安排整个运行。我的 dag 没有任何并发​​或 max_active_runs 设置。也没有任务级别的并发限制(池、task_concurrency)。即使设置了它们,我相信这些参数只会将 dags 或任务的执行排队,而不是完全跳过计划运行(也许有人确认)?

我猜这将是全局 Airflow 设置中的某些内容,它限制了同时安排的活动 dag 运行的数量。有什么建议吗?我们的基础架构团队很久以前就搭建好了环境,所以我需要提供一些说明让他们看看

气流版本 1.10.12

标签: airflow

解决方案


推荐阅读