[Brook S2] Generated the Stream service and writer bindings with nexgen.

.github/workflows/ci.yml

@@ -230,6 +230,8 @@ jobs:
       - run: uv add --python 3.10 "protobuf<4"
       - run: uv sync --all-extras
       - run: cargo install --locked nexgen --version 0.2.8 --features advanced --force
+      # The Stream service bindings need a nexgen revision that no release has yet.
+      - run: uv run scripts/gen_stream_service.py --install-nexgen
       - run: poe build-develop
       - run: poe gen-protos
       - name: Check generation unchanged

.gitignore

@@ -15,3 +15,6 @@ temporalio/bridge/temporal_sdk_bridge*
 tags
 /.claude
 tmpclaude-*
+
+# nexgen builds that scripts/gen_stream_service.py installs
+/.nexgen-streams/

pyproject.toml

@@ -109,16 +109,19 @@ format = [
 ]
 gen-docs = "uv run scripts/gen_docs.py"
 gen-nexus-system-api = "uv run scripts/gen_nexus_system_api.py"
+gen-stream-service = "uv run scripts/gen_stream_service.py"
 gen-protos = [
   { cmd = "uv run scripts/gen_protos.py" },
   { ref = "gen-nexus-system-api" },
+  { ref = "gen-stream-service" },
   { cmd = "uv run scripts/gen_payload_visitor.py" },
   { cmd = "uv run scripts/gen_bridge_client.py" },
   { ref = "format" },
 ]
 gen-protos-docker = [
   { cmd = "uv run scripts/gen_protos_docker.py" },
   { ref = "gen-nexus-system-api" },
+  { ref = "gen-stream-service" },
   { cmd = "uv run scripts/gen_payload_visitor.py" },
   { cmd = "uv run scripts/gen_bridge_client.py" },
   { ref = "format" },
@@ -184,6 +187,8 @@ exclude = [
   'temporalio/bridge/proto',
   'temporalio/nexus/system/workflow_service',
   'temporalio/common/_streams/proto',
+  'temporalio/common/_streams/system',
+  'temporalio/common/_streams/writer_system',
 ]
 
 [[tool.mypy.overrides]]
@@ -193,13 +198,15 @@ ignore_errors = true
 [[tool.mypy.overrides]]
 module = [
   "temporalio.common._streams.proto.*",
+  "temporalio.common._streams.system.*",
+  "temporalio.common._streams.writer_system.*",
 ]
 ignore_errors = true
 
 [tool.pydocstyle]
 convention = "google"
 # https://github.com/PyCQA/pydocstyle/issues/363#issuecomment-625563088
-match_dir = "^(?!(docs|scripts|tests|api|proto|system|_support|notifications|\\.)).*"
+match_dir = "^(?!(docs|scripts|tests|api|proto|system|writer_system|_support|notifications|\\.)).*"
 add_ignore = [
   # We like to wrap at a certain number of chars, even long summary sentences.
   # https://github.com/PyCQA/pydocstyle/issues/184
@@ -232,6 +239,8 @@ privacy = [
   "HIDDEN:temporalio.worker.workflow_instance",
   "HIDDEN:temporalio.worker.workflow_sandbox.importer",
   "HIDDEN:temporalio.worker.workflow_sandbox.in_sandbox",
+  "HIDDEN:temporalio.common._streams.system.client",
+  "HIDDEN:temporalio.common._streams.writer_system.client",
   "HIDDEN:**.*_pb2*",
 ]
 project-name = "Temporal Python"