Nel flusso d'aria, che sto cercando di fare una funzione che è dedicato a generare gruppi di disponibilità del database in un file:
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
Poi, in un altro file che sto cercando di importare i gruppi di disponibilità del database da un file separato:
load_dags.py:
from dynamic_dag import generate_dag
globals()["Dynamic_DAG_A"] = generate_dag('A')
Tuttavia, i gruppi di disponibilità del database non vengono visualizzati sul web UI. Ma se li faccio in un unico file, come di seguito codice, funziona:
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')
Mi chiedo perchè farlo in due file separati, non funziona.