Кодовое представление воздушного потока показывает код главного даг - PullRequest
Новая
       89

Кодовое представление воздушного потока показывает код главного даг

4 голосов
/ 17 марта 2020

Я новичок в Airflow, и я следовал учебнику на официальной странице (https://airflow.readthedocs.io/en/stable/tutorial.html)
и добавил подделку в учебник dag. Когда я увеличиваю вложенный тег в веб-интерфейсе и нажимаю на код, отображается код основного тега. Также, когда я нажимаю на детали подпада, отображается имя основного ярлыка, как на скриншоте.

Снимок экрана неправильного пути к файлу: Screenshot of wrong filepath

Структура моего файла: 

dags/
├── subdags
│   ├── hellosubdag.py
│   ├── __init__.py
├── tutorial.py

Код моего основного кода: 

from datetime import timedelta

from airflow import DAG

from airflow.operators.bash_operator import BashOperator
from airflow.operators.subdag_operator import SubDagOperator
from airflow.utils.dates import days_ago
from subdags.hellosubdag import sub_dag

default_args = {
    'owner': 'airflow',
    'depends_on_past': False,
    'start_date': days_ago(2),
    'retries': 1,
    'retry_delay': timedelta(minutes=5),
}
parentdag = DAG(
    dag_id='tutorial',
    default_args=default_args,
    description='A simple tutorial DAG',
    schedule_interval=timedelta(days=1),
)

subdag_execute = SubDagOperator(
    task_id='subdag-exe',
    subdag=sub_dag('tutorial', 'subdag-exe', default_args['start_date'], timedelta(days=1)),
    dag=parentdag,
)

И подзадача просто печатает строку.

Моя компания использовала airflow 1.10.3 до обновления до 1.10.9, и мне сказали, что он работал до обновления.

Я не могу найти какой-либо журнал изменений или документацию по этой проблеме, была ли эта функция удалена в какой-то момент или я что-то не так делаю?

...