workflow_streams: rename module from workflow_stream

Public surface moves from temporalio.contrib.workflow_stream to
temporalio.contrib.workflow_streams. Internal signal/update/query
names (__temporal_workflow_stream_*) are wire identifiers and stay
unchanged so existing histories and mixed-version clients keep working.

Co-Authored-By: Claude Opus 4.7 (1M context) <noreply@anthropic.com>

Author: jssmith

temporalio/contrib/google_adk_agents/_model.py

@@ -8,7 +8,7 @@
 
 import temporalio.workflow
 from temporalio import activity, workflow
-from temporalio.contrib.workflow_stream import WorkflowStreamClient
+from temporalio.contrib.workflow_streams import WorkflowStreamClient
 from temporalio.exceptions import ApplicationError
 from temporalio.workflow import ActivityConfig
 
@@ -121,7 +121,7 @@ def __init__(
                 callers invoke ``generate_content_async(stream=True)``;
                 if ``None``, the streaming call raises before scheduling
                 an activity. The workflow must host a
-                :class:`temporalio.contrib.workflow_stream.WorkflowStream`
+                :class:`temporalio.contrib.workflow_streams.WorkflowStream`
                 to receive the publishes; otherwise the signals are
                 unhandled and dropped. Streaming support is
                 experimental and may change in future versions.

temporalio/contrib/openai_agents/README.md

@@ -590,7 +590,7 @@ agents-SDK `StreamEvent` union (so raw model events arrive as
 `RawResponsesStreamEvent.data`).
 
 External consumers (UIs, tracing pipelines, etc.) observe events as
-they arrive by hosting a [`WorkflowStream`](../workflow_stream/README.md)
+they arrive by hosting a [`WorkflowStream`](../workflow_streams/README.md)
 in the workflow and subscribing with `WorkflowStreamClient`. The
 streaming activity publishes each event to the topic configured on
 `ModelActivityParameters.streaming_event_topic`. The topic is required
@@ -621,7 +621,7 @@ class MyAgent:
 
 To publish raw model events to external subscribers, host a
 `WorkflowStream` in the workflow and configure
-`OpenAIAgentsPlugin(model_params=ModelActivityParameters(streaming_event_topic="events"))`. See [`temporalio.contrib.workflow_stream`](../workflow_stream/README.md) for the
+`OpenAIAgentsPlugin(model_params=ModelActivityParameters(streaming_event_topic="events"))`. See [`temporalio.contrib.workflow_streams`](../workflow_streams/README.md) for the
 publisher and subscriber API.
 
 `RunResultStreaming.stream_events()` yields the agents-SDK

temporalio/contrib/openai_agents/_invoke_model_activity.py

@@ -44,7 +44,7 @@
 
 from temporalio import activity
 from temporalio.contrib.openai_agents._heartbeat_decorator import _auto_heartbeater
-from temporalio.contrib.workflow_stream import WorkflowStreamClient
+from temporalio.contrib.workflow_streams import WorkflowStreamClient
 from temporalio.exceptions import ApplicationError
 
 

temporalio/contrib/openai_agents/_model_parameters.py

@@ -74,7 +74,7 @@ class ModelActivityParameters:
     calls ``Runner.run_streamed``. Required for ``Runner.run_streamed``;
     if left as ``None``, ``run_streamed`` raises before scheduling any
     activity. The workflow must host a
-    :class:`temporalio.contrib.workflow_stream.WorkflowStream` to receive
+    :class:`temporalio.contrib.workflow_streams.WorkflowStream` to receive
     the publishes; otherwise the signals are unhandled and dropped.
 
     Streaming is incompatible with ``use_local_activity`` (local activities

…oralio/contrib/workflow_stream/README.md …ralio/contrib/workflow_streams/README.mdtemporalio/contrib/workflow_stream/README.md renamed to temporalio/contrib/workflow_streams/README.md temporalio/contrib/workflow_stream/README.md renamed to temporalio/contrib/workflow_streams/README.md

@@ -12,9 +12,9 @@
 :py:class:`WorkflowStreamClient` for the external client interface.
 """
 
-from temporalio.contrib.workflow_stream._client import WorkflowStreamClient
-from temporalio.contrib.workflow_stream._stream import WorkflowStream
-from temporalio.contrib.workflow_stream._types import (
+from temporalio.contrib.workflow_streams._client import WorkflowStreamClient
+from temporalio.contrib.workflow_streams._stream import WorkflowStream
+from temporalio.contrib.workflow_streams._types import (
     PollInput,
     PollResult,
     PublishEntry,

…alio/contrib/workflow_stream/__init__.py …lio/contrib/workflow_streams/__init__.pytemporalio/contrib/workflow_stream/__init__.py renamed to temporalio/contrib/workflow_streams/__init__.py temporalio/contrib/workflow_stream/__init__.py renamed to temporalio/contrib/workflow_streams/__init__.py

@@ -23,7 +23,7 @@
 from temporalio import workflow
 from temporalio.client import Client, WorkflowFailureError
 from temporalio.contrib.google_adk_agents import GoogleAdkPlugin, TemporalModel
-from temporalio.contrib.workflow_stream import WorkflowStream, WorkflowStreamClient
+from temporalio.contrib.workflow_streams import WorkflowStream, WorkflowStreamClient
 from temporalio.worker import Worker
 
 logger = logging.getLogger(__name__)