Skip to content

[Bridge] Served Activity and Workflow Activity streams over Nexus. - #264

Closed
moetemp wants to merge 65 commits into
moe/bridge/v2/dr26-bridge-push-lanefrom
moe/bridge/v2/dr35-wfa-stream-nexus
Closed

moetemp wants to merge 65 commits into
moe/bridge/v2/dr26-bridge-push-lanefrom
moe/bridge/v2/dr35-wfa-stream-nexus

Conversation

@moetemp

@moetemp moetemp commented Oct 16, 2026 •

Copy link
Copy Markdown
Owner

What changed?

This PR serves streams that a standalone Activity or a Workflow Activity owns over Nexus. The Core pin and the regenerated bindings let a StreamRef carry its activity_id across the contract. A Workflow ref sends no activity_id, so its JSON and its token keep their bytes. StreamOperationHandler attaches the caller for each owner kind. The codec step and StreamFollowerService decode with the Activity's ActivitySerializationContext (DD-189).

The PR also adds a tool call demo, the guide section and the Nexus lane for Activity streams. Stacked on #263.

Why?

Tool-call streams need an owner that isn't a Workflow, and callers in another namespace reach them only through Nexus (DD-192, DD-201). A codec keyed by its context couldn't decode an Activity stream before.

How did you test it?

Link to a test plan if any -

  • Unit Tests
  • Staging
  • End to End Tests

Ran the Bridge lane with the Activity in one namespace and the caller in another, on standalone Redis and a Redis Cluster.

# Conflicts:
#	scripts/streams_live_lane.sh
@moetemp

moetemp commented Oct 18, 2026

Copy link
Copy Markdown
Owner Author

Closing this in favor of the re-cut Bridge stack (#296 to #320). Its content is now in #317, #320.

@moetemp moetemp closed this Oct 18, 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