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

["Bas Harenslak (JIRA)" <ji...@apache.org>]

Bas Harenslak created AIRFLOW-3556:
--------------------------------------

             Summary: 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


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)