Skip to content
Closed
Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
51 commits
Select commit Hold shift + click to select a range
246f3c0
Added the workflow half of a server-side stream.
moedash Sep 25, 2026
c76d176
Added the native provider with one owned stream per topic.
moedash Sep 25, 2026
cf6a38c
Added the Workflow Streams surface over a server-side stream.
moedash Sep 25, 2026
217782b
Merge branch 'moe/AI-198-py-05-native-wire' into moe/AI-198-py-06-nat…
moedash Sep 25, 2026
f2511f7
Gave the contrib client a producer identity and a pending batch.
moedash Sep 25, 2026
e3b4230
Closed only the stream channels a provider opened.
moedash Sep 25, 2026
a223504
Named the way out of a stream continuity failure.
moedash Sep 25, 2026
2b3577f
Stopped holding records for a reader that closed.
moedash Sep 25, 2026
ee2b477
Merge branch 'moe/AI-198-py-05-native-wire' into moe/AI-198-py-06-nat…
moedash Sep 25, 2026
55eef18
Started the native producer's numbering at one.
moedash Sep 25, 2026
79c2d38
Merge branch 'moe/AI-198-py-05-native-wire' into moe/AI-198-py-06-nat…
moedash Sep 25, 2026
9160c82
Renamed the stream command fields the workflow writes.
moedash Sep 25, 2026
b2a7d57
Merge branch 'moe/AI-198-py-05-native-wire' into moe/AI-198-py-06-nat…
moedash Sep 26, 2026
c362a17
Merge branch 'moe/AI-198-py-05-native-wire' into moe/AI-198-py-06-nat…
moedash Sep 26, 2026
5d264e1
Merge branch 'moe/AI-198-py-05-native-wire' into moe/AI-198-py-06-nat…
moedash Sep 28, 2026
a48b223
Mapped the native default topic onto the server's default stream.
moedash Sep 28, 2026
f492053
Merge branch 'moe/AI-198-py-05-native-wire' into moe/AI-198-py-06-nat…
moedash Sep 28, 2026
6be8473
Opened activity-owned streams on the native provider.
moedash Sep 28, 2026
211d435
Merge branch 'moe/AI-198-py-05-native-wire' into moe/AI-198-py-06-nat…
moedash Sep 29, 2026
c8cd5e8
Mapped every read start onto the native provider.
moedash Sep 29, 2026
dd072ac
Merge branch 'moe/AI-198-py-05-native-wire' into moe/AI-198-py-06-nat…
moedash Sep 29, 2026
560f5a0
Retried throttled and unavailable stream calls as sdk-core does.
moedash Sep 29, 2026
5c3421e
Derived the stream channel from the client's connection.
moedash Sep 30, 2026
47f75c1
Mapped the server's typed refusals to the interface errors.
moedash Sep 30, 2026
defaf5c
Stamped every native record with the hash of its plaintext body.
moedash Sep 30, 2026
0ee2aaa
Routed native stream bodies through the client's data converter.
moedash Sep 30, 2026
60fd7ec
Kept the declared content hash out of the worker's payload pass.
moedash Sep 30, 2026
23b964a
Merge remote-tracking branch 'origin/moe/AI-198-py-04-accessors' into…
moedash Sep 30, 2026
f37da2e
Hosted standalone streams and refs on the native provider.
moedash Sep 30, 2026
3eb6664
Mapped the STREAM_CLOSED reason token to StreamClosedError.
moedash Sep 30, 2026
54cd798
Merge branch 'moe/AI-198-py-05-native-wire' into moe/AI-198-py-06-nat…
moedash Sep 30, 2026
50902e6
Merge branch 'moe/AI-198-py-05-native-wire' into moe/AI-198-py-06-nat…
moedash Sep 30, 2026
2b19d6e
Took the server's word on a create of a standalone stream that exists.
moedash Sep 30, 2026
966e6c6
Merge branch 'moe/AI-198-py-05-native-wire' into moe/AI-198-py-06-nat…
moedash Oct 1, 2026
20ae07a
Passed the byte cap through and trusted the server on a repeated create.
moedash Oct 1, 2026
e80180e
Reused the retention case's result variable instead of redeclaring it.
moedash Oct 1, 2026
3c2040a
Merge branch 'moe/AI-198-py-05-native-wire' into moe/AI-198-py-06-nat…
moedash Oct 1, 2026
8d1d9a0
Merge branch 'moe/AI-198-py-05-native-wire' into moe/AI-198-py-06-nat…
moedash Oct 1, 2026
20330e8
Merge branch 'moe/AI-198-py-05-native-wire' into moe/AI-198-py-06-nat…
moedash Oct 1, 2026
cf87ec6
Merge branch 'moe/AI-198-py-05-native-wire' into moe/AI-198-py-06-nat…
moedash Oct 2, 2026
c5b259c
Expected the typed cursor error from a read below the floor.
moedash Oct 2, 2026
afb734a
Merge branch 'moe/AI-198-py-05-native-wire' into moe/AI-198-py-06-nat…
moedash Oct 2, 2026
dd8ccd5
Merge branch 'moe/AI-198-py-05-native-wire' into moe/AI-198-py-06-nat…
moedash Oct 2, 2026
6bc691b
Merge branch 'moe/AI-198-py-05-native-wire' into moe/AI-198-py-06-nat…
moedash Oct 2, 2026
f4a2e25
Merge branch 'moe/AI-198-py-05-native-wire' into moe/AI-198-py-06-nat…
moedash Oct 2, 2026
f235b47
Followed a native stream through its channel on a live server.
moedash Oct 2, 2026
1f7cee0
Waited for each standalone append's notification before the next.
moedash Oct 2, 2026
fb4caa8
Merge branch 'moe/AI-198-py-05-native-wire' into moe/AI-198-py-06-nat…
moedash Oct 2, 2026
f97af15
Merge branch 'moe/AI-198-py-05-native-wire' into moe/AI-198-py-06-nat…
moedash Oct 3, 2026
56ab511
Named a standalone activity's stream channel by execution on the nati…
moedash Oct 3, 2026
56bf209
Merge branch 'moe/AI-198-py-05-native-wire' into moe/AI-198-py-06-nat…
moedash Oct 3, 2026
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
604 changes: 531 additions & 73 deletions temporalio/client_stream.py

Large diffs are not rendered by default.

8 changes: 5 additions & 3 deletions temporalio/contrib/langgraph/_plugin.py
Original file line number Diff line number Diff line change
Expand Up @@ -104,11 +104,13 @@ class LangGraphPlugin(SimplePlugin):
inherited default of either form.
streaming_topic: When set, ``langgraph.config.get_stream_writer()``
inside a node publishes to this topic on the workflow's
:class:`WorkflowStream`. The workflow must construct
``WorkflowStream()`` in its ``@workflow.init`` (the plugin's
:class:`temporalio.contrib.workflow_streams.WorkflowStream`. The
workflow must construct ``WorkflowStream()`` in its
``@workflow.init`` (the plugin's
interceptor verifies this on workflow start). Nodes with
``execute_in='activity'`` publish through
:class:`WorkflowStreamClient` (signal); nodes with
:class:`temporalio.contrib.workflow_streams.WorkflowStreamClient`
(signal); nodes with
``execute_in='workflow'`` publish synchronously to the
in-workflow stream (no signal).
streaming_batch_interval: How often the activity-side stream
Expand Down
Loading
Loading