ޠjlSrSSKJr SSKrSSKJrJrJr SSKJ r J r J r SSK J r SSKJr SSKJr SS KJrJrJrJrJrJrJrJrJrJrJrJrJrJ r "S S 5r!g) z5Synchronous client for managing threads in LangGraph.) annotationsN)IteratorMappingSequence)AnyLiteraloverload)_quote_path_param)SyncHttpClient)SyncThreadStream) CheckpointJsonOnConflictBehavior PruneStrategyQueryParamTypes SortOrder StreamPartThreadThreadSelectField ThreadSortBy ThreadState ThreadStatusThreadStreamModeThreadUpdateStateResponsec n\rSrSrSrS)SjrSSSS.S*SjjrSSSSSSSSS.S+Sjjr\SS SSS .S,S jj5r \SSSS .S-S jj5r \SSSS .S.Sjj5r SS SSS .S.Sjjr SSS.S/Sjjr SSSSSSSSSSSSS. S0Sjjr SSSSSS.S1Sjjr SSS.S/Sjjr SSSS.S2SjjrS3S SSS.S4SjjjrSSSSSS.S5SjjrSSSSSSS .S6S!jjrS7SSS"S#.S8S$jjjrS%SSSS&.S9S'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"}) ``` cXlgNhttp)selfr!s U/var/www/html/gaurav/venv/lib/python3.13/site-packages/langgraph_sdk/_sync/threads.py__init__SyncThreadsClient.__init__,s N)includeheadersparamsc0nU(aSRU5US'U(aURU5 URRS[ U53UU=(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))joinupdater!getr )r" thread_idr'r(r) query_paramss r#r0SyncThreadsClient.get/sgR(* &)hhw&7L #     'yy}}))45 6'4  r&)metadatar1 if_exists superstepsgraph_idttlr(r)c 0n U(aX)S'U(dU(a0U=(d 0EU(aSU0O0EU S'U(aX9S'U(aEUV V s/sH3n SU SV s/sHn U SU RS5U SS .PM sn 0PM5 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" ) ``` ) r1r7r4r5updatesvaluescommandas_node)r;r<r=r6deleter8strategyr8z/threadsjsonr(r))r0 isinstanceintfloatr!post) r"r4r1r5r6r7r8r(r)payloadsus r#createSyncThreadsClient.createcsV#% #,K x#>r#-5J)2#GJ  #,K $ %$A "#9   ".A '(k'(uuY'7'(| ".   $ %GL ! ?#U|,,),(!C!$yy~~jwPV~WW#  %s C$CCCF)r8return_minimalr(r)cgrr"r1r4r8rLr(r)s r#r/SyncThreadsClient.updatesr&)r8r(r)cgrrNrOs r#r/rPsr&cgrrNrOs r#r/rPsr&cSU0nUb([U[[45(a USS.US'OX7S'[U=(d 05nU(aSUS'URR S[ U53UU=(d SUS 9$) a8Update 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"). return_minimal: If `True`, request a 204 response with no body. headers: Optional custom headers to include with the request. params: Optional query parameters to include with the request. Returns: The updated `Thread`, or `None` when `return_minimal=True`. ???+ 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, ) ``` r4Nr>r?r8zreturn=minimalPreferr,rA)rCrDrEdictr!patchr ) r"r1r4r8rLr(r)rGrequest_headerss r#r/rPsH$.x"8 ?#U|,,),(!C!$w}"- (8OH %yy))45 6#+t   r&r-cPURRS[U53X#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)r!r>r r"r1r(r)s r#r>SyncThreadsClient.deletes.4 ))45 6  r& r) r4r;idsstatuslimitoffsetsort_by sort_orderselectextractr(r)c UUS.n U(aXS'U(aX-S'U(aX=S'U(aXMS'U(aX}S'U(aXS'U (aXS'U (aXS 'URRS XU S 9$) aSearch for threads. Args: metadata: Thread metadata to filter on. values: State values to filter on. ids: List of thread IDs to filter by. status: Thread status to filter on. Must be one of 'idle', 'busy', 'interrupted' or 'error'. limit: Limit on number of threads to return. offset: Offset in threads table to start search from. sort_by: Sort by field. sort_order: Sort order. select: List of fields to include in the response. extract: Dictionary mapping aliases to JSONB paths to extract from thread data. Paths use dot notation for nested keys and bracket notation for array indices (e.g., `{"last_msg": "values.messages[-1]"}`). Extracted values are returned in an `extracted` field on each thread. Maximum 10 paths per request. headers: Optional custom headers to include with the request. params: Optional query parameters to include with the request. Returns: List of the threads matching the search parameters. ???+ example "Example Usage" ```python client = get_sync_client(url="http://localhost:2024") threads = client.threads.search( metadata={"number":1}, status="interrupted", limit=15, offset=5 ) ``` )r^r_r4r;r\r]r`rarbrcz/threads/searchrAr!rF)r"r4r;r\r]r^r_r`rarbrcr(r)rGs r#searchSyncThreadsClient.search$sl#  "*J   &H   EN  &H  !(I  $.L !  &H  !(I yy~~ GV  r&)r4r;r]r(r)c~0nU(aXS'U(aX&S'U(aX6S'URRSXdUS9$)acCount threads matching filters. Args: metadata: Thread metadata to filter on. values: State values to filter on. status: Thread status to filter on. headers: Optional custom headers to include with the request. params: Optional query parameters to include with the request. Returns: int: Number of threads matching the criteria. r4r;r]z/threads/countrAre)r"r4r;r]r(r)rGs r#countSyncThreadsClient.countqsK*#% "*J   &H   &H yy~~ 7F  r&cTURRS[U5S3SUUS9$)aCopy a thread. Args: thread_id: The ID of the thread to copy. 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_sync_client(url="http://localhost:2024") client.threads.copy( thread_id="my_thread_id" ) ``` r,z/copyNrAr!rFr rYs r#copySyncThreadsClient.copys:6yy~~))45U ;   r&r>)r@r(r)cTSU0nUS:waX%S'URRSXSUS9$)aPrune threads by ID. Args: thread_ids: List of thread IDs to prune. strategy: The prune strategy. `"delete"` removes threads entirely. `"keep_latest"` prunes old checkpoints but keeps threads and their latest state. Defaults to `"delete"`. headers: Optional custom headers to include with the request. params: Optional query parameters to include with the request. Returns: A dict containing `pruned_count` (number of threads pruned). ???+ example "Example Usage" ```python client = get_sync_client(url="http://localhost:2024") result = client.threads.prune( thread_ids=["thread_1", "thread_2"], ) print(result) # {'pruned_count': 2} ``` thread_idsr>r@z/threads/prunerAre)r"rpr@r(r)rGs r#pruneSyncThreadsClient.prunesDB *#  x "*J yy~~ 7F  r&) subgraphsr(r)cU(a+URRS[U5S3X$S.UUS9$U(aMSU0nU(a0UE[U5EnURR S[U5S[U53UUS9$SU0nU(a0UE[U5EnURR S[U5S3UUS9$) aGet the state of a thread. Args: thread_id: The ID of the thread to get the state of. checkpoint: The checkpoint to get the state of. subgraphs: Include subgraphs states. headers: Optional custom headers to include with the request. Returns: The thread of the state. ???+ example "Example Usage" ```python client = get_sync_client(url="http://localhost:2024") thread_state = client.threads.get_state( thread_id="my_thread_id", checkpoint_id="my_checkpoint_id" ) print(thread_state) ``` ```shell ---------------------------------------------------------------------------------------------------------------------------------------------------------------------- { 'values': { 'messages': [ { 'content': 'how are you?', 'additional_kwargs': {}, 'response_metadata': {}, 'type': 'human', 'name': None, 'id': 'fe0a5778-cfe9-42ee-b807-0adaa1873c10', 'example': False }, { 'content': "I'm doing well, thanks for asking! I'm an AI assistant created by Anthropic to be helpful, honest, and harmless.", 'additional_kwargs': {}, 'response_metadata': {}, 'type': 'ai', 'name': None, 'id': 'run-159b782c-b679-4830-83c6-cef87798fe8b', 'example': False, 'tool_calls': [], 'invalid_tool_calls': [], 'usage_metadata': None } ] }, 'next': [], 'checkpoint': { 'thread_id': 'e2496803-ecd5-4e0c-a779-3226296181c2', 'checkpoint_ns': '', 'checkpoint_id': '1ef4a9b8-e6fb-67b1-8001-abd5184439d1' } 'metadata': { 'step': 1, 'run_id': '1ef4a9b8-d7da-679a-a45a-872054341df2', 'source': 'loop', 'writes': { 'agent': { 'messages': [ { 'id': 'run-159b782c-b679-4830-83c6-cef87798fe8b', 'name': None, 'type': 'ai', 'content': "I'm doing well, thanks for asking! I'm an AI assistant created by Anthropic to be helpful, honest, and harmless.", 'example': False, 'tool_calls': [], 'usage_metadata': None, 'additional_kwargs': {}, 'response_metadata': {}, 'invalid_tool_calls': [] } ] } }, 'user_id': None, 'graph_id': 'agent', 'thread_id': 'e2496803-ecd5-4e0c-a779-3226296181c2', 'created_by': 'system', 'assistant_id': 'fe096781-5601-53d2-b2f6-0d3403f7e9ca'}, 'created_at': '2024-07-25T15:35:44.184703+00:00', 'parent_config': { 'thread_id': 'e2496803-ecd5-4e0c-a779-3226296181c2', 'checkpoint_ns': '', 'checkpoint_id': '1ef4a9b8-d80d-6fa7-8000-9300467fad0f' } } ``` r,z/state/checkpoint) checkpointrsrArsz/state/)r)r(/state)r!rFr rUr0)r"r1ru checkpoint_idrsr(r) get_paramss r# get_stateSyncThreadsClient.get_statesZ 99>>-i899JK$.G "  %y1J; ;d6l; 99==-i89ARS`Aa@bc!!  &y1J; ;d6l; 99==-i89@!! r&)r=rurwr(r)cSU0nU(aXXS'U(aXHS'U(aX8S'URRS[U5S3UUUS9$)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': {} } } ``` r;rwrur=r,rvrArl) r"r1r;r=rurwr(r)rGs r# update_stateSyncThreadsClient.update_statecsj` f#  '4O $ $.L ! !(I yy~~))45V <   r&)r^beforer4rur(r)cSU0nU(aX8S'U(aXHS'U(aXXS'URRS[U5S3UUUS9$)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"} ) ``` r^r~r4rur,z/historyrArl) r"r1r^r~r4rur(r)rGs r# get_historySyncThreadsClient.get_historysjL U#   &H  "*J  $.L !yy~~))45X >   r&sse)r(run_start_timeout transportc US;a [S5e[URUbUO[[R "55UUUUSLUS9$)aOpen a v3 thread-centric streaming session. Args: thread_id: optional explicit thread identifier. Defaults to a fresh UUIDv4. assistant_id: assistant the run will use. Required. headers: optional headers forwarded on every command and SSE request for this stream session. transport: event transport to use, `"sse"` (default) or `"websocket"`. Returns: A `SyncThreadStream` to use as a context manager. )r websocketz'transport must be 'sse' or 'websocket'.N)r!r1 assistant_idr(rexplicit_thread_idtransport_kind) ValueErrorr r!struuiduuid4)r"r1rr(rrs r#streamSyncThreadsClient.streamsV. 0 0FG G#,#8ic$**,>O%/(4$  r& run_modes) stream_mode last_event_idr(r)cSU0nU(aURU5 URRS[U5S3S0U(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) ``` rr,z/streamGETz Last-Event-IDr-)r/r!rr )r"r1rrr(r)r2s r# join_streamSyncThreadsClient.join_streams}D ;      'yy))45W = 7DO]3"=b    r&r )r!r returnNone) r1rr'Sequence[str] | Noner(Mapping[str, str] | Noner)QueryParamTypes | Nonerr)r4rr1 str | Noner5zOnConflictBehavior | Noner6z4Sequence[dict[str, Sequence[dict[str, Any]]]] | Noner7rr8int | Mapping[str, Any] | Noner(rr)rrr)r1rr4Mapping[str, Any]r8rrLzLiteral[False]r(rr)rrr)r1rr4rr8rrLz Literal[True]r(rr)rrr)r1rr4rr8rrLboolr(rr)rrz Thread | None)r1rr(rr)rrr)r4rr;rr\rr]ThreadStatus | Noner^rDr_rDr`zThreadSortBy | NonerazSortOrder | Nonerbzlist[ThreadSelectField] | Nonerczdict[str, str] | Noner(rr)rrz list[Thread]) r4rr;rr]rr(rr)rrrD) rpz Sequence[str]r@rr(rr)rrzdict[str, Any])NN)r1rruCheckpoint | Nonerwrrsrr(rr)rrr)r1rr;z&dict[str, Any] | Sequence[dict] | Noner=rrurrwrr(rr)rrr)r1rr^rDr~zstr | Checkpoint | Noner4zMapping[str, Any] | Nonerurr(rr)rrzlist[ThreadState]r) r1rrrr(rrz float | NonerzLiteral['sse', 'websocket']rr ) r1rrz-ThreadStreamMode | Sequence[ThreadStreamMode]rrr(rr)rrzIterator[StreamPart])__name__ __module__ __qualname____firstlineno____doc__r$r0rJr r/r>rfrirmrqryr|rrr__static_attributes__rNr&r#rrs )-,0)- 2 2 & 2 * 2 ' 2  2 n $/3KO#.2,0)-IXIX IX - IX I IXIX,IX*IX'IX IXV /3).,0)-  $  ,  ' * '     /3,0)-  $  ,  & * '     /3,0)-  $  ,   * '     /3$,0)-2 2 $ 2 , 2  2 *2 '2  2 p-1)-   *  '    B$(&*'+'+15)-,0)-K K  K " K $ K K K %K %K /K 'K *K 'K  K `&*,0)-    $  *  '   H-1)-    *  '    L#+,0)- ' !'  ' * ' ' '  ' X)-$( E  ,0)-EE&E" E  E*E'E EX#(,$(,0)-= = 7=  = & = "= *= '=  #= F*.-1(,,0)-3 3  3 ( 3 + 3 &3 *3 '3  3 n!%! -1*.16! !  ! * ! ( ! /!  ! NFQ$(,0)-. . C . " . * . '.  . . r&r)"r __future__rrcollections.abcrrrtypingrrr langgraph_sdk._shared.utilitiesr langgraph_sdk._sync.httpr langgraph_sdk._sync.streamr langgraph_sdk.schemar rrrrrrrrrrrrrrrNr&r#rsC;" 77))=37$J  J  r&