Airflow DAG未使用自定义MongoDB连接，默认使用mongo_default问题求助

我最近碰到了Apache Airflow的一个棘手问题：我的DAG完全不使用我特意配置的自定义MongoDB连接，反而默认走了mongo_default连接，这直接导致我的工作流连不上正确的MongoDB实例，卡得我没法推进工作。

我已经做了这些操作：

• 在Airflow UI的「Admin > Connections」页面创建了一个自定义MongoDB连接，设置了专属的连接ID（比如my_mongo_conn）
• 在DAG代码里明确指定了使用这个自定义连接，代码片段如下：

from airflow.providers.mongo.hooks.mongo import MongoHook

def my_task():
    mongo_hook = MongoHook(mongo_conn_id='my_mongo_conn')
    # 后续业务代码...

my_task = PythonOperator(
    task_id='my_mongo_task',
    python_callable=my_task,
    dag=dag
)

预期行为 #

DAG应该正常调用我在Airflow UI中定义的my_mongo_conn连接，连接到目标MongoDB实例。

实际结果 #

当我触发DAG运行时，Airflow完全忽略了我指定的自定义连接，一个劲地尝试使用默认的mongo_default连接，导致工作流无法正常执行。

备注：内容来源于stack exchange，提问作者mhhnull