Skip to content

[FROZEN][Bridge] Followed a stream from a Worker through a standalone operation. - #307

Closed
moetemp wants to merge 17 commits into
moe/bridge/v3/N11-workflow-readerfrom
moe/bridge/v3/N12-worker-follower
Closed

moetemp wants to merge 17 commits into
moe/bridge/v3/N11-workflow-readerfrom
moe/bridge/v3/N12-worker-follower

Conversation

@moetemp

@moetemp moetemp commented Oct 18, 2026

Copy link
Copy Markdown
Owner

What changed?

This PR adds StreamFollowerService and follow_stream. They follow a stream from a Worker through a standalone operation, with no Workflow. The read position travels in the callback's state, so any Worker on the task queue can take the next call.

Why?

Some consumers aren't Workflows, such as a connector that pushes a stream to a chat. It's one module, so this PR is a bit over 800 lines.

How did you test it?

Link to a test plan if any -

  • Unit Tests
  • Staging
  • End to End Tests

@moetemp moetemp changed the title [Bridge] Followed a stream from a Worker through a standalone operation. [FROZEN][Bridge] Followed a stream from a Worker through a standalone operation. Oct 20, 2026
@moetemp

moetemp commented Oct 22, 2026

Copy link
Copy Markdown
Owner Author

Closed as unused. Jetty and Bridge are frozen, and the Brook v4 stack doesn't build on this PR. The branch stays, so this PR can be reopened.

@moetemp moetemp closed this Oct 22, 2026
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.

1 participant