python之Airflow ，在创建时启用 dag

当我在 python 中创建带有 Airflow 的 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。我想知道是否有一个设置可以直接在创建时传递。我认为它与“暂停”有关但找不到参数名称。

请您参考如下方法:

将 airflow.cfg 中的 dags_are_paused_at_creation 更改为 False。默认值为 True，因此您的 dags 在创建时暂停。

[core] 
dags_are_paused_at_creation = False 

设置以下环境变量。

AIRFLOW__CORE__DAGS_ARE_PAUSED_AT_CREATION=False 

如果您想限制单个 DAG 的此设置，您可以将 is_paused_upon_creation DAG 参数设置为 True。

例子:

DAG(dag_id='my-dag', is_paused_upon_creation=True)