Skip to content

Conversation

viktordebulat
Copy link

If the source (rowStream) emits an error or closes before all data is read, pipeline will reject.

This manually consumes the async iterator from the stream, catching errors at each step. If the stream ends early or throws, you catch the error and can handle it gracefully. This avoids some of the internal state issues that can occur with pipeline when the source stream is an async generator that may throw.

#9566

@github-actions github-actions bot added the pr:community Contribution from Cube.js community members. label Aug 17, 2025
@viktordebulat
Copy link
Author

Hi @igorlukanin, i'm not sure that this approach is the best way. Could you summon someone to review this?
I've been using this for 3 month in my project (ClickHouse rollups with lambdas) and would like to add this fix to the upstream

@viktordebulat viktordebulat marked this pull request as ready for review September 5, 2025 05:35
@viktordebulat viktordebulat requested a review from a team as a code owner September 5, 2025 05:35
@KSDaemon
Copy link
Member

KSDaemon commented Oct 9, 2025

@ovr WDYT?

@KSDaemon KSDaemon requested a review from ovr October 9, 2025 10:14
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

pr:community Contribution from Cube.js community members.

Projects

None yet

Development

Successfully merging this pull request may close these issues.

2 participants