小编Din*_*ane的帖子

气流网络服务器

DAG 已暂停：

Airflow Scheduler 持续运行 DAG

我有一个全新安装的 Airflow。所有暂停的示例都运行良好。新的 DAG 示例即使在 Web 上暂停时也会继续运行。PAUSING/unPAUSING 在默认示例上运行良好。另一个问题是，它每 6 小时安排一次。为什么要继续尝试运行 DAG？

SWAT_Tutorial_01.py

from airflow import DAG
from airflow.operators.bash_operator import BashOperator
from datetime import datetime, timedelta

default_args = {'owner': 'airflow',
        'depends_on_past': False,
        'start_date': datetime(2018, 3, 16),
        'email': ['sample@scholastic.com'],
        'email_on_failure': False,
        'email_on_retry': False,
        'retries': 1,
        'retry_delay': timedelta(minutes=5),
        # 'catchup': False,
        # 'queue': 'bash_queue',
        # 'pool': 'backfill',
        # 'priority_weight': 10,
        # 'end_date': datetime(2016, 1, 1),
}

dag = DAG( 'SWAT.Tutorial_01', default_args=default_args, schedule_interval=timedelta(hours=6))

# t1, t2 and t3 …