ޠj5*SrSSKJr SSKJrJrJr SSKJrJ r J r Sr \ "1Sk5r SSjrSSjrSS jrSS S jjr\ S rS!S jrS"SjrS#Sjr"SS\ 5r"SS5r"SS5r"SS5r"SS5r"SS5rg )$u;Per-channel event → items state machines. Used both by the projection iterators (`_ValuesProjection`, `_MessagesProjection`, `_ToolCallsProjection`, `_SubgraphsProjection`) on `AsyncThreadStream` / `SyncThreadStream`, and by `interleave_projections`, which drives multiple decoders from one shared subscription. ) annotations)CallableIterableMapping)AnyLiteralProtocol)valuesmessages tool_calls subgraphsupdates checkpointstasks>inputtools lifecyclec UH?nU[;dMUS:XaSOSn[U<SUSSR[5S35e g) a9Reject reserved protocol channel names before they hit the fallback. Genuine extension names pass through untouched; only names that ``infer_channel`` treats as built-in methods without an interleave decoder are rejected, so a typo'd or unsupported protocol channel surfaces an error instead of an empty stream. rz (use "tool_calls")z. is not a valid interleave_projections channelz. Supported channels: z, z, or an extension name.N)RESERVED_INTERLEAVE_CHANNELS ValueErrorjoinSUPPORTED_INTERLEAVE_CHANNELS)channelschhints W/var/www/html/gaurav/venv/lib/python3.13/site-packages/langgraph_sdk/stream/decoders.pyvalidate_interleave_channelsr"s_ - -,.'M(rD&FtfM''+yy1N'O&PQ(( c[U[5(d/$URS5=(d /n[U[5(a [U5$/$)N namespace) isinstancedictgetlist) params_fieldr!s r_event_namespacer'4sD lD ) )   -3I(D994 ?ArArctURS5=(d URS5nUb [U5$S$)Nid message_idr$str)datar*s r_message_event_idr.;s1$9488L#9J(43z?>$>rNc:[U5nUbSU3$UbSU3$g)aReturn the routing key for a message-channel event in `active`. Keys on `message_id` when available so concurrent messages that share the same `run_id` (two AI turns in one agent step) route to independent streams rather than colliding on a shared `run:` slot. zmessage: __single__)r.)r-fallbackr*s r_message_route_keyr2@s7#4(J*&&($$ r)started completedfailed interruptedcDURS5upnX(aU4$S4$)N:) partition)segmentnameseptask_ids r_parse_namespace_segmentr>Rs, **3/Dw C ))T ))rc|URS5(agURS5nU(a S[U54$g)N interrupts)r6Nerrorr5)r4Nr+)r-rAs r_terminal_from_tasks_resultrBWs9 xx " HHW E U## rcx[U5[U5S-:H=(a [US[U55U:H$)N)lentuple)r!scopes r_is_direct_childrHbs4 y>SZ!^ + Wi #e*6M0NRW0WWrc\rSrSrSSjrSrg)DecoderfcgN)selfevents rfeed Decoder.feedgssrrNNrPzMapping[str, Any]return Iterable[Any])__name__ __module__ __qualname____firstlineno__rQ__static_attributes__rNrrrJrJfsBrrJc0\rSrSrSrSSSjjrS SjrSrg) DataDecoderju#Yields `params.data` from events of a single `method`. Covers the channels whose projection is just "emit the payload": `values`, `updates`, `checkpoints`, `tasks` — the SDK analog of local's `Values`/`Updates`/`Checkpoints`/`TasksTransformer`, all of which push `params["data"]` unchanged. The REST-state seeding for `values` stays at the projection layer; it is a one-shot pre-stream fetch, not part of the event state machine. Args: method: The protocol `method` this decoder consumes. namespace: When not `None`, events whose namespace differs are ignored (scope filter, mirroring the local transformers' `namespace != scope` check). `None` consumes every namespace — the historical `values` projection behavior, where subscription scoping is handled upstream. NcFXlUb[U5UlgSUlgrM)_methodr% _namespace)rOmethodr!s r__init__DataDecoder.__init__|s -6-B$y/rc## URS5UR:wagURS5=(d 0nURb[U5UR:wagURS5nUbUv gg7f)Nraparamsr-)r$r_r`r'rOrPrer-s rrQDataDecoder.feedsl 99X $,, . 8$* ?? &+;F+Ct+V zz&!  J sA)r_r`rM)rar,r!zlist[str] | NonerSrVrWrXrY__doc__rbrQrZrNrrr\r\js"Mrr\c4\rSrSrSrSSjrSSjrSrg) MessagesDecodera3Yields one chat-model stream per `message-start` event. Subsequent events route to the matching stream via `stream.dispatch(data)`. Mirrors the per-event body of `_MessagesProjection._messages_iter` (`_async/stream.py:404-458`). The subscription open/close and the `_root_messages_inbox` drain branch stay at the projection layer. Args: namespace: Events whose namespace differs are ignored (scope filter). stream_factory: Keyword-only `(namespace, node, message_id) -> stream`. Sync binds `ChatModelStream`; async binds `AsyncChatModelStream`. c>[U5UlX l0UlgrM)r%r`_stream_factory_active)rOr!stream_factorys rrbMessagesDecoder.__init__s y/-') rc#*# URS5S:wagURS5=(d 0n[U5UR:wagURS5n[U[5(dgURS5S:Xa[ U5n[ X4S9n[URS5[5(aURS5O0nUR[UR5U(aURS 5OSUS 9nXpRU'URU5 Uv g[ U5nURRU5nUcKUS :XaE[UR5S :Xa,[[URR555nUcgURU5 URS5S ;a@[URR55HupXLdM URU M gg7f)Nrar rer-rPz message-start)r1metadatalanggraph_node)r!noder*r0rD)zmessage-finishrA)r$r'r`r"r#r.r2rnr%rodispatchrEnextiterr items) rOrPrer-r*keyrsstream route_key candidates rrQMessagesDecoder.feeds 99X * , 8$* F #t 6 zz&!$%%  88G  /*40J$T?C(2488J3G(N(N$TV ))t/7?X\\"23T%*F !'LL  OOD !L$T*C\\%%c*F~#"5#dll:Kq:Pd4<<#6#6#89:~ OOD !xx $??,01C1C1E,F(I * LL3-G@s G:HH)ror`rnN)r! list[str]rpCallable[..., Any]rSrhrNrrrkrks# **+*"4rrkc,\rSrSrSrSSjrSSjrSrg) ToolCallsDecoderaYields one tool-call handle per `tool-started` event. Mirrors the per-event body of `_ToolCallsProjection._tool_calls_iter` (`_async/stream.py:1168-1217`). The thread register/unregister and the terminal-error-on-close finally stay at the projection / wrapper layer. Args: namespace: Events whose namespace differs are ignored. handle_factory: Keyword-only `(tool_call_id, name, input, namespace) -> handle`. c>[U5UlX l0UlgrM)r%r`_handle_factoryro)rOr!handle_factorys rrbToolCallsDecoder.__init__sy/-') rc#Z# URS5S:wagURS5=(d 0n[U5UR:wagURS5n[U[5(dgURS5n[U[ 5(dgURS5nUS:XaoURS5nUR U[U[ 5(aUOS URS 5[UR5S 9nXpRU'Uv gUS :XaXURRU5nURS 5nUb([U[ 5(aURU5 gggUS:XaAURRUS5nUb!URURS55 ggUS:Xa^URRUS5nUb>URS5n UR[U (a [ U 5OS55 ggg7f)Nrarrer- tool_call_idrPz tool-started tool_namerr)rr;rr!ztool-output-deltadeltaz tool-finishedoutputz tool-errormessagezTool call errored)r$r'r`r"r#r,rr%ro _push_deltapop_finish_fail RuntimeError) rOrPrer-r event_typer;handlerrs rrQToolCallsDecoder.feeds 99X ' ) 8$* F #t 6 zz&!$%% xx/ ,,, XXg&  '88K(D)))'c22Thhw't/ *F *0LL &L . .\\%%l3FHHW%E!j&<&<""5)'=! ? *\\%%lD9F!txx12" < '\\%%lD9F!((9-  W>QR"(sH)H+)rorr`N)r!rrrrSrhrNrrrrs * &rrc@\rSrSrSrS SjrS SjrS SjrS SjrSr g) SubgraphsDecoderiaDiscovers child subgraph handles and fans out events to active ones. Mirrors the per-event body of `_SubgraphsProjection._subgraphs_iter` (`_async/stream.py:963-1041`) plus `_apply_tasks_result`. Root-inbox forwarding and terminal-status-on-close stay at the projection / wrapper layer. Args: scope: Tuple-form namespace of this decoder's parent. `()` for root. handle_factory: Keyword-only `(path, graph_name, trigger_call_id) -> handle`. cHXlX l0Ul[5UlgrM)_scoperroset_seen)rOrGrs rrbSubgraphsDecoder.__init__s -35 +.5 rc## URS5=(d 0n[U5nURS5n[U[5(dgURS5n[ U5nUR R 5H=upx[U5n [U5U :dM!USU U:XdM,URU5 O US:XaMSU;aURX45 g[X0R5(aURU5ShvN ggUS:XaKURS5S:Xa5[X0R5(aURU5ShvN ggggNXN 7f) Nrer-rarresultrrPr3) r$r'r"r#rFroryrE _push_event_apply_tasks_resultrHr _discover) rOrPrer!r-rans_tuple child_path child_handle child_lens rrQSubgraphsDecoder.feedsC8$*$V, zz&!$%% 8$#(, (:(:(< $JJI8} )hz .Bj.P((/ )= W 4((9!)[[99>>)444: k !!Y. KK88~~i0 0 09/ "5 1s2B E/&E/1A!E/E+AE/"E-# E/-E/c## [U5nX R;agURRU5 [US5up4UR UU=(d SUS9nXPR U'Uv g7f)N)path graph_nametrigger_call_id)rFraddr>rro)rOr!rrrrs rrSubgraphsDecoder._discover1ssY ::   t&>tBx&H# %%!)T+&  $ T sA4A6c4URS5nU(dg[U5n[URR 55HMupVUSSU:waMUR U:waM"[ U5upxURXx5 URU MO g)Nr)r)r$rFr%roryrrBr) rOr!r- result_id parent_pathrrstatusrAs rr$SubgraphsDecoder._apply_tasks_result?sHHTN  I& "&t||'9'9';"< J#2+-%%27=MF NN6 ) Z(#=r)rorrrN)rGtuple[str, ...]rrrS)r!rrTrU)r!rr-dict[str, Any]rTNone) rVrWrXrYrirbrQrrrZrNrrrrs 1 1:  )rrc,\rSrSrSrSSjrSSjrSrg) ExtensionsDecoderiNa1Yields `params.data` from one named custom channel. Mirrors `_ExtensionProjection._iter` (`_async/stream.py:1278-1299`), with an added name filter so it can share one subscription in interleave. Args: name: The extension name. Only `custom` events whose `data["name"]` matches are consumed. c4U(d [S5eXlg)Nz!extension name must be non-empty.)r_name)rOr;s rrbExtensionsDecoder.__init__Ys@A A rc## URS5S:wagURS5=(d 0nURS5n[U[5(dgURS5UR:wagUv g7f)Nracustomrer-r;)r$r"r#rrfs rrQExtensionsDecoder.feed^sg 99X ( * 8$*zz&!$%%  88F tzz )  sA=A?)rN)r;r,rSrhrNrrrrNs rr)rrrTr)r&rrTr)r-rrT str | NonerM)r-rr1rrTr,)r:r,rTztuple[str, str | None])r-rrTz!tuple[SubgraphStatus, str | None])r!rrGrrTbool)ri __future__rcollections.abcrrrtypingrrr r frozensetrrr'r.r2SubgraphStatusr>rBrHrJr\rkrrrrNrrrs#77))! ))HI$B? HI*  &XChCB9494x77tJ)J)Zr