Airflow: बनाने डेग से एक अलग फाइल

में 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')

मैं सोच रहा हूँ क्यों कर रही है यह दो अलग-अलग फ़ाइलें काम नहीं करता है ।