从终端触发 Airflow DAG 不工作

Question

我正在尝试使用气流来定义我想从命令行手动触发的特定工作流程。

我创建了 DAG 并添加了一堆任务。

 dag = airflow.DAG(
    "DAG_NAME",
    start_date=datetime(2015, 1, 1),
    schedule_interval=None,
    default_args=args)

然后我在终端运行

airflow trigger_dag DAG_NAME

没有任何反应。调度程序在另一个线程中运行。非常感谢任何方向。谢谢你

原文由 amustafa 发布，翻译遵循 CC BY-SA 4.0 许可协议

Answer 1

我刚遇到同样的问题。

假设您能够在 airflow list_dags 或通过网络服务器看到您的 dag，那么：

我不仅必须在 Web UI 中打开 dag，而且还必须确保 airflow scheduler 作为一个单独的进程运行。

一旦我运行了调度程序，我就能够使用 airflow trigger_dag <dag_id>

我的 dag 配置与您的配置没有显着差异。我还有 schedule_interval=None

原文由 neolytics 发布，翻译遵循 CC BY-SA 3.0 许可协议