当我用python创建一个空气流动的DAG时,我可以传递一些参数。在
SETTINGS = {
'owner': 'hello',
'depends_on_past': False,
'start_date': datetime(2019, 1, 1),
'email_on_failure': False,
'email_on_retry': False,
'retries': 1,
'retry_delay': timedelta(minutes=5),
}
dag = DAG(dag_id,
schedule_interval='@daily',
catchup=False,
default_args=SETTINGS)
但是,当我这样做的时候,我仍然需要在界面上单击并启用DAG。我想知道是否有一个设置传递给直接做它的创造。我想这和“pause”有关,但是找不到参数的名称。在
DAG有一个参数:
is_paused_upon_creation
。我没有尝试使用它,但是您可以在源代码中找到一些信息:https://github.com/apache/airflow/blob/master/airflow/models/dag.py将
airflow.cfg
中的dags_are_paused_at_creation
更改为False
。默认值是True
,因此您的dag在创建时暂停。在设置以下环境变量。在
^{pr2}$如果要将此设置限制为单个DAG,可以将
is_paused_upon_creation
DAG参数设置为True
。在示例:
相关问题 更多 >
编程相关推荐