공기 흐름을 만들기 DAG 에서 별도의 파일

에서 기류,내가 만들려고 노력하는 기능에 전념하고 생성 Dag 에서 파일

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

그런 다음 다른 파일에 있는 내가 가져오려고 하 dag 에서 별도의 파일:

load_dags.py:

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

그러나,dag 은 표시되지 않은 web UI. 하지만 내가 그들을에 하나의 파일로 아래 코드는,작동합니다:

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')

저는 왜 그 일을에서 두 개의 파일이 작동하지 않습니다.