dabla commented on PR #73688: URL: https://github.com/apache/airflow/pull/73688#issuecomment-5855751497
Rebased on the reworked #62922 (see the comment there: `.iterate()` now resolves its input by index like `.expand()`). Still a single commit on top of it, f3ed32fe4d. What the rework changed here: `BatchedExpandInput.aresolve()` is a `range(map_index, length, size)` over the delegate instead of walking the whole input and skipping; the striding tests moved to `aresolve()`; and the round-robin note in the docs no longer argues from a length that is "unknowable until drained", since the count is fixed by the scheduler before the task runs, which is the reason that actually holds. -- 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]
