Airflow None 计划无效。任务仍然运行自动

Question

我有一个 airflow dag，我不想安排。我在我的 dag 文件中使用 schedule_interval:None，但部署后 dag 仍然自动运行。使用的 Airflow 版本：2.1.0

随附气流截图。我在我的 dag 文件中使用了以下 python 代码。

import os
import sys
import logging
import croniter
import datetime
from datetime import timedelta
from airflow import DAG
from airflow.operators.python_operator import PythonOperator



default_args = {
'owner': 'test-owner',
'depends_on_past': True,
'start_date': '2021-11-14',
'email': ['test.owner@gmail.com'],
'email_on_failure': True,
'email_on_retry': True,
'retries': 1,
'retry_delay': timedelta(minutes=5),
'schedule_interval':None,
 }

 dag = DAG(
'test-dag',
default_args=default_args,
description='test description'
)

def test_task(ds, **kwargs):
    print(kwargs)
    print(ds)


task = PythonOperator(
    task_id="test_task",
    provide_context=True,
    python_callable=test_task,
    op_kwargs={"image": "value"},
    dag=dag,
)

我还设置了气流环境变量如下：

AIRFLOW__CORE__LOAD_EXAMPLES: "False"
AIRFLOW__SCHEDULER__DAG_DIR_LIST_INTERVAL: 30
AIRFLOW__CORE__DAGS_ARE_PAUSED_AT_CREATION: "False"

Answer 1

您在 default_args 中设置了 schedule_interval，它会将给定的字典作为参数传播给 DAG 中的所有运算符。但是，schedule_interval 是 DAG 上的一个参数，所以你必须在那里设置它：

 dag = DAG(
'test-dag',
default_args=default_args,
description='test description',
schedule_interval=None,
)

Airflow None 计划无效。任务仍然运行自动

Airflow None Schedule is not working. Tasks are still running automatically

airflow

airflow-scheduler

airflow-2.x

airflow-webserver

Airflow None 计划无效。任务仍然 运行 自动

Airflow None Schedule is not working. Tasks are still running automatically

airflow

airflow-scheduler

airflow-2.x

airflow-webserver

Airflow None 计划无效。任务仍然运行自动