我不明白需要运行哪些命令才能安排 DAG。假设我使用 DAG 测试了 DAG airflow test dag_name task_id_1 2017-06-22
,第二个任务使用airflow test dag_name task_id_2 2017-06-22
.
我跑了airflow trigger_dag dag_name
,但那是为了在那一刻实例化 DAG 吗?
假设我希望dag_name
's 时间/调度看起来像:
'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 小时。
现在我应该运行什么命令或命令列表?airflow scheduler
每次我想添加和安排 DAG 时都必须运行吗?