Только первая задача в dag выполняется в потоке воздуха, когда schedule_interval установлен в @once

Question

Я тестировал воздушный поток 1.10, используя следующий знак:

dag = DAG(dag_id='something',
start_date=datetime(2019,1,2).replace(tzinfo=pytz.timezone('US/Eastern')),
schedule_interval='@once',
...)

У меня есть несколько операторов bash:

o1 = BashOperator(bash_command="echo 0", dag=dag, task_id='o1')
o2 = BashOperator(bash_command="echo 0", dag=dag, task_id='o2')
o3 = BashOperator(bash_command="echo 0", dag=dag, task_id='o3')
o1 >> o2 >> o3

Анализ потока воздуха без проблем отображается и отображает тег.Однако, когда я запускаю метку, запускается только первая задача, и она помечается как зеленая.Затем отметка остается в рабочем состоянии, в то время как все остальные задачи отмечены белым, что означает, что они не собраны планировщиком.Затем я получаю электронное письмо со словами:

Executor reports task instance finished (success) although the task says its queued. Was the task killed externally?

Answer 1

Ладно. Думаю, я понял, проблема в стартовой дате с учетом часового пояса. Проблема ушла, как только я удалил replace(tzinfo=pytz.timezone('US/Eastern'))