Skip to content

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

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

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

Conversation

@moetemp

@moetemp moetemp commented Nov 14, 2026 •

Copy link
Copy Markdown
Contributor

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

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

  • 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 CI alone. The generated code calls support functions, such as default_producer(), that #2129 adds, and the script that writes these files is in #2129 too. This PR sits on #2127.

These are the files that `poe gen-protos` writes for the Stream service. They are in a PR of
their own, so that the hand-written change shows alone.
…eam.

The new Stream WIT gives the Workflow target `append` and `close`, so the generated Workflow `Stream` has them and `async with` closes it.

This branch has not been deployed

No deployments
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