=KiaSrSSKJr SSKJrJrJr SSKJr SSK J r SSK J r J r JrJrJrJrJrJrJrJrJrJrJrJr "SS5rg ) z/Async client for managing threads in LangGraph.) annotations) AsyncIteratorMappingSequence)Any) HttpClient) 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)/ ThreadsClientaClient for managing threads in LangGraph. A thread maintains the state of a graph across multiple interactions/invocations (aka runs). It accumulates and persists the graph's state, allowing for continuity between separate invocations of the graph. ???+ example "Example" ```python client = get_client(url="http://localhost:2024")) new_thread = await client.threads.create(metadata={"user_id": "123"}) ``` cXlg)Nhttp)selfrs ^/var/www/html/dynamic-report/venv/lib/python3.13/site-packages/langgraph_sdk/_async/threads.py__init__ThreadsClient.__init__*s N)includeheadersparamsc# 0nU(aSRU5US'U(aURU5 URRSU3UU=(d SS9IShvN $N7f)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_client(url="http://localhost:2024") thread = await 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+ThreadsClient.get-smT(* &)hhw&7L #     'YY]] { #'4#    sA A)"A'#A))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 SXUS9IS hvN $s sn fs sn n fN7f)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. params: Optional query parameters to include with the request. Returns: The created thread. ???+ example "Example Usage" ```python client = get_client(url="http://localhost:2024") thread = await client.threads.create( metadata={"number":1}, thread_id="my-thread-id", if_exists="raise" ) ``` r,r2r/r0updatesvaluescommandas_node)r6r7r8r1Ndeleter3strategyr3z/threadsjsonr#r$)r+ isinstanceintfloatrpost) rr/r,r0r1r2r3r#r$payloadsus rcreateThreadsClient.createbs&V#% #,K x#>r#-5J)2#GJ  #,K $ %$A "#9   ".A '(k'(uuY'7'(| ".   $ %GL ! ?#U|,,),(!C!$YY^^ Wf$   #  %& s7AC/C' %C"C' AC/C-C/"C''C/)r3r#r$c# SU0nUb([U[[45(a USS.US'OX6S'URR SU3UUUS9IShvN $N7f)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_client(url="http://localhost:2024") thread = await client.threads.update( thread_id="my-thread-id", metadata={"number":1}, ttl=43_200, ) ``` r/Nr9r:r3r'r<)r>r?r@rpatch)rr,r/r3r#r$rBs rr*ThreadsClient.updatestD$.x"8 ?#U|,,),(!C!$YY__ { # %    sAAAAr(cZ# URRSU3X#S9IShvN gN7f)aDelete 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 = get_client(url="http://localhost2024) await client.threads.delete( thread_id="my_thread_id" ) ``` r'r(N)rr9rr,r#r$s rr9ThreadsClient.deletes+6ii9+6WWWs !+)+ r) r/r6idsstatuslimitoffsetsort_by sort_orderselectr#r$c # UUS.n U(aXS'U(aX,S'U(aXrs75"<<0$w  w  r!