2016-10-19 5 views
0

Ich habe meine Aufgabe eingestellt, täglich ausgeführt zu werden, doch das Programm läuft einen Tag hinterher, ich fragte mich, ob es eine Antwort darauf gab?Airflow nicht korrekt geplant

default_args ={ 
    'owner': 'airflow', 
    'start_date' : datetime(year=2016,month=10,day=8), 
    'depends_on_past': True, 
    'email_on_failure': False, 
    'email_on_retry': True, 
    'retries:': 3, 
    'retry_delay' :timedelta(minutes=2)} 

Ich bin auf PST, also auch wenn der Scheduler auf UTC ist, sollte es nicht beeinflussen, warum es durch 2 Tage ausgeschaltet ist, da UTC schneller ist. Und nach einem Tag. Wie in, ab 18 Oktober 18:00 Uhr PST, der letzte Lauf der geplanten Aufgabe ist 17. Oktober, nicht am 18. Oktober.

Antwort

1

Airflow terminiert dags für das vorherige Zeitplan-Intervall.

A dag mit dem Cron-Zeitplan @daily die execution_date (ging in die ausgeführte Aufgabe Kontext) von 2016/10/14 00:00:00 daher erhalten, wenn sie auf 2016/10/15 00:00:00 laufen. Die Idee ist, dass, wenn ein dag bei 2016/10/15 00:00:00 läuft es wahrscheinlich einen Job im Zeitraum 2016/10/14 00:00:00 bis 2016/10/15 00:00:00 ausgeführt wird.