0

我正在努力解决一个我似乎无法弄清楚的奇怪问题。我有一个没有什么花哨的基本 DAG。它只是利用 bash 运算符来启动 Python 脚本。

我有这个 DAG 计划在每个星期一运行。当我打开网络服务器中的 dag 时，它开始回填到 9 月 25 日。但是，它不会在 10 月 2 日回填。当我将日程安排从每周更改为每天时，它工作正常。

这是我的 DAG 设置。

default_args = {
    'owner': 'xxxxx',
    'depends_on_past': False,
    'email': ['xxxxxx'],
    'start_date': datetime(2017, 9, 1, 0, 0),
    'email_on_failure': False,
    'email_on_retry': False,
    'retries': 2,
    'retry_delay': timedelta(minutes=10),
}


# Create DAG
dag = DAG(dag_id='IFS_weekly_forecast',
            schedule_interval = '0 8 * * MON',
          default_args=default_args)

从这张照片中可以看出，回填到 25 日为止都很好。之后没有新任务排队。

DAG 运行

我在这里做错了什么？我有其他 DAG 已经运行好几个星期了。我还重新启动了调度程序和网络服务器，这没有帮助。

编辑：

下面的主题似乎涵盖了同样的问题。但是，这改变了我的问题。如何让气流在给定日期每周运行，而不是等待整个时间段结束？

气流不会回填最新运行

4

0 回答 0