планировщик воздушного потока выполняет dag раньше, чем дата его начала

Я пытаюсь выполнить даг на start_date= datetime.strptime('3/2/2020 8:20:00', '%m/%d/%Y %H:%M:%S') и schedule_interval=schedule_interval='20/5 8 * * *', но даг выполняется до фактической start_date.

from datetime import datetime
from airflow import DAG
from airflow.operators.dummy_operator import DummyOperator
from airflow.operators.python_operator import PythonOperator

def print_hello():
    return 'Hello world!'

default_args = {
'owner':'admin',
'retries': 0,
'email_on_retry': False,
'depends_on_past': False,
'email_on_failure': False,
'priority_weight': 10,
'email': [''],
'queue':'bash_queue',
'start_date': datetime.strptime('3/2/2020 8:20:00', '%m/%d/%Y %H:%M:%S'),
}

dag = DAG('somename',
default_args=default_args,
catchup = False,
schedule_interval='20/5 8 * * *'
 )
dummy_operator = DummyOperator(task_id='dummy_task', retries=3, dag=dag)

hello_operator = PythonOperator(task_id='hello_task', python_callable=print_hello, dag=dag)

dummy_operator >> hello_operator 

может ли кто-нибудь помочь мне понять странное поведение воздушного потока?


person Akul Sharma    schedule 03.03.2020    source источник
comment
ты исправил?.   -  person joss    schedule 07.04.2020
comment
пожалуйста, взгляните на [airflow.apache.org/docs/stable/scheduler.html ], там это тоже объясняется. Если есть вопросы, спрашивайте!   -  person Akul Sharma    schedule 09.07.2020