2017-05-29 114 views

回答

0

您可以創建DAG爲:

dag = DAG("Your_dag", default_args=default_args, schedule_interval="0 19 * * 1-4") 
+0

這是爲星期四,但我需要它運行在星期五11。我如何適應? –

+0

我想你應該把它作爲兩個不同的DAG來處理。 –

0

你可以做這樣的事情:

schedules = { 
    'M-Th': '0 19 * * 1-4', 
    'F': '0 23 * * 5', 
} 

for name, schedule in schedules.items(): 
    globals()[name] = DAG('<base_dag_name.' + name, default_args=default_args, schedule_interval=schedule) 

這將創建兩個來自單個文件的DAG。 DAG需要在全球範圍內得到Airflow的認可。