2016-10-19 9 views
0

Я поставил задачу на ежедневную работу, но программа запускается на следующий день, мне было интересно, есть ли ответ на этот вопрос?Воздушный поток не правильно настроен

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)} 

Я на PST, так что даже если планировщик на UTC, это не должно повлиять, почему он выключен на 2 дня, так как UTC быстрее. И к дню. Как и в случае с 18 октября 18:00 по тихоокеанскому времени, последний запуск запланированной задачи - 17 октября, а не 18 октября.

ответ

1

Расписания воздушного потока затухают за предыдущий период.

даг с графиком хронами @daily будет, следовательно, получить execution_date (принят в контекст Выполненного задания) из 2016/10/14 00:00:00 при запуске на 2016/10/15 00:00:00. Идея состоит в том, что, если даг работает на 2016/10/15 00:00:00, он, вероятно, выполняет определенную работу в течение периода 2016/10/14 00:00:00 до 2016/10/15 00:00:00.