[
https://issues.apache.org/jira/browse/AIRFLOW-3859?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bas Harenslak updated AIRFLOW-3859:
-----------------------------------
Description:
I noticed this DAG's dependencies overlap since upgrading to Airflow 1.10.2:
!image-2019-02-10-10-54-41-616.png!
They did not overlap in Airflow 1.10.0:
!http://localhost:9000/images/bash-data-pipelines-with-apache-airflow/example_dag.png!
I'll add info to this issue if I find a possible cause.
Code:
{code:java}
import airflow
from airflow.models import DAG
from airflow.operators.dummy_operator import DummyOperator
args = {"owner": "airflow", "start_date": airflow.utils.dates.days_ago(14)}
dag = DAG(
dag_id="airflow-3859",
default_args=args,
schedule_interval="0 0 * * *",
)
tasks = {i: DummyOperator(task_id=f"task{i}", dag=dag) for i in range(1, 10)}
tasks[1] >> [tasks[2], tasks[3]]
tasks[2] >> tasks[4] >> [tasks[5], tasks[7]] >> tasks[9]
tasks[3] >> tasks[6] >> tasks[7]
tasks[5] >> tasks[7] >> tasks[8] >> tasks[9]{code}
was:
I noticed this DAG's dependencies overlap since upgrading to Airflow 1.10.2:
!image-2019-02-10-10-54-41-616.png!
They did not overlap in Airflow 1.10.0:
!http://localhost:9000/images/bash-data-pipelines-with-apache-airflow/example_dag.png!
I'll add info to this issue if I find a possible cause.
> Dependencies in Graph UI overlap after upgrade 1.10.0 -> 1.10.2
> ---------------------------------------------------------------
>
> Key: AIRFLOW-3859
> URL: https://issues.apache.org/jira/browse/AIRFLOW-3859
> Project: Apache Airflow
> Issue Type: Bug
> Reporter: Bas Harenslak
> Priority: Major
> Attachments: image-2019-02-10-10-54-41-616.png
>
>
> I noticed this DAG's dependencies overlap since upgrading to Airflow 1.10.2:
> !image-2019-02-10-10-54-41-616.png!
> They did not overlap in Airflow 1.10.0:
> !http://localhost:9000/images/bash-data-pipelines-with-apache-airflow/example_dag.png!
> I'll add info to this issue if I find a possible cause.
> Code:
> {code:java}
> import airflow
> from airflow.models import DAG
> from airflow.operators.dummy_operator import DummyOperator
> args = {"owner": "airflow", "start_date": airflow.utils.dates.days_ago(14)}
> dag = DAG(
> dag_id="airflow-3859",
> default_args=args,
> schedule_interval="0 0 * * *",
> )
> tasks = {i: DummyOperator(task_id=f"task{i}", dag=dag) for i in range(1, 10)}
> tasks[1] >> [tasks[2], tasks[3]]
> tasks[2] >> tasks[4] >> [tasks[5], tasks[7]] >> tasks[9]
> tasks[3] >> tasks[6] >> tasks[7]
> tasks[5] >> tasks[7] >> tasks[8] >> tasks[9]{code}
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
