[jira] [Assigned] (AIRFLOW-3556) Add a "cross join" function for setting dependencies between two lists of tasks

["Fokko Driesprong (JIRA)" <ji...@apache.org>]

     [ https://issues.apache.org/jira/browse/AIRFLOW-3556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Fokko Driesprong reassigned AIRFLOW-3556:
-----------------------------------------

    Assignee: Bas Harenslak

> Add a "cross join" function for setting dependencies between two lists of tasks
> -------------------------------------------------------------------------------
>
>                 Key: AIRFLOW-3556
>                 URL: https://issues.apache.org/jira/browse/AIRFLOW-3556
>             Project: Apache Airflow
>          Issue Type: New Feature
>            Reporter: Bas Harenslak
>            Assignee: Bas Harenslak
>            Priority: Major
>             Fix For: 2.0.0
>
>
> Similar to airflow.utils.helpers.chain(), it would be useful to have a helper function that sets downstream dependencies in a cross join fashion between two lists of tasks.
> For example:
> {code}
> cross_downstream(from_tasks=[t1, t2, t3], to_tasks=[t4, t5, t6])
> Sets dependencies:
>     t1 --> t4
>        \ /
>     t2 -X> t5
>        / \
>     t3 --> t6
> Equivalent to:
> t1.set_downstream(t4)
> t1.set_downstream(t5)
> t1.set_downstream(t6)
> t2.set_downstream(t4)
> t2.set_downstream(t5)
> t2.set_downstream(t6)
> t3.set_downstream(t4)
> t3.set_downstream(t5)
> t3.set_downstream(t6){code}



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)