0

我不明白需要运行哪些命令才能安排 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 时都必须运行吗?

4

1 回答 1

1

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

于 2017-06-26T09:14:16.960 回答