Ошибка инверсии вида дерева потока? - PullRequest
Новая
       26

Ошибка инверсии вида дерева потока?

0 голосов
/ 29 апреля 2020

Я запускаю пару активных групп доступности баз данных в Google Cloud composer (управляемый поток воздуха), и кажется, что древовидное представление всех моих групп обеспечения доступности баз данных инвертировано.

Обратите внимание на следующую группу обеспечения доступности баз данных: 

from airflow import DAG
from datetime import datetime, timedelta
from airflow.operators.dummy_operator import DummyOperator

default_args = {
    "owner": "airflow",
    "start_date": datetime(2020, 4, 26),
    "depends_on_past": False,
    "email_on_failure": False,
    "email_on_retry": False,
    "email": "youremail@host.com",
    "retries": 1,
    "retry_delay": timedelta(minutes=5)
}

with DAG(dag_id="Dummy_test", schedule_interval="@daily", default_args=default_args, catchup=True) as dag:
    op1 = DummyOperator(task_id='op1', dag=dag)
    op2 = DummyOperator(task_id='op2', dag=dag)
    op3 = DummyOperator(task_id='op3', dag=dag)
    op4 = DummyOperator(task_id='op4', dag=dag)
    op5 = DummyOperator(task_id='op5', dag=dag)
    op6 = DummyOperator(task_id='op6', dag=dag)
    op7 = DummyOperator(task_id='op7', dag=dag)
    op8 = DummyOperator(task_id='op8', dag=dag)
    op9 = DummyOperator(task_id='op9', dag=dag)

    op1 >> op2
    op2 >> op3
    op3 >> op4
    op4 >> op5
    op5 >> op6
    op6 >> [op7, op8, op9]

Правильно отображается в графическом представлении:

It renders correctly in Graph view

Но представление дерева инвертировано?

enter image description here

Это ошибка пользовательского интерфейса или я неправильно определяю свои зависимости? Это происходит со всеми моими дагами, а не только с этим простым фиктивным примером.

1 Ответ

1 голос
/ 30 апреля 2020

Благодаря Итроулли и его комментариям теперь я вижу, что это ожидаемое поведение. Спасибо!

...