=Ki^SrSSKJr SSKJrJrJr SSKJr SSK J r SSK J r J r JrJrJrJrJrJrJrJrJrJrJrJr "SS5rg ) z5Synchronous client for managing threads in LangGraph.) annotations)IteratorMappingSequence)Any)SyncHttpClient) CheckpointJsonOnConflictBehavior PruneStrategyQueryParamTypes SortOrder StreamPartThreadThreadSelectField ThreadSortBy ThreadState ThreadStatusThreadStreamModeThreadUpdateStateResponsec \rSrSrSrS"SjrSSSS.S#SjjrSSSSSSSSS.S$SjjrSSSS .S%S jjrSSS .S&S jjr SSSSS SSSSSSS. S'Sjjr SSSSSS.S(Sjjr SSS .S&Sjjr SSSS.S)Sjjr S*SSSS.S+SjjjrSSSSSS.S,SjjrS SSSSSS.S-SjjrSSSSS.S.S jjrS!rg)/SyncThreadsClienta]Synchronous client for managing threads in LangGraph. This class provides methods to create, retrieve, and manage threads, which represent conversations or stateful interactions. ???+ example "Example" ```python client = get_sync_client(url="http://localhost:2024") thread = client.threads.create(metadata={"user_id": "123"}) ``` cXlg)Nhttp)selfrs ]/var/www/html/dynamic-report/venv/lib/python3.13/site-packages/langgraph_sdk/_sync/threads.py__init__SyncThreadsClient.__init__)s N)includeheadersparamsc0nU(aSRU5US'U(aURU5 URRSU3UU=(d SS9$)a2Get a thread by ID. Args: thread_id: The ID of the thread to get. include: Additional fields to include in the response. Supported values: `"ttl"`. headers: Optional custom headers to include with the request. params: Optional query parameters to include with the request. Returns: `Thread` object. ???+ example "Example Usage" ```python client = get_sync_client(url="http://localhost:2024") thread = client.threads.get( thread_id="my_thread_id" ) print(thread) ``` ```shell ----------------------------------------------------- { 'thread_id': 'my_thread_id', 'created_at': '2024-07-18T18:35:15.540834+00:00', 'updated_at': '2024-07-18T18:35:15.540834+00:00', 'metadata': {'graph_id': 'agent'} } ``` ,r" /threads/Nr#r$)joinupdaterget)r thread_idr"r#r$ query_paramss rr+SyncThreadsClient.get,s`R(* &)hhw&7L #     'yy}} { #'4  r!)metadatar, if_exists superstepsgraph_idttlr#r$c 0n U(aX)S'U(dU(a0U=(d 0EU(aSU0O0EU S'U(aX9S'U(aGUV V s/sH4n SU SV s/sHn U SU RS5U SS .PM sn 0PM6 sn n U S 'Ub([U[[45(a US S .U S 'OXiS 'URR SXUS9$s sn fs sn n f)aCreate a new thread. Args: metadata: Metadata to add to thread. thread_id: ID of thread. If `None`, ID will be a randomly generated UUID. if_exists: How to handle duplicate creation. Defaults to 'raise' under the hood. Must be either 'raise' (raise error if duplicate), or 'do_nothing' (return existing thread). supersteps: Apply a list of supersteps when creating a thread, each containing a sequence of updates. Each update has `values` or `command` and `as_node`. Used for copying a thread between deployments. graph_id: Optional graph ID to associate with the thread. ttl: Optional time-to-live in minutes for the thread. You can pass an integer (minutes) or a mapping with keys `ttl` and optional `strategy` (defaults to "delete"). headers: Optional custom headers to include with the request. Returns: The created `Thread`. ???+ example "Example Usage" ```python client = get_sync_client(url="http://localhost:2024") thread = client.threads.create( metadata={"number":1}, thread_id="my-thread-id", if_exists="raise" ) ``` ) r,r2r/r0updatesvaluescommandas_node)r6r7r8r1deleter3strategyr3z/threadsjsonr#r$)r+ isinstanceintfloatrpost) rr/r,r0r1r2r3r#r$payloadsus rcreateSyncThreadsClient.create`sV#% #,K x#>r#-5J)2#GJ  #,K $ %$A "#9   ".A '(k'(uuY'7'(| ".   $ %GL ! ?#U|,,),(!C!$yy~~jwPV~WW#  %sC%CCC)r3r#r$cSU0nUb([U[[45(a USS.US'OX6S'URR SU3UUUS9$)aUpdate a thread. Args: thread_id: ID of thread to update. metadata: Metadata to merge with existing thread metadata. ttl: Optional time-to-live in minutes for the thread. You can pass an integer (minutes) or a mapping with keys `ttl` and optional `strategy` (defaults to "delete"). headers: Optional custom headers to include with the request. params: Optional query parameters to include with the request. Returns: The created `Thread`. ???+ example "Example Usage" ```python client = get_sync_client(url="http://localhost:2024") thread = client.threads.update( thread_id="my-thread-id", metadata={"number":1}, ttl=43_200, ) ``` r/r9r:r3r'r<)r>r?r@rpatch)rr,r/r3r#r$rBs rr*SyncThreadsClient.updatesgD$.x"8 ?#U|,,),(!C!$yy { #   r!r(c>URRSU3X#S9 g)aYDelete a thread. Args: thread_id: The ID of the thread to delete. headers: Optional custom headers to include with the request. params: Optional query parameters to include with the request. Returns: `None` ???+ example "Example Usage" ```python client.threads.delete( thread_id="my_thread_id" ) ``` r'r(N)rr9rr,r#r$s rr9SyncThreadsClient.deletes"4 9YK0'Qr! r) r/r6idsstatuslimitoffsetsort_by sort_orderselectr#r$c UUS.n U(aXS'U(aX,S'U(aX>I;&78$.G "  %y1J; ;d6l; 99==I;gm_=!!  &y1J; ;d6l; 99==I;f-!! r!)r8rerhr#r$cSU0nU(aXXS'U(aXHS'U(aX8S'URRSUS3XUS9$)aUpdate the state of a thread. Args: thread_id: The ID of the thread to update. values: The values to update the state with. as_node: Update the state as if this node had just executed. checkpoint: The checkpoint to update the state of. headers: Optional custom headers to include with the request. Returns: Response after updating a thread's state. ???+ example "Example Usage" ```python response = await client.threads.update_state( thread_id="my_thread_id", values={"messages":[{"role": "user", "content": "hello!"}]}, as_node="my_node", ) print(response) ---------------------------------------------------------------------------------------------------------------------------------------------------------------------- { 'checkpoint': { 'thread_id': 'e2496803-ecd5-4e0c-a779-3226296181c2', 'checkpoint_ns': '', 'checkpoint_id': '1ef4a9b8-e6fb-67b1-8001-abd5184439d1', 'checkpoint_map': {} } } ``` r6rhrer8r'rfr<rV) rr,r6r8rerhr#r$rBs r update_stateSyncThreadsClient.update_state%s_` f#  '4O $ $.L ! !(I yy~~ {& )QW  r!)rPbeforer/rer#r$cSU0nU(aX8S'U(aXHS'U(aXXS'URRSUS3UUUS9$)aGet the state history of a thread. Args: thread_id: The ID of the thread to get the state history for. checkpoint: Return states for this subgraph. If empty defaults to root. limit: The maximum number of states to return. before: Return states before this checkpoint. metadata: Filter states by metadata key-value pairs. headers: Optional custom headers to include with the request. Returns: The state history of the `Thread`. ???+ example "Example Usage" ```python thread_state = client.threads.get_history( thread_id="my_thread_id", limit=5, before="my_timestamp", metadata={"name":"my_name"} ) ``` rPror/rer'z/historyr<rV) rr,rPror/rer#r$rBs r get_historySyncThreadsClient.get_historyascL U#   &H  "*J  $.L !yy~~ {( +   r! run_modes) stream_mode last_event_idr#r$cSU0nU(aURU5 URRSUS3S0U(aSU0O0EU=(d 0EUS9$)a3Get a stream of events for a thread. Args: thread_id: The ID of the thread to get the stream for. last_event_id: The ID of the last event to get. headers: Optional custom headers to include with the request. params: Optional query parameters to include with the request. Returns: An iterator of stream parts. ???+ example "Example Usage" ```python for chunk in client.threads.join_stream( thread_id="my_thread_id", last_event_id="my_event_id", stream_mode="run_modes", ): print(chunk) ``` rtr'z/streamGETz Last-Event-IDr()r*rstream)rr,rtrur#r$r-s r join_streamSyncThreadsClient.join_streamsvD ;      'yy {' * 7DO]3"=b    r!r)rrreturnNone) r,strr"Sequence[str] | Noner#Mapping[str, str] | Noner$QueryParamTypes | Noner{r)r/r r, str | Noner0zOnConflictBehavior | Noner1z4Sequence[dict[str, Sequence[dict[str, Any]]]] | Noner2rr3int | Mapping[str, Any] | Noner#rr$rr{r) r,r}r/zMapping[str, Any]r3rr#rr$rr{r)r,r}r#rr$rr{r|)r/r r6r rNr~rOThreadStatus | NonerPr?rQr?rRzThreadSortBy | NonerSzSortOrder | NonerTzlist[ThreadSelectField] | Noner#rr$rr{z list[Thread]) r/r r6r rOrr#rr$rr{r?) r`z Sequence[str]r;r r#rr$rr{zdict[str, Any])NN)r,r}reCheckpoint | Nonerhrrcboolr#rr$rr{r)r,r}r6z&dict[str, Any] | Sequence[dict] | Noner8rrerrhrr#rr$rr{r)r,r}rPr?rozstr | Checkpoint | Noner/zMapping[str, Any] | Nonererr#rr$rr{zlist[ThreadState]) r,r}rtz-ThreadStreamMode | Sequence[ThreadStreamMode]rurr#rr$rr{zIterator[StreamPart])__name__ __module__ __qualname____firstlineno____doc__rr+rEr*r9rWrZr]rarjrmrqry__static_attributes__r!rrrsU )-,0)- 2 2 & 2 * 2 ' 2  2 n $/3KO#.2,0)-IXIX IX - IX I IXIX,IX*IX'IX IX`/3,0)-- - $ - , - * - '-  - f-1)- RR* R ' R  R>$(&*'+'+15,0)-> >  > " > $ > > > %> %> /> *> '>  > F&*,0)-    $  *  '   H-1)-   *  '    F#+,0)- ' !'  ' * ' ' '  ' X)-$( E  ,0)-EE&E" E  E*E'E EX#(,$(,0)-: : 7:  : & : ": *: ':  #: @*.-1(,,0)-3 3  3 ( 3 + 3 &3 *3 '3  3 rFQ$(,0)-. . C . " . * . '.  . . r!rN)r __future__rcollections.abcrrrtypingrlanggraph_sdk._sync.httprlanggraph_sdk.schemar r r r r rrrrrrrrrrrr!rrs7;"773$i  i  r!