[
https://issues.apache.org/jira/browse/AIRFLOW-1287?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luke Rohde updated AIRFLOW-1287:
--------------------------------
Description:
The ShortCircuitOperator sets status to skipped for task instances by name and
execution date, but fails to filter by DAG. So if multiple DAGs have the tasks
with the same name, this sets downstream tasks to skipped on other DAGs.
https://github.com/apache/incubator-airflow/pull/2351
was:
The ShortCircuitOperator sets status to skipped for task instances by name and
execution date, but fails to filter by DAG. So if multiple DAGs have the tasks
with the same name, this sets downstream tasks to skipped on other DAGs.
I'll follow with a PR addressing this.
> Python ShortCircuitOperator missing DAG filter when setting downstream deps
> as skipped
> --------------------------------------------------------------------------------------
>
> Key: AIRFLOW-1287
> URL: https://issues.apache.org/jira/browse/AIRFLOW-1287
> Project: Apache Airflow
> Issue Type: Bug
> Components: operators
> Affects Versions: Airflow 1.8
> Reporter: Luke Rohde
> Assignee: Luke Rohde
>
> The ShortCircuitOperator sets status to skipped for task instances by name
> and execution date, but fails to filter by DAG. So if multiple DAGs have the
> tasks with the same name, this sets downstream tasks to skipped on other DAGs.
> https://github.com/apache/incubator-airflow/pull/2351
--
This message was sent by Atlassian JIRA
(v6.3.15#6346)
