gpt4 book ai didi

Airflow 未在/usr/local/airflow/dags 中加载 dags

转载 作者:行者123 更新时间:2023-12-03 14:33:43 28 4
gpt4 key购买 nike

Airflow 似乎跳过了我添加到/usr/local/airflow/dags 的 dags。

当我跑

airflow list_dags

输出显示
[2017-08-06 17:03:47,220] {models.py:168} INFO - Filling up the DagBag from /usr/local/airflow/dags


-------------------------------------------------------------------
DAGS
-------------------------------------------------------------------
example_bash_operator
example_branch_dop_operator_v3
example_branch_operator
example_http_operator
example_passing_params_via_test_command
example_python_operator
example_short_circuit_operator
example_skip_dag
example_subdag_operator
example_subdag_operator.section-1
example_subdag_operator.section-2
example_trigger_controller_dag
example_trigger_target_dag
example_xcom
latest_only
latest_only_with_trigger
test_utils
tutorial

但这不包括/usr/local/airflow/dags 中的 dags
ls -la /usr/local/airflow/dags/
total 20
drwxr-xr-x 3 airflow airflow 4096 Aug 6 17:08 .
drwxr-xr-x 4 airflow airflow 4096 Aug 6 16:57 ..
-rw-r--r-- 1 airflow airflow 1645 Aug 6 17:03 custom_example_bash_operator.py
drwxr-xr-x 2 airflow airflow 4096 Aug 6 17:08 __pycache__

Airflow 是否需要满足其他一些条件才能识别 DAG 并加载它?

最佳答案

我的 dag 正在加载,但 DAG 的名称错误。我期望 dag 由文件命名,但名称由 DAG 构造函数的第一个参数决定

dag = DAG(
'tutorial', default_args=default_args, schedule_interval=timedelta(1))

关于 Airflow 未在/usr/local/airflow/dags 中加载 dags,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/45534535/

28 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com