Subdag не выполнен и не показан как «успех»

Question

Я экспериментировал с «example_subdag_operator» в воздушном потоке. После того, как я изменил «start_date» на datetime.now(), а затем вручную запускаю запуск dag. Оператор зеленый, но когда я увеличил масштаб до самого поддага, ничего не выполняется (белый в графическом виде), а «Выполнить» - пустым. \

Я использую новейшую версию, построенную из мастера. Я также тестировал на выпущенной версии. Тем не менее та же проблема \

Это ошибка? Или я что-то пропустил?

from datetime import datetime 

from airflow.models import DAG 
from airflow.operators.dummy_operator import DummyOperator 
from airflow.operators.subdag_operator import SubDagOperator 

from airflow.example_dags.subdags.subdag import subdag 


DAG_NAME = 'example_subdag_operator' 

args = { 
    'owner': 'airflow', 
    'start_date': datetime.now(), 
} 

dag = DAG(
    dag_id=DAG_NAME, 
    default_args=args, 
    schedule_interval="@once", 
) 

start = DummyOperator(
    task_id='start', 
    default_args=args, 
    dag=dag, 
) 

section_1 = SubDagOperator(
    task_id='section-1', 
    subdag=subdag(DAG_NAME, 'section-1', args), 
    default_args=args, 
    dag=dag, 
) 

some_other_task = DummyOperator(
    task_id='some-other-task', 
    default_args=args, 
    dag=dag, 
) 

section_2 = SubDagOperator(
    task_id='section-2', 
    subdag=subdag(DAG_NAME, 'section-2', args), 
    default_args=args, 
    dag=dag, 
) 

end = DummyOperator(
    task_id='end', 
    default_args=args, 
    dag=dag, 
) 

start.set_downstream(section_1) 
section_1.set_downstream(some_other_task) 
some_other_task.set_downstream(section_2) 
section_2.set_downstream(end) 

subdag operator success

subdag not executed

Answer 1

Это не ошибка. Рекомендуется не использовать динамические значения для start_date, особенно datetime.now(). Задача запускается после закрытия периода, и, теоретически, @hourly DAG никогда не дойдет до часа после того, как сейчас() перемещается.

[https://airflow.incubator.apache.org/faq.html#what-s-the-deal-with-start-date]