airflow schedule_interval не работает

У меня вот такой DAG,

dag = DAG('testing',description='Testing DAG',schedule_interval='0 4,15 * * *')

t1 = BashOperator(task_id = 'testing_task',bash_command = 'python /home/ubuntu/airflow/dags/scripts/test.py',dag=dag, start_date=datetime(2018, 2, 8))

Я хочу запланировать его запуск каждый день в 15:00 и 16:00, я изменил местный часовой пояс своего экземпляра AWS на NZ.

В веб-интерфейсе воздушного потока в правом верхнем углу я все еще вижу воздушный поток, показывающий время в формате UTC. Однако, если я вижу последний запуск (мой ручной запуск через пользовательский интерфейс) для моего DAG, он показывает время NZ. Поэтому я предположил, что расписание работает в местном часовом поясе (время Новой Зеландии), поэтому попытался запланировать его в этом часовом поясе, но он не был запущен вовремя. Работа не работала вовремя. Как это решить?

Спасибо,


person ds_user    schedule 07.02.2018    source источник


Ответы (1)


Прямо сейчас (начиная с Airflow 1.9) Airflow работает только по всемирному координированному времени. «Решение» на данный момент - поместить расписание в UTC - как бы ужасно это ни было.

Хорошая новость заключается в том, что в основной ветке (которая будет в следующем выпуске без точки, Airflow 1.10) есть поддержка часовых поясов! https://github.com/apache/incubator-airflow/blob/772dbae298680feb9d521e7cd5526f4059d7cb69/docs/timezone.rst

person Ash Berlin-Taylor    schedule 08.02.2018