dstandish commented on code in PR #31927:
URL: https://github.com/apache/airflow/pull/31927#discussion_r1231392834
##########
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:
thanks for the suggestions.
well, here's the argument for sequential. "sequential" here means, each
element provided will be arrowed to the next, in sequence, whether list or
otherwise. maybe `chain_linear` would be another option, perhaps better cus it
doesn't invoke the concept of sequences, or sequential vs parallel.
wdyt?
longest doesn't quite feel right because as you mention, we don't "fill out"
anything to match the longest.
i do see the connection with reduce... because effectively we're reducing
the elements with `>>`. maybe i would pick `chain_reduce` over `chain_reduced`.
the thing that steers me away though is the fact that it invokes the `reduce`
notion which makes it sound like it's doing something related to mapping.
--
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]
