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

.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" },
@@ -186,6 +189,8 @@ exclude = [
   'temporalio/bridge/proto',
   'temporalio/nexus/system/workflow_service',
   'temporalio/streams/proto',
+  'temporalio/streams/system',
+  'temporalio/streams/writer_system',
   # The Core submodule, which has a script of the crate's test vectors
   'temporalio/bridge/sdk-core',
 ]
@@ -197,13 +202,15 @@ ignore_errors = true
 [[tool.mypy.overrides]]
 module = [
   "temporalio.streams.proto.*",
+  "temporalio.streams.system.*",
+  "temporalio.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|sdk-core|\\.)).*"
+match_dir = "^(?!(docs|scripts|tests|api|proto|system|writer_system|_support|notifications|sdk-core|\\.)).*"
 add_ignore = [
   # We like to wrap at a certain number of chars, even long summary sentences.
   # https://github.com/PyCQA/pydocstyle/issues/184
@@ -225,6 +232,8 @@ intersphinx = [
 privacy = [
   "PRIVATE:temporalio.bridge",
   "PRIVATE:temporalio.streams.proto",
+  "PRIVATE:temporalio.streams.system",
+  "PRIVATE:temporalio.streams.writer_system",
   "PRIVATE:temporalio.types",
   "PRIVATE:temporalio.worker.workflow_sandbox.restrictions",
   "PRIVATE:temporalio.worker.workflow_sandbox.runner",
@@ -237,6 +246,8 @@ privacy = [
   "HIDDEN:temporalio.worker.workflow_instance",
   "HIDDEN:temporalio.worker.workflow_sandbox.importer",
   "HIDDEN:temporalio.worker.workflow_sandbox.in_sandbox",
+  "HIDDEN:temporalio.streams.system.client",
+  "HIDDEN:temporalio.streams.writer_system.client",
   "HIDDEN:**.*_pb2*",
 ]
 project-name = "Temporal Python"