2017-12-24 13 views
1

Ich baute mein DAG wie folgt aus:unerwünschte DAG läuft in Airflow

default_args = { 
    'owner': 'Aviv', 
    'depends_on_past': False, 
    'start_date': datetime(2017, 1, 1), 
    'email': ['[email protected]'], 
    'email_on_failure': False, 
    'email_on_retry': False, 
    'retries': 0, 
    'retry_delay': timedelta(minutes=1) 
} 

dag = DAG(
    'MyDAG' 
    , schedule_interval=timedelta(minutes=3) 
    , default_args=default_args 
    , catchup=False 
) 

und aus irgendeinem Grund, wenn ich die DAG un-Pause, die zwei Mal sofort ausgeführt wird. Irgendeine Idee warum? Und gibt es irgendeine Regel, die ich anwenden kann, um dieser DAG zu sagen, dass sie nie mehr als einmal in der gleichen Zeit läuft?

Antwort

2

Sie max_active_runs wie folgt angeben:

dag = airflow.DAG(
    'customer_staging', 
    schedule_interval="@daily", 
    dagrun_timeout=timedelta(minutes=60), 
    template_searchpath=tmpl_search_path, 
    default_args=args, 
    max_active_runs=1) 

Ich habe es nie passiert gesehen, sind Sie sicher, dass diese Läufe nicht Aufschüttungen sind, finden Sie unter: https://stackoverflow.com/a/47953439/9132848

0

Ich denke sein, weil Sie verpasst haben Die geplante Zeit und die Luftströmung füllen sie automatisch wieder auf, wenn Sie sie wieder einschalten. Sie können dies unter catchup_by_default = False in der airflow.cfg deaktivieren.

Verwandte Themen