エアフローは、1分後に自分のタスクを殺す

Question

私が持っている次のような二つのタスクと非常にシンプルなDAG、：

：

default_args = { 
    'owner': 'me', 
    'start_date': dt.datetime.today(), 
    'retries': 0, 
    'retry_delay': dt.timedelta(minutes=1) 
} 

dag = DAG(
    'test DAG', 
    default_args=default_args, 
    schedule_interval=None 
) 

t0 = PythonOperator(
    task_id="task 1", 
    python_callable=run_task_1, 
    op_args=[arg_1, args_2, args_3], 
    dag=dag, 
    execution_timeout=dt.timedelta(minutes=60) 
) 

t1 = PythonOperator(
    task_id="task 2", 
    python_callable=run_task_2, 
    dag=dag, 
    execution_timeout=dt.timedelta(minutes=60) 
) 

t1.set_upstream(t0) 

は、しかし、私はそれを実行したとき、私はログに以下を参照してください。

[2017年10月17日16：18：35519] {jobs.py:2083} INFO - タスクは、他の有用なエラーログなし 戻りコード-9

で終了しました。誰もそれを前に見た？ DAGを間違って定義しましたか？どんな助けにも感謝！

Answer 1

どのバージョンのエアフローを使用していますか？
1.8より、エアフローは、動的開始日にスケジューラを寛大にしません。https://github.com/apache/incubator-airflow/blob/master/UPDATING.md#less-forgiving-scheduler-on-dynamic-start_date。
特定の日付を指定してください。