小编Sai*_*mon的帖子

气流不回填最新运行

出于某种原因,Airflow 似乎不会触发具有每周计划间隔的 dag 的最新运行。

当前的日期:

$ date
$ Tue Aug  9 17:09:55 UTC 2016
Run Code Online (Sandbox Code Playgroud)

DAG:

from datetime import datetime
from datetime import timedelta

from airflow import DAG
from airflow.operators.bash_operator import BashOperator

dag = DAG(
    dag_id='superdag',
    start_date=datetime(2016, 7, 18),
    schedule_interval=timedelta(days=7),
    default_args={
        'owner': 'Jon Doe',
        'depends_on_past': False
    }
)

BashOperator(
    task_id='print_date',
    bash_command='date',
    dag=dag
)
Run Code Online (Sandbox Code Playgroud)

运行调度程序

$ airflow scheduler -d superdag
Run Code Online (Sandbox Code Playgroud)

您预计总共有四次 DAG 运行,因为调度程序应该回填 7/18、7/25、8/1 和 8/8。但是,未安排最后一次运行。

气流 DAG 运行

在此处输入图片说明

编辑 1:

我理解 Vineet 虽然这似乎并不能解释我的问题。

在我上面的示例中,DAG 的开始日期是 7 月 18 日。

  • 第一次 DAG 运行:7 月 18 …

airflow

3
推荐指数
1
解决办法
2431
查看次数

标签 统计

airflow ×1