[
https://issues.apache.org/jira/browse/AIRFLOW-3556?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16728964#comment-16728964
]
ASF GitHub Bot commented on AIRFLOW-3556:
-----------------------------------------
Fokko commented on pull request #4356: [AIRFLOW-3556] Add cross join set
downstream function
URL: https://github.com/apache/incubator-airflow/pull/4356
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
> 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)
