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?