出于某种原因,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。但是,未安排最后一次运行。
编辑 1:
我理解 Vineet 虽然这似乎并不能解释我的问题。
在我上面的示例中,DAG 的开始日期是 7 月 18 日。
airflow ×1