气流在定义中按 dag 取消暂停

Question

有什么办法让服务器保持默认..

dags_are_paused_at_creation = True

...但是对于一个特定的 dag，默认情况下将其定义为未暂停？

dag = DAG(
    dag_id=MISC_DAG_ID,
    default_args=default_args,
    params=params,
    schedule_interval=None,
    concurrency=1,
    max_active_runs=1,
    is_paused=False
)

Answer 1

来自documentation

is_paused_upon_creation (bool or None) – 指定第一次创建 dag 时是否暂停。如果 dag 已经存在，则此标志将被忽略。如果未指定此可选参数，将使用全局配置设置。

所以设置 is_paused_upon_creation=False

Answer 2

这是一个函数，你必须用

调用它

dag.is_paused(False) 

您不能直接访问该属性，因为它是私有的，只需使用函数