时间戳

首页 > 解决方案 > 最初打开时如何自动停止气流运行（在计划外的时间）？

airflow - 最初打开时如何自动停止气流运行（在计划外的时间）？

问题描述

最初打开时如何自动停止气流运行（在计划外的时间）？

我的狗看起来像...

default_args = {
    'owner': 'rvillanueva',
    'depends_on_past': False,
    'start_date': datetime(2019, 10, 13),
    'email': ['me@co.com'],
    'email_on_failure': True,
    # 'email_on_retry': False,
    'retries': 0,
    'retry_delay': timedelta(minutes=5),
    'max_active_runs': 3,
    # 'queue': 'bash_queue',
    # 'pool': 'backfill',
    # 'priority_weight': 10,
    # 'end_date': datetime(2016, 1, 1),
}

dag = DAG('mydag', default_args=default_args, catchup=False, schedule_interval="10 22 * * *")
...

我曾认为拥有depends_on_past=False或catchup=False足以阻止这种情况，但是当它们在网络服务器 UI 中打开时，dag 仍然运行一次（在某些情况下，导致它们最终在实际计划时间重叠运行）。

有没有办法阻止这种情况？

标签： airflow

解决方案

推荐阅读