Aus irgendeinem Grund scheint Airflow nicht den letzten Lauf für einen Tag mit einem wöchentlichen Zeitplanintervall auszulösen.

Aktuelles Datum

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

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 Scheduler

$ airflow scheduler -d superdag

Sie würden insgesamt vier DAG-Läufe erwarten, da der Scheduler die Werte für 7/18, 7/25, 8/1 und 8/8 zurückfüllen sollte. Der letzte Lauf ist jedoch nicht geplant.

EDIT 1:

Ich verstehe, dass Vineet, obwohl das mein Problem nicht zu erklären scheint.

In meinem obigen Beispiel ist das Startdatum der DAG der 18. Juli.

rster DAG-Lauf: 18. Juweiter DAG-Lauf: 25. Ju Dritter DAG-Lauf: 1. August Vierter DAG-Lauf: 8. August (nicht ausgeführt)

Wo jeder DAG-Lauf Daten aus der vorherigen Woche verarbeitet.

Heute, da der 9. August ist, würde ich erwarten, dass der vierte DAG-Lauf mit einem Ausführungsdatum vom 8. August ausgeführt wurde, bei dem Daten für die letzte Woche (1. August bis 8. August) verarbeitet werden, dies jedoch nicht.