Skip to content

Revert "Revert #30533: Automatically execute unbounded pipelines in streaming mode." - #30894

Closed
damccorm wants to merge 1 commit into
masterfrom
revert-30706-rollback-30533
Closed

Revert "Revert #30533: Automatically execute unbounded pipelines in streaming mode."#30894
damccorm wants to merge 1 commit into
masterfrom
revert-30706-rollback-30533

Conversation

@damccorm

Copy link
Copy Markdown
Contributor

Reverts #30706

This change was initially correct


if any(pcoll.is_bounded == beam_runner_api_pb2.IsBounded.UNBOUNDED
for pcoll in self.proto_pipeline.components.pcollections.values()):
options.view_as(StandardOptions).streaming = True

Copy link
Copy Markdown
Contributor

Choose a reason for hiding this comment

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

if users specify streaming, can we honor the one specified by the users? This at least can let users keep the current behavior.

@damccorm

Copy link
Copy Markdown
ContributorAuthor

We're taking a different (runner driven) approach here

@damccorm
damccorm deleted the revert-30706-rollback-30533 branch April 12, 2024 20:50
Sign up for freeto join this conversation on GitHub. Already have an account? Sign in to comment

Labels

Projects

None yet

Development

Successfully merging this pull request may close these issues.

2 participants

@damccorm@liferoad