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
?