планировщик воздушного потока выполняет dag раньше даты его начала - PullRequest
Новая
       44

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

0 голосов
/ 03 марта 2020

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

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

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

...