No fluxo de ar, o que eu estou tentando fazer uma função que é dedicado a gerar DAGs em um arquivo:
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
Em seguida, em um outro arquivo que eu estou tentando importar os dags a partir de um arquivo separado:
load_dags.py:
from dynamic_dag import generate_dag
globals()["Dynamic_DAG_A"] = generate_dag('A')
No entanto, os dags não são exibidos na INTERFACE do usuário da web. Mas, se eu faço-los em um único arquivo, conforme código abaixo, ele vai funcionar:
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')
Eu estou querendo saber por que fazê-lo em dois arquivos separados não funciona.