Por alguna razón, Airflow no parece desencadenar la última ejecución de un dag con un intervalo de programación semanal.

Fecha actual:

$ date
$ Tue Aug  9 17:09:55 UTC 2016

TROZO DE CUERO:

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
)

Ejecutar planificador

$ airflow scheduler -d superdag

Es de esperar un total de cuatro ejecuciones de DAG, ya que el planificador debe rellenar para 7/18, 7/25, 8/1 y 8/8. Sin embargo, la última ejecución no está programada.

EDITAR 1:

Entiendo que Vineet, aunque eso no parece explicar mi problema.

En mi ejemplo anterior, la fecha de inicio del DAG es el 18 de julio.

Primera ejecución de DAG: 18 de julioSegunda carrera de DAG: 25 de julioTercera carrera de DAG: 1 de agostoCuarta carrera de DAG: 8 de agosto (no se ejecuta)

Donde cada ejecución de DAG procesa datos de la semana anterior.

Hoy, el 9 de agosto, esperaría que la Cuarta ejecución del DAG se haya ejecutado con una fecha de ejecución del 8 de agosto que procesa los datos de la última semana (del 1 de agosto al 8 de agosto), pero no es así.