气流,创建时启用dag

2024-06-16 11:31:32 发布

您现在位置:Python中文网/ 问答频道 /正文

当我用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”有关,但是找不到参数的名称。在


Tags: falsehello参数datesettingsonemailstart
2条回答

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在创建时暂停。在

[core]
dags_are_paused_at_creation = False

设置以下环境变量。在

^{pr2}$

如果要将此设置限制为单个DAG,可以将is_paused_upon_creationDAG参数设置为True。在

示例:

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

相关问题 更多 >