Eliãn
09/09/2022, 12:56 PMpython
configs = {
'products': {
'schedule_interval':'@weekly'
},
'customers': {
'schedule_interval':'@daily'
},
}
def generate_dag(dag_id, start_date, schedule_interval, details):
with DAG(dag_id, start_date=start_date, schedule_interval=schedule_interval) as dag:
@task
...
for name, detail in configs.items():
dag_id = f'dag_{name}'
globals()[dag_id] = generate_dag(dag_id, ...)
@noklam something like this