Airflow:สร้าง DAG จากแฟ้มแยก

ใน airflow ฉันกำลังพยายามทำเป็นฟังก์ชันนั่นคืออุทิศตนเพื่อสร้าง DAGs อยู่ในแฟ้ม:

dynamic_dags.py:

def generate_dag(name):
    with DAG(
        dag_id=f'dag_{name}',
        default_args=args,
        start_date=days_ago(2),
        schedule_interval='5 5 * * *',
        tags=['Test'],
        catchup=False
    ) as dag:
        dummy_task=DummyOperator(
            task_id="dynamic_dummy_task",
            dag=dag
        )
    return dag

แล้วในอีกแฟ้มฉันพยายามที่จะใช้นำเข้าที่ dags จากแยกเป็นแฟ้ม:

load_dags.py:

from dynamic_dag import generate_dag
globals()["Dynamic_DAG_A"] = generate_dag('A')

อย่างไรก็ตามที่ dags ไม่ได้แสดงบนเว็บส่วนติดต่อผู้ใช้ขอ. แต่ถ้าฉันทำพวกเขาด้วยการโดดครั้งเดียวแฟ้มที่ด้านล่างรหัสมันจะทำงาน:

def generate_dag(name):
    with DAG(
        dag_id=f'dag_{name}',
        default_args=args,
        start_date=days_ago(2),
        schedule_interval='5 5 * * *',
        tags=['Test'],
        catchup=False
    ) as dag:
        dummy_task=DummyOperator(
            task_id="dynamic_dummy_task",
            dag=dag
        )
    return dag

globals()["Dynamic_DAG_A"] = generate_dag('A')

ฉันสงสัยว่าทำไมถึงทำมันในสองคนแยกออกแฟ้มที่ไม่ได้ทำงาน