氣流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開始，在動態start_date，https://github.com/apache/incubator-airflow/blob/master/UPDATING.md#less-forgiving-scheduler-on-dynamic-start_date上，氣流對寬鬆調度程序影響較小。
嘗試給出一個特定的日期。