Pinned Core at the external runtime's channel wake.

.gitmodules

@@ -1,4 +1,4 @@
 [submodule "sdk-core"]
 	path = temporalio/bridge/sdk-core
 	url = https://github.com/moedash/sdk-rust.git
-	branch = moe/AI-198-if-ext-core-5-zero-cache-retention
+	branch = moe/AI-198-if-ext-core-6-channel-wake

temporalio/bridge/proto/workflow_commands/__init__.py

@@ -33,6 +33,7 @@
     WorkflowCommand,
     WorkflowOutputStreamBuffered,
     WorkflowOutputStreamCommit,
+    WorkflowStreamChannels,
     WorkflowStreamProgress,
     WorkflowStreamQuiescent,
 )
@@ -72,6 +73,7 @@
     "WorkflowCommand",
     "WorkflowOutputStreamBuffered",
     "WorkflowOutputStreamCommit",
+    "WorkflowStreamChannels",
     "WorkflowStreamProgress",
     "WorkflowStreamQuiescent",
 ]

temporalio/bridge/proto/workflow_commands/workflow_commands_pb2.pyi

@@ -110,6 +110,7 @@ class WorkflowCommand(google.protobuf.message.Message):
     WORKFLOW_OUTPUT_STREAM_BUFFERED_FIELD_NUMBER: builtins.int
     SUBSCRIBE_NOTIFICATION_CHANNEL_FIELD_NUMBER: builtins.int
     UNSUBSCRIBE_NOTIFICATION_CHANNEL_FIELD_NUMBER: builtins.int
+    WORKFLOW_STREAM_CHANNELS_FIELD_NUMBER: builtins.int
     @property
     def user_metadata(self) -> temporalio.api.sdk.v1.user_metadata_pb2.UserMetadata:
         """User metadata that may or may not be persisted into history depending on the command type.
@@ -196,6 +197,8 @@ class WorkflowCommand(google.protobuf.message.Message):
     def unsubscribe_notification_channel(
         self,
     ) -> global___UnsubscribeNotificationChannel: ...
+    @property
+    def workflow_stream_channels(self) -> global___WorkflowStreamChannels: ...
     def __init__(
         self,
         *,
@@ -241,6 +244,7 @@ class WorkflowCommand(google.protobuf.message.Message):
         | None = ...,
         unsubscribe_notification_channel: global___UnsubscribeNotificationChannel
         | None = ...,
+        workflow_stream_channels: global___WorkflowStreamChannels | None = ...,
     ) -> None: ...
     def HasField(
         self,
@@ -305,6 +309,8 @@ class WorkflowCommand(google.protobuf.message.Message):
             b"workflow_output_stream_buffered",
             "workflow_output_stream_commit",
             b"workflow_output_stream_commit",
+            "workflow_stream_channels",
+            b"workflow_stream_channels",
             "workflow_stream_progress",
             b"workflow_stream_progress",
             "workflow_stream_quiescent",
@@ -374,6 +380,8 @@ class WorkflowCommand(google.protobuf.message.Message):
             b"workflow_output_stream_buffered",
             "workflow_output_stream_commit",
             b"workflow_output_stream_commit",
+            "workflow_stream_channels",
+            b"workflow_stream_channels",
             "workflow_stream_progress",
             b"workflow_stream_progress",
             "workflow_stream_quiescent",
@@ -414,6 +422,7 @@ class WorkflowCommand(google.protobuf.message.Message):
             "workflow_output_stream_buffered",
             "subscribe_notification_channel",
             "unsubscribe_notification_channel",
+            "workflow_stream_channels",
         ]
         | None
     ): ...
@@ -444,6 +453,38 @@ class UnsubscribeNotificationChannel(google.protobuf.message.Message):
 
 global___UnsubscribeNotificationChannel = UnsubscribeNotificationChannel
 
+class WorkflowStreamChannels(google.protobuf.message.Message):
+    """The complete set of notification channels the run listens on, one per open external stream
+    reader, in a stable order replay reproduces.
+
+    Core subscribes the run to a channel it has not yet subscribed on the completion that ends the
+    Workflow Task, after the progress marker and never on a run-ending completion. Issued from the
+    activation that opened the reader, the server-bound subscribe command would end a task that
+    was meant to stay retained. Reported on every completion once a reader has been opened, the
+    empty set included: an absent command leaves Core's view unchanged, which is what the park and
+    finalization answers rely on. Carries no retention request of its own.
+    """
+
+    DESCRIPTOR: google.protobuf.descriptor.Descriptor
+
+    CHANNELS_FIELD_NUMBER: builtins.int
+    @property
+    def channels(
+        self,
+    ) -> google.protobuf.internal.containers.RepeatedScalarFieldContainer[
+        builtins.str
+    ]: ...
+    def __init__(
+        self,
+        *,
+        channels: collections.abc.Iterable[builtins.str] | None = ...,
+    ) -> None: ...
+    def ClearField(
+        self, field_name: typing_extensions.Literal["channels", b"channels"]
+    ) -> None: ...
+
+global___WorkflowStreamChannels = WorkflowStreamChannels
+
 class SubscribeNotificationChannel(google.protobuf.message.Message):
     """Subscribe this workflow to a notification channel, so the scheduled event of
     each later Workflow Task carries the notifications folded for it.