uranusjr commented on code in PR #31927:
URL: https://github.com/apache/airflow/pull/31927#discussion_r1230786528
##########
airflow/models/baseoperator.py:
##########
@@ -1838,6 +1839,38 @@ def cross_downstream(
task.set_downstream(to_tasks)
+def chain_sequential(*elements: DependencyMixin | Sequence[DependencyMixin]):
Review Comment:
~~`chain_correctly`~~
Maybe something to describe the fact each “group” is joined? One that comes
immediately to me is `chain_reduced` since this is very much like how dynamic
task mapping works when each mapped task is automatically joined (and looking
back these really should have been consistent with each other). If I can design
this from scratch I’d call _this_ `chain` and the other `chain_branched` but
now we are stuck to coming up with the opposite of branching.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
