气流 schedule_interval 不工作

airflow schedule_interval not working

我有这样的 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))

我想将它安排在 运行 每天下午 3 点和凌晨 4 点,我将我的 AWS 实例本地时区更改为新西兰。

在气流网络 UI 中,在右上角,我仍然看到气流显示 UTC 时间。但是,如果我看到我的 DAG 的最后一个 运行(我的手册 运行 到 UI),它会显示新西兰时间。所以我假设计划在当地时区(NZ 时间)工作,所以试图在该时区安排,但它没有按时触发。工作没有按时工作。如何解决?

谢谢,

现在(从 Airflow 1.9 开始)Airflow 仅在 UTC 中运行。 "solution" 现在是将时间表设置为 UTC 时间——尽管那太可怕了。

好消息是 master 分支(将在下一个非点版本 Airflow 1.10 中)支持时区! https://github.com/apache/incubator-airflow/blob/772dbae298680feb9d521e7cd5526f4059d7cb69/docs/timezone.rst