tjwidZddlmZddlmZddlmZmZmZm Z ddl Z ddl m Z ddl mZddlmZmZmZmZmZmZmZmZmZmZmZmZmZGd d ZdS) z8Synchronous client for managing assistants in LangGraph.) annotations)Mapping)AnyLiteralcastoverloadN)_quote_path_param)SyncHttpClient) AssistantAssistantSelectFieldAssistantSortByAssistantsSearchResponseAssistantVersionConfigContext GraphSchemaJsonOnConflictBehaviorQueryParamTypes SortOrder Subgraphsc reZdZdZdOdZddddPdZdddddQdZddddRdZ dSddddTdZ dUddddddddddVd+Z ddddddddd,dWd-Z dddd.dXd0Z e dddd1d2dddddd3 dYd@Z e dddd1d2ddddAdddB dZdEZ dddd1d2ddddAdddB d[dHZ ddddddId\dJZ d]dddd^dLZdddd_dNZdS)`SyncAssistantsClientafClient for managing assistants in LangGraph synchronously. This class provides methods to interact with assistants, which are versioned configurations of your graph. ???+ example "Example" ```python client = get_sync_client(url="http://localhost:2024") assistant = client.assistants.get("assistant_id_123") ``` httpr returnNonec||_dSN)r)selfrs \/var/www/html/CA-Chatbot/venv/lib/python3.11/site-packages/langgraph_sdk/_sync/assistants.py__init__zSyncAssistantsClient.__init__*s  Nheadersparams assistant_idstrr$Mapping[str, str] | Noner%QueryParamTypes | Noner c\|jdt|||S)aGet an assistant by ID. Args: assistant_id: The ID of the assistant to get OR the name of the graph (to use the default assistant). headers: Optional custom headers to include with the request. params: Optional query parameters to include with the request. Returns: `Assistant` Object. ???+ example "Example Usage" ```python assistant = client.assistants.get( assistant_id="my_assistant_id" ) print(assistant) ``` ```shell ---------------------------------------------------- { 'assistant_id': 'my_assistant_id', 'graph_id': 'agent', 'created_at': '2024-06-25T17:10:33.109781+00:00', 'updated_at': '2024-06-25T17:10:33.109781+00:00', 'config': {}, 'context': {}, 'metadata': {'created_by': 'system'} } ``` /assistants/r#rgetr rr&r$r%s r r-zSyncAssistantsClient.get-s<Ry}} <,\:: < <   r"F)xrayr$r%r/ int | booldict[str, list[dict[str, Any]]]cd|i}|r|||jdt|d||S)aGet the graph of an assistant by ID. Args: assistant_id: The ID of the assistant to get the graph of. xray: Include graph representation of subgraphs. If an integer value is provided, only subgraphs with a depth less than or equal to the value will be included. headers: Optional custom headers to include with the request. params: Optional query parameters to include with the request. Returns: The graph information for the assistant in JSON format. ???+ example "Example Usage" ```python client = get_sync_client(url="http://localhost:2024") graph_info = client.assistants.get_graph( assistant_id="my_assistant_id" ) print(graph_info) -------------------------------------------------------------------------------------------------------------------------- { 'nodes': [ {'id': '__start__', 'type': 'schema', 'data': '__start__'}, {'id': '__end__', 'type': 'schema', 'data': '__end__'}, {'id': 'agent','type': 'runnable','data': {'id': ['langgraph', 'utils', 'RunnableCallable'],'name': 'agent'}}, ], 'edges': [ {'source': '__start__', 'target': 'agent'}, {'source': 'agent','target': '__end__'} ] } ``` r/r+z/graphr%r$)updaterr-r )rr&r/r$r% query_paramss r get_graphzSyncAssistantsClient.get_graph\sd\~  (    ' ' 'y}} B,\:: B B B   r"rc^|jdt|d||S)aGet the schemas of an assistant by ID. Args: assistant_id: The ID of the assistant to get the schema of. headers: Optional custom headers to include with the request. params: Optional query parameters to include with the request. Returns: GraphSchema: The graph schema for the assistant. ???+ example "Example Usage" ```python client = get_sync_client(url="http://localhost:2024") schema = client.assistants.get_schemas( assistant_id="my_assistant_id" ) print(schema) ``` ```shell ---------------------------------------------------------------------------------------------------------------------------- { 'graph_id': 'agent', 'state_schema': { 'title': 'LangGraphInput', '$ref': '#/definitions/AgentState', 'definitions': { 'BaseMessage': { 'title': 'BaseMessage', 'description': 'Base abstract Message class. Messages are the inputs and outputs of ChatModels.', 'type': 'object', 'properties': { 'content': { 'title': 'Content', 'anyOf': [ {'type': 'string'}, {'type': 'array','items': {'anyOf': [{'type': 'string'}, {'type': 'object'}]}} ] }, 'additional_kwargs': { 'title': 'Additional Kwargs', 'type': 'object' }, 'response_metadata': { 'title': 'Response Metadata', 'type': 'object' }, 'type': { 'title': 'Type', 'type': 'string' }, 'name': { 'title': 'Name', 'type': 'string' }, 'id': { 'title': 'Id', 'type': 'string' } }, 'required': ['content', 'type'] }, 'AgentState': { 'title': 'AgentState', 'type': 'object', 'properties': { 'messages': { 'title': 'Messages', 'type': 'array', 'items': {'$ref': '#/definitions/BaseMessage'} } }, 'required': ['messages'] } } }, 'config_schema': { 'title': 'Configurable', 'type': 'object', 'properties': { 'model_name': { 'title': 'Model Name', 'enum': ['anthropic', 'openai'], 'type': 'string' } } }, 'context_schema': { 'title': 'Context', 'type': 'object', 'properties': { 'model_name': { 'title': 'Model Name', 'enum': ['anthropic', 'openai'], 'type': 'string' } } } } ``` r+z/schemasr#r,r.s r get_schemasz SyncAssistantsClient.get_schemass?By}} D,\:: D D D   r" namespace str | Nonerecurseboolrcd|i}|ri|t|}|=|jdt|dt|||S|jdt|d||S)aiGet the schemas of an assistant by ID. Args: assistant_id: The ID of the assistant to get the schema of. headers: Optional custom headers to include with the request. params: Optional query parameters to include with the request. Returns: Subgraphs: The graph schema for the assistant. r;Nr+z /subgraphs/r3z /subgraphs)dictrr-r )rr&r9r;r$r% get_paramss r get_subgraphsz"SyncAssistantsClient.get_subgraphss( )  87J7$v,,7J  9==i0>>iiK\]fKgKgii!!  9==J0>>JJJ!! r")contextmetadatar& if_existsnamer$ descriptionr%graph_idconfig Config | NonerAContext | NonerBrrCOnConflictBehavior | NonerDrEcd|i} |r|| d<|r|| d<|r|| d<|r|| d<|r|| d<|r|| d<| r| | d<|jd | || S) aCreate a new assistant. Useful when graph is configurable and you want to create different assistants based on different configurations. Args: graph_id: The ID of the graph the assistant should use. The graph ID is normally set in your langgraph.json configuration. config: Configuration to use for the graph. context: Static context to add to the assistant. !!! version-added "Added in version 0.6.0" metadata: Metadata to add to assistant. assistant_id: Assistant ID to use, will default to a random UUID if not provided. 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 assistant). name: The name of the assistant. Defaults to 'Untitled' under the hood. headers: Optional custom headers to include with the request. description: Optional description of the assistant. The description field is available for langgraph-api server version>=0.0.45 params: Optional query parameters to include with the request. Returns: The created assistant. ???+ example "Example Usage" ```python client = get_sync_client(url="http://localhost:2024") assistant = client.assistants.create( graph_id="agent", context={"model_name": "openai"}, metadata={"number":1}, assistant_id="my-assistant-id", if_exists="do_nothing", name="my_name" ) ``` rFrGrArBr&rCrDrEz /assistantsjsonr$r%rpost) rrFrGrArBr&rCrDr$rEr%payloads r createzSyncAssistantsClient.create>sf #   ' &GH   )!(GI   +"*GJ   3&2GN #  -#,GK  #"GFO  1%0GM "y~~    r")rFrGrArBrDr$rEr%ci} |r|| d<||| d<||| d<|r|| d<|r|| d<|r|| d<|jdt|| || S) azUpdate an assistant. Use this to point to a different graph, update the configuration, or change the metadata of an assistant. Args: assistant_id: Assistant to update. graph_id: The ID of the graph the assistant should use. The graph ID is normally set in your langgraph.json configuration. If `None`, assistant will keep pointing to same graph. config: Configuration to use for the graph. context: Static context to add to the assistant. !!! version-added "Added in version 0.6.0" metadata: Metadata to merge with existing assistant metadata. name: The new name for the assistant. headers: Optional custom headers to include with the request. description: Optional description of the assistant. The description field is available for langgraph-api server version>=0.0.45 Returns: The updated assistant. ???+ example "Example Usage" ```python client = get_sync_client(url="http://localhost:2024") assistant = client.assistants.update( assistant_id='e280dad7-8618-443f-87f1-8e41841c180f', graph_id="other-graph", context={"model_name": "anthropic"}, metadata={"number":2} ) ``` rFNrGrArBrDrEr+rL)rpatchr ) rr&rFrGrArBrDr$rEr%rPs r r4zSyncAssistantsClient.updatesZ#%  +"*GJ    &GH   !(GI   +"*GJ   #"GFO  1%0GM "y <,\:: < <    r")delete_threadsr$r%rTci}|rd|d<|r|||jdt|||pddS)aDelete an assistant. Args: assistant_id: The assistant ID to delete. delete_threads: If true, delete all threads with `metadata.assistant_id` matching this assistant, along with runs and checkpoints belonging to those threads. 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.assistants.delete( assistant_id="my_assistant_id" ) ``` TrTr+Nr#)r4rdeleter )rr&rTr$r%r5s r rVzSyncAssistantsClient.deletes>(*  2-1L) *  (    ' ' '  <,\:: < <'4      r" r) rBrFrDlimitoffsetsort_by sort_orderselectr$r%rXintrYrZAssistantSortBy | Noner[SortOrder | Noner\!list[AssistantSelectField] | Noneresponse_formatLiteral['object']rc dSr rrBrFrDrXrYrZr[r\rar$r%s r searchzSyncAssistantsClient.searchs $'3r"array) rBrFrDrXrYrZr[r\rar$r%Literal['array']list[Assistant]c dSrrdres r rfzSyncAssistantsClient.searchs #r"Literal['array', 'object']*AssistantsSearchResponse | list[Assistant]c <| dvrtd||d} |r|| d<|r|| d<|r|| d<|r|| d<|r|| d<|r|| d <d dfd } ttt|jd| | | | dkr| nd }| dkr|dS|S)a Search for assistants. Args: metadata: Metadata to filter by. Exact match filter for each KV pair. graph_id: The ID of the graph to filter by. The graph ID is normally set in your langgraph.json configuration. name: The name of the assistant to filter by. The filtering logic will match assistants where 'name' is a substring (case insensitive) of the assistant name. limit: The maximum number of results to return. offset: The number of results to skip. sort_by: The field to sort by. sort_order: The order to sort by. select: Specific assistant fields to include in the response. response_format: Controls the response shape. Use `"array"` (default) to return a bare list of assistants, or `"object"` to return a mapping containing assistants plus pagination metadata. Defaults to "array", though this default will be changed to "object" in a future release. headers: Optional custom headers to include with the request. Returns: A list of assistants (when `response_format="array"`) or a mapping with the assistants and the next pagination cursor (when `response_format="object"`). ???+ example "Example Usage" ```python client = get_sync_client(url="http://localhost:2024") response = client.assistants.search( metadata = {"name":"my_name"}, graph_id="my_graph_id", limit=5, offset=5, response_format="object", ) assistants = response["assistants"] next_cursor = response["next"] ``` )rgobjectz+response_format must be 'array' or 'object'rXrYrBrFrDrZr[r\Nresponsehttpx.Responserrc<|jddS)NzX-Pagination-Next)r$r-)rp next_cursors r capture_paginationz7SyncAssistantsClient.search..capture_pagination\s"*../BCCKKKr"z/assistants/searchrn)rMr$r% on_response) assistantsnext)rprqrr) ValueErrorrlistr rrO)rrBrFrDrXrYrZr[r\rar$r%rPrtrvrss @r rfzSyncAssistantsClient.searchs:l "5 5 5JKK K# #   +"*GJ   +"*GJ   #"GFO  )!(GI   /$.GL !  ' &GH "&  D D D D D D O INN$2AX2M2M..SW       h & &",kBB Br")rBrFrDr$r%cli}|r||d<|r||d<|r||d<|jd|||S)aOCount assistants matching filters. Args: metadata: Metadata to filter by. Exact match for each key/value. graph_id: Optional graph id to filter by. name: Optional name to filter by. The filtering logic will match assistants where 'name' is a substring (case insensitive) of the assistant name. headers: Optional custom headers to include with the request. params: Optional query parameters to include with the request. Returns: int: Number of assistants matching the criteria. rBrFrDz/assistants/countrLrN)rrBrFrDr$r%rPs r countzSyncAssistantsClient.countnsd,#%  +"*GJ   +"*GJ   #"GFOy~~ gwv   r"list[AssistantVersion]cx||d}|r||d<|jdt|d|||S)aList all versions of an assistant. Args: assistant_id: The assistant ID to get versions for. metadata: Metadata to filter versions by. Exact match filter for each KV pair. limit: The maximum number of versions to return. offset: The number of versions to skip. headers: Optional custom headers to include with the request. Returns: A list of assistants. ???+ example "Example Usage" ```python client = get_sync_client(url="http://localhost:2024") assistant_versions = client.assistants.get_versions( assistant_id="my_assistant_id" ) ``` rorBr+z /versionsrLrrOr )rr&rBrXrYr$r%rPs r get_versionsz!SyncAssistantsClient.get_versionsshD# #   +"*GJ y~~ E,\:: E E E    r"versionchd|i}|jdt|d|||S)aFChange the version of an assistant. Args: assistant_id: The assistant ID to delete. version: The version to change to. headers: Optional custom headers to include with the request. Returns: `Assistant` Object. ???+ example "Example Usage" ```python client = get_sync_client(url="http://localhost:2024") new_version_assistant = client.assistants.set_latest( assistant_id="my_assistant_id", version=3 ) ``` rr+z/latestrLr~)rr&rr$r%rPs r set_latestzSyncAssistantsClient.set_latestsK<$-g"6y~~ C,\:: C C C    r")rr rr)r&r'r$r(r%r)rr ) r&r'r/r0r$r(r%r)rr1)r&r'r$r(r%r)rr)NF) r&r'r9r:r;r<r$r(r%r)rrr)rFr:rGrHrArIrBrr&r:rCrJrDr:r$r(rEr:r%r)rr )r&r'rFr:rGrHrArIrBrrDr:r$r(rEr:r%r)rr ) r&r'rTr<r$r(r%r)rr)rBrrFr:rDr:rXr]rYr]rZr^r[r_r\r`rarbr$r(r%r)rr)rBrrFr:rDr:rXr]rYr]rZr^r[r_r\r`rarhr$r(r%r)rri)rBrrFr:rDr:rXr]rYr]rZr^r[r_r\r`rarkr$r(r%r)rrl) rBrrFr:rDr:r$r(r%r)rr])NrWr)r&r'rBrrXr]rYr]r$r(r%r)rr|) r&r'rr]r$r(r%r)rr )__name__ __module__ __qualname____doc__r!r-r6r8r@rQr4rVrrfr{rrrdr"r rrs  -1)- - - - - - - f!,0)- 5 5 5 5 5 5 v-1)- E E E E E E T!% " -1)-""""""N!%E #'#'/3,0"&)-E E E E E E V $ $"&,0"&)-? ? ? ? ? ? J %,0)- ( ( ( ( ( ( T#*.'+48,0)-'''''X' #*.'+48,3,0)-X&#*.'+486=,0)-ZZZZZZ~#,0)-      H , -1)-, , , , , , f-1)- % % % % % % % % r"r)r __future__rcollections.abcrtypingrrrrhttpxlanggraph_sdk._shared.utilitiesr langgraph_sdk._sync.httpr langgraph_sdk.schemar r r rrrrrrrrrrrrdr"r rsR>>""""""######//////////// ======333333"E  E  E  E  E  E  E  E  E  E  r"