2017-06-22 68 views
0

我不明白我需要运行哪些命令才能获得DAG预定。假设我使用airflow test dag_name task_id_1 2017-06-22测试了DAG,第二项任务使用了airflow test dag_name task_id_2 2017-06-22运行预定DAG的Airflow命令的顺序是什么?

我跑airflow trigger_dag dag_name,但那是为了实例化DAG恰好那一刻吗?

比方说,我想dag_name的定时/调度的样子:

'start_date': datetime.datetime(2017, 6, 22, 18), 
'end_date': datetime.datetime(2017, 6, 23, 20), 
schedule_interval = datetime.timedelta(1) 

所以我只想调度和运行它今天和明天,从今天开始@ 18:00 UTC与后24小时那。

现在我应该运行什么命令或命令列表?每次我想要添加和计划DAG时,是否必须运行airflow scheduler

回答

0

trigger_dag会立即触发DAG运行。要安排DAG,只需将它放在DAG文件夹中,转到Airflow UI并启用DAG。