Skip to content

Delay/retain input capabilities for specific outputs#738

Merged
frankmcsherry merged 1 commit intoTimelyDataflow:masterfrom
antiguru:output_index
Feb 7, 2026
Merged

Delay/retain input capabilities for specific outputs#738
frankmcsherry merged 1 commit intoTimelyDataflow:masterfrom
antiguru:output_index

Conversation

@antiguru
Copy link
Member

@antiguru antiguru commented Feb 7, 2026

This PR implements various ergonomic improvements around capabilities and integration with outputs. Specifically, it makes the output port explicit, where previously one had to remember the order in which outputs were constructed.

Changes the API on input capabilities such that retain/delay always takes an output port. Adds a function to outputs to determine their port. Removes functions that would always use port 0 as it is confusing in multi-output operators. Retain does not move the input capability anymore.

This PR implements various ergonomic improvements around capabilities and
integration with outputs. Specifically, it makes the output port explicit,
where previously one had to remember the order in which outputs were
constructed.

Changes the API on input capabilities such that retain/delay always takes
an output port. Adds a function to outputs to determine their port. Removes
functions that would always use port 0 as it is confusing in multi-output
operators. Retain does not move the input capability anymore.

Signed-off-by: Moritz Hoffmann <antiguru@gmail.com>
Copy link
Member

@frankmcsherry frankmcsherry left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Looks good to me!

@frankmcsherry frankmcsherry merged commit 0bbaddf into TimelyDataflow:master Feb 7, 2026
7 checks passed
@antiguru antiguru deleted the output_index branch February 7, 2026 03:54
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

2 participants