Regenerated the vendored stream protos for protobuf 3.

This package has to load on a protobuf 3 runtime, and generated code
refuses to load on a runtime older than the one it was built against. The
protoc of that generation has no `--pyi_out`, so the stubs come from
`mypy-protobuf`, which is what the other generated protos already use.

Author: moetemp

scripts/gen_stream_protos.py

@@ -9,7 +9,9 @@
 Run it with an interpreter whose ``grpcio-tools`` matches the oldest protobuf
 runtime this package has to load on. Generated code refuses to load on a
 runtime older than the one it was built against, and these modules end up in
-applications that pin protobuf themselves.
+applications that pin protobuf themselves. The stubs come from
+``mypy-protobuf`` rather than protoc's own ``--pyi_out``, which that
+generation of protoc does not have.
 
 Two rewrites make the copies compile against this SDK. The server's own
 routing and API-category options are dropped, because they mean nothing to a
@@ -119,8 +121,9 @@ def main() -> None:
                 f"--proto_path={work}",
                 f"--proto_path={api_proto_path()}",
                 f"--python_out={out}",
-                f"--pyi_out={out}",
                 f"--grpc_python_out={out}",
+                f"--mypy_out={out}",
+                f"--mypy_grpc_out={out}",
                 *targets,
             ],
             check=True,

temporalio/api/streamservice/v1/__init__.py

@@ -19,6 +19,10 @@
     AddWorkflowMessagesInput,
     AddWorkflowMessagesRequest,
     AddWorkflowMessagesResponse,
+    AdvanceConsumerHeadInput,
+    AdvanceConsumerHeadOutput,
+    AdvanceConsumerHeadRequest,
+    AdvanceConsumerHeadResponse,
     CloseStreamInput,
     CloseStreamOutput,
     CloseStreamRequest,
@@ -53,6 +57,10 @@
     PollWorkflowMessagesInput,
     PollWorkflowMessagesRequest,
     PollWorkflowMessagesResponse,
+    RegisterStreamConsumerInput,
+    RegisterStreamConsumerOutput,
+    RegisterStreamConsumerRequest,
+    RegisterStreamConsumerResponse,
     StreamListEntry,
     SubscribeWorkflowInput,
     SubscribeWorkflowOutput,
@@ -79,6 +87,10 @@
     "AddWorkflowMessagesInput",
     "AddWorkflowMessagesRequest",
     "AddWorkflowMessagesResponse",
+    "AdvanceConsumerHeadInput",
+    "AdvanceConsumerHeadOutput",
+    "AdvanceConsumerHeadRequest",
+    "AdvanceConsumerHeadResponse",
     "CloseStreamInput",
     "CloseStreamOutput",
     "CloseStreamRequest",
@@ -115,6 +127,10 @@
     "PollWorkflowMessagesRequest",
     "PollWorkflowMessagesResponse",
     "ProducerCursor",
+    "RegisterStreamConsumerInput",
+    "RegisterStreamConsumerOutput",
+    "RegisterStreamConsumerRequest",
+    "RegisterStreamConsumerResponse",
     "STREAM_MESSAGE_KIND_DATA",
     "STREAM_MESSAGE_KIND_FLUSH",
     "STREAM_MESSAGE_KIND_UNSPECIFIED",