时间戳

首页 > 解决方案 > Airflow subdag codeview 显示 main-dag 的代码

python - Airflow subdag codeview 显示 main-dag 的代码

问题描述

我是 Airflow 的新手，我按照官方页面 ( https://airflow.readthedocs.io/en/stable/tutorial.html )上
的教程进行操作，并在教程 dag 中添加了一个 subdag。当我放大 web-UI 上的 subdag 并单击代码时，会显示 main-dag 的代码。此外，当我单击 subdag 的详细信息时，会显示 main-dag 的文件名，就像在屏幕截图上一样。

错误文件路径的屏幕截图： 错误文件路径的屏幕截图

我的文件结构：

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,
)

subdag 只是打印一个字符串。

我的公司在更新到 1.10.9 之前使用气流 1.10.3，我被告知它在更新之前曾经工作过。

我找不到有关此问题的任何更改日志或文档，此功能是否在某个时候被删除或者我做错了什么？

标签： pythonairflowfilepath

解决方案

推荐阅读