airflow自动生成dag
阅读原文时间:2023年07月11日阅读:3

def auto_create_dag():
dag_list=[]
dag = DAG()
dag_list.append(dag)
return dag_list
dags = auto_create_dag()
for dag in dags:
globals()[dag.dag_id] = dag

转载自:https://zhuanlan.zhihu.com/p/97525893

手机扫一扫

移动阅读更方便

阿里云服务器
腾讯云服务器
七牛云服务器

你可能感兴趣的文章