Skip to content

chore: add the generated code of the Streams API - #382

Closed
moetemp wants to merge 3 commits into
moe/activity-workflow-task-infofrom
moe/streams/generated-code
Closed

moetemp wants to merge 3 commits into
moe/activity-workflow-task-infofrom
moe/streams/generated-code

Conversation

@moetemp

@moetemp moetemp commented Nov 13, 2026

Copy link
Copy Markdown
Owner

This PR adds the generated code of the Streams API, and nothing else.

It is the base of #381, so that #381 shows only the hand-written change. The files are what poe gen-protos writes at the head of #381.

  • The nexgen output under temporalio/nexus/system/stream_service/.
  • The Stream _pb2 modules, and the __init__.py files of their packages.
  • The Stream part of temporalio/bridge/_visitor.py, and the two exports in temporalio/workflow/__init__.py.

Please note that this branch doesn't pass the type check alone. The generated code calls support functions, such as default_producer(), that #381 adds.

These files are what `poe gen-protos` writes for the Stream protos and WIT. They have a branch
of their own, so that the hand-written change shows alone.
Ran `NEX_GEN_BIN=<nexgen 0.2.8> NEX_GEN_STREAM_BIN=<nexgen main build> uv run poe gen-protos`.
The Workflow `Stream` has no `append`, `close` or `read` any more, and no `async with`.
That change has a branch of its own, and this branch sits on top of it, so the generated code and the Stream change no longer show it.
@moetemp
moetemp changed the base branch from moe/streams/restart-base to moe/activity-workflow-task-info November 13, 2026 22:23
@moetemp

moetemp commented Nov 14, 2026

Copy link
Copy Markdown
Owner Author

closed in favour of temporalio#2128

@moetemp moetemp closed this Nov 14, 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