;i"SrSSKJr SSKrSSKrSSKrSSKrSSKrSSKrSSK J r J r J r J r SSKJrJrJrJrJr SSKrSSKJr SSKJr SSKJr SS KJr \\R>\ 4r!"S S 5r"S S jr#g)zThe Async LangSmith Client.) annotationsN)AsyncGenerator AsyncIteratorMappingSequence)AnyLiteralOptionalUnioncast)client)schemas)utils)_beta_decoratorc<\rSrSrSrSrS`SaSjjrSbSjrSrSr \ S 5r \ ScS j5r SdS jr SeSfS jjrSS SS.SgSjjrSSS.ShSjjrSiSjrSjSjrSSSSSSSSSSSSSSSSS.SkSjjrSS.SlSjjrSmSjrSnSjrSoSjrSpSqSjjrSSS.SrSjjrSsSjrSpStS jjrSuS!jrSvS"jrSwSxS#jjrSyS$jrSSS%.SzS&jjr SwS{S'jjr!SeSSSSS(.S|S)jjjr"SSSS*.S}S+jjr#S~S,jr$SSSSS-.SS.jjr%SS/jr&SSSSS0.SS1jjr'SSS2.SS3jjr(SS4jr)SS5.SS6jjr*SS7jr+SS8jr,SS9jr-SS:jr.\/R`S;S<.SS=jj5r1\/R`SS>j5r2\/R`SS?.SS@jj5r3SSAjr4SSBjr5SSCjr6SSSEjjr7SSFjr8SSGjr9SSHjr:SSIjr;SSJjrdD,QH  E * *:V:a-a$hTA:VWHH((   AEWs/C4c# U$7f)zEnter the async client.r*s r3 __aenter__AsyncClient.__aenter__Fs  sc@# UR5IShvN gN7f)zExit the async client.N)aclose)r*exc_typeexc_valexc_tbs r3 __aexit__AsyncClient.__aexit__Jskkms cT# URR5IShvN gN7f)zClose the async client.N)rr<r8s r3r<AsyncClient.acloseNsll!!###s (&(c@[URR5$N)strrrr8s r3_api_urlAsyncClient._api_urlRs4<<(())cX[R"URUR5$)zThe web host url.)r get_host_urlrrGr8s r3 _host_urlAsyncClient._host_urlVs$$T]]DMMBBrIc v# [[URRSS55nSU;a2USnUR 5VVs0sH upgUcM Xg_M nnnXS'[ U5HAn UR R"X40UD6IShvN n [R"U 5 U s $ [R"S5es snnfN  WQ R(( ''3."449&H:&++/7)5 ))S0"::B6(8*U))S0"::28*BtAwiH))S0"554XJba J))S0"991(2d1gYG))S0"99'zDG9=#11$VHAhZ7J4PQ7)T%% 0Ao-";;odSTgY# U=(d 0nURSS5nURSS5US'X2S'URSXS9IShvN nUR5nU(dgUHnU7v M [U5US:agU[U5- nMeNM7f)zGet a paginated list of items.offsetrlimitdGETrON)rSrojsonlen)r*pathrOrrrmrTitems r3_aget_paginated_list AsyncClient._aget_paginated_lists 2Ha( **Wc2w%8 !888TTHMMOE 5zF7O+ c%j FTsA B BABPOSTruns)bodyrequest_methoddata_keyc# U(aUR5O0nURUU[R"U5S9IShvN nUR 5nU(dgUR U5(dgXtHnU7v M UR S5n U (dgU R S5(dgU SUS'MN}7f)z%Get a cursor paginated list of items.contentNcursorsnextcursor)copyror# _dumps_jsonrwrS) r*ryrrrparams_rm response_bodyrunrs r3_aget_cursor_paginated_list'AsyncClient._aget_cursor_paginated_lists"&$))+2!88!--g69H %MMOM  $$X..$. /#'' 2G;;v&& 'GH %sACCA>C) project_name revision_idc# UURS5=(d [R"5UUU=(d [R"5US.UEnUR SS[ R"U5S9IShvN gN7f)z Create a run.id)namerinputsrun_type session_namerr}/runsrN)rSuuiduuid4r get_tracer_projectror#r)r*rrrrrrh run_creates r3 create_runAsyncClient.create_runs}**T"2djjl (IH,G,G,I&   )) GY%:%::%F*   sA;B=B>Bc# 0UES[R"U50EnURSS[R"U53[R"U5S9IShvN gN7f)z Update a run.rPATCH/runs/rN)r#_as_uuidror)r*run_idrhdatas r3 update_runAsyncClient.update_runsg <&;$ 2 26 :;)) Y''/0 1))$/*   sAA&A$A&c# URSS[R"U535IShvN n[R"S0UR 5D6$N(7f)z Read a run.rurNr7)ror#r ls_schemasRunrw)r*rrms r3read_runAsyncClient.read_runsR44 Y''/0 1  ~~0 00  -AA)A) project_idrrtrace_idreference_example_idqueryfilter trace_filter tree_filteris_root parent_run_id start_timeerrorrun_idsselectrsc $# /n[U[R[45(aUR U5 O&[U[ 5(aUR U5 Ub}[U[5(aU/n[R"UVs/sHnURUS9PM sn6IShvN nUR UVs/sHnURPM sn5 U(a!SU;a[R"S[5 U(aUOSUU(aU/OSUUUU U U U (aU R5OSU UUUS.UEnU(a3UVs/sH"n[[R "U55PM$ snUS'UR#5VVs0sHunnUcM UU_M nnnSnUR%SUS 9ShvN n[&R("S 0UD67v US - nUcM,UU:dM4 gs snfGNHs snfs snfs snnfNI g7f) aList runs from the LangSmith API. Parameters ---------- project_id : UUID or None, default=None The ID(s) of the project to filter by. project_name : str or None, default=None The name(s) of the project to filter by. run_type : str or None, default=None The type of the runs to filter by. trace_id : UUID or None, default=None The ID of the trace to filter by. reference_example_id : UUID or None, default=None The ID of the reference example to filter by. query : str or None, default=None The query string to filter by. filter : str or None, default=None The filter string to filter by. trace_filter : str or None, default=None Filter to apply to the ROOT run in the trace tree. This is meant to be used in conjunction with the regular `filter` parameter to let you filter runs by attributes of the root run within a trace. tree_filter : str or None, default=None Filter to apply to OTHER runs in the trace tree, including sibling and child runs. This is meant to be used in conjunction with the regular `filter` parameter to let you filter runs by attributes of any run within a trace. is_root : bool or None, default=None Whether to filter by root runs. parent_run_id : UUID or None, default=None The ID of the parent run to filter by. start_time : datetime or None, default=None The start time to filter by. error : bool or None, default=None Whether to filter by error status. run_ids : List[str or UUID] or None, default=None The IDs of the runs to filter by. limit : int or None, default=None The maximum number of runs to return. **kwargs : Any Additional keyword arguments. Yields: ------ Run The runs. Examples: -------- List all runs in a project: .. code-block:: python project_runs = client.list_runs(project_name="") List LLM and Chat runs in the last 24 hours: .. code-block:: python todays_llm_runs = client.list_runs( project_name="", start_time=datetime.now() - timedelta(days=1), run_type="llm", ) List root traces in a project: .. code-block:: python root_runs = client.list_runs(project_name="", is_root=1) List runs without errors: .. code-block:: python correct_runs = client.list_runs(project_name="", error=False) List runs and only return their inputs/outputs (to speed up the query): .. code-block:: python input_output_runs = client.list_runs( project_name="", select=["inputs", "outputs"] ) List runs by run ID: .. code-block:: python run_ids = [ "a36092d2-4ad5-4fb4-9c0d-0dba9a2ed836", "9398e6be-964f-4aa4-8ae9-ad78cd4b7074", ] selected_runs = client.list_runs(id=run_ids) List all "chain" type runs that took more than 10 seconds and had `total_tokens` greater than 5000: .. code-block:: python chain_runs = client.list_runs( project_name="", filter='and(eq(run_type, "chain"), gt(latency, 10), gt(total_tokens, 5000))', ) List all runs called "extractor" whose root of the trace was assigned feedback "user_score" score of 1: .. code-block:: python good_extractor_runs = client.list_runs( project_name="", filter='eq(name, "extractor")', trace_filter='and(eq(feedback_key, "user_score"), eq(feedback_score, 1))', ) List all runs that started after a specific timestamp and either have "error" not equal to null or a "Correctness" feedback score equal to 0: .. code-block:: python complex_runs = client.list_runs( project_name="", filter='and(gt(start_time, "2023-07-15T12:34:56Z"), or(neq(error, null), and(eq(feedback_key, "Correctness"), eq(feedback_score, 0.0))))', ) List all runs where `tags` include "experimental" or "beta" and `latency` is greater than 2 seconds: .. code-block:: python tagged_runs = client.list_runs( project_name="", filter='and(or(has(tags, "experimental"), has(tags, "beta")), gt(latency, 2))', ) Nr child_run_idszOThe child_run_ids field is deprecated and will be removed in following versions)sessionrreference_examplerrrrr parent_runrrrtracerrrz /runs/query)rrQr7)r&rUUIDrFappendlistextendrdgather read_projectrwarningswarnDeprecationWarning isoformatr#rrTrrr)r*rrrrrrrrrrrrrrrrsrh project_idsrprojectsproject body_queryid_rirjrixrs r3 list_runsAsyncClient.list_runssx j499c"2 3 3   z *  D ) )   z *  #,,, ,~ $^^COP<4$###6<PH   (C(w (C D o/ MMa"  '2{t *>%&D(&'4>*..0D!& "#& & 8C%8CI&&s+, %Jy !",!1!1!3E!3Aq1!3E 99-d9S #..'3' ' !GB R5[OQ D8%F SsBHG4*H1G92HG<A7H)H;H H"H)H>HH H H*H2H<H HH)share_idcz# [R"US5n[U5[U=(d [R"55S.nUR SSUS3[R "U5S9IShvN n[R"U5 UR5SnURS US 3$N?7f) aGGet a share link for a run asynchronously. Args: run_id (ID_TYPE): The ID of the run to share. share_id (Optional[ID_TYPE], optional): Custom share ID. If not provided, a random UUID will be generated. Returns: str: The URL of the shared run. Raises: httpx.HTTPStatusError: If the API request fails. r)r share_tokenPUTr/sharerNr/public//r) r#rrFrrrorr rWrwrL)r*rrrun_id_rrmrs r3 share_runAsyncClient.share_runs $$VX6'lx74::<8 44 WIV $))$/5   ++H5mmom4 ..!+b99 sA7B;9B9:AB;cr# UR[R"US55IShvN nUSL$N7f)z)Get share state for a run asynchronously.rN)read_run_shared_linkr#r)r*rlinks r3 run_is_sharedAsyncClient.run_is_shareds6..y/A/A&(/STT4Us *75 7c# URSS[R"US5S35IShvN n[R"U5 UR 5nUbSU;agUR SUSS3$NI7f) aRetrieve the shared link for a specific run asynchronously. Args: run_id (ID_TYPE): The ID of the run. Returns: Optional[str]: The shared link for the run, or None if the link is not available. Raises: httpx.HTTPStatusError: If the API request fails. rurrrNrrr)ror#rr rWrwrL)r*rrmresults r3r AsyncClient.read_run_shared_links44 Y''9:& A   ++H5 >]&8..!&*?)@CC s/A=A;A A=c# SU0UEnURSS[R"U5S9IShvN n[R"S0UR 5D6$N(7f)zCreate a project.rr} /sessionsrNr7)ror#rr TracerSessionrw)r*rrhrrms r3create_projectAsyncClient.create_projectsc  //44 K)>)>t)D5  '':(--/:: /AA)Ac# U(a2URSS[R"U535IShvN nO.U(aURSSSU0S9IShvN nO [S5eUR 5n[ U[ 5(a:U(d[R"SUS 35e[R"S 0US D6$[R"S 0UD6$NN7f) zRead a project.ru /sessions/Nrrrv2Either project_name or project_id must be providedzProject not foundrr7) ror#r ValueErrorrwr&rr r_rr)r*rrrmrs r3rAsyncClient.read_project s !88I$6$6z$B#CDH!88{FL+A9HQR R}} dD ! !55|nJ7++6d1g6 6''/$//#"4C#C"C#C!BC#!C#)rrc# UcUc [S5eUc,URUS9IShvN n[UR5nU(d [S5eUR SS[ R "U535IShvN gN]N7f)zDelete a project from LangSmith. Parameters ---------- project_name : str or None, default=None The name of the project to delete. project_id : str or None, default=None The ID of the project to delete. NrrzProject not foundDELETEr)rrrFrror#r)r*rrrs r3delete_projectAsyncClient.delete_project%s  ,"6QR R   --<-HHGWZZJ01 1)) ++J78 9   I s"'B BAB B B  B c# SU0UEnURSS[R"U5S9IShvN n[R"S0UR 5D6$N(7f)zCreate a dataset.rr} /datasetsrNr7)ror#rrDatasetrw)r* dataset_namerhrrms r3create_datasetAsyncClient.create_dataset=sc  //44 K)>)>t)D5  !!4HMMO44 rc# U(a2URSS[R"U535IShvN nO.U(aURSSSU0S9IShvN nO [S5eUR 5n[ U[ 5(a:U(d[R"SUS 35e[R"S 0US D6$[R"S 0UD6$NN7f) zRead a dataset.ru /datasets/Nrrrvz2Either dataset_name or dataset_id must be providedzDataset rrr7) ror#rrrwr&rr r_rr)r*r dataset_idrmrs r3 read_datasetAsyncClient.read_datasetIs !88I$6$6z$B#CDH!88{FL+A9HQR R}} dD ! !55|nJ7%%0Q0 0!!)D))#rcr# URSS[R"U535IShvN gN7f)zDelete a dataset.rrN)ror#r)r*rs r3delete_datasetAsyncClient.delete_datasetcs6)) ++J78 9   s -757c z# URSUS9ShvN n[R"S0UD67v M$N g7f)zList datasets.rrvNr7)r{rr)r*rhdatasets r3 list_datasetsAsyncClient.list_datasetsjs= "66{66R 0'$$/w/ / 0Rs;979;9;cD# UcUc [S5eUc#URUS9IShvN nURnUU[U5S.UEnUR SS[ R "U5S9IShvN n[R"S0UR5D6$NrN*7f) zCreate an example.Nz2Either dataset_id or dataset_name must be providedr)routputsrr} /examplesrr7) rrrrFror#rrExamplerw) r*rr rrrhrrrms r3create_exampleAsyncClient.create_examplers  ,"6QR R   --<-HHG Jj/    44 K)>)>t)D5  !!4HMMO44I s"'B BA B 3B4)B B c# URSS[R"U535IShvN n[R"S0UR 5D6$N(7f)zRead an example.ruz /examples/Nr7)ror#rrr rw)r* example_idrms r3 read_exampleAsyncClient.read_examplesS44 Z 2 2: >?@  !!4HMMO44 r)rrc :# UR5nU(a[R"U5US'O-U(a&URUS9IShvN nURUS'UR SUS9ShvN n[ R"S0UD67v M$NGN! g7f)zList examples.rrNr rvr7)rr#rrrr{rr )r*rrrhrOrexamples r3 list_examplesAsyncClient.list_exampless  ) 2 2: >F9   --<-HHG ' F9 !66{66R 0'$$/w/ / I 0Rs6A B B#B1B5B6B9BBBc# [R"USS9UUUUS.UEnURSS[R"U5S9IShvN n[R "S0UR 5D6$N(7f) aCreate feedback for a run. Args: run_id (Optional[ls_client.ID_TYPE]): The ID of the run to provide feedback for. Can be None for project-level feedback. key (str): The name of the metric or aspect this feedback is about. score (Optional[float]): The score to rate this run on the metric or aspect. value (Optional[Any]): The display value or non-numeric value for this feedback. comment (Optional[str]): A comment about this feedback. **kwargs: Additional keyword arguments to include in the feedback data. Returns: ls_schemas.Feedback: The created feedback object. Raises: httpx.HTTPStatusError: If the API request fails. T) accept_null)rkeyscorevaluecommentr} /feedbackrNr7)r# _ensure_uuidrorrFeedbackrw) r*rrrrrrhrrms r3create_feedbackAsyncClient.create_feedbacks6 ,,VF    44 K)>)>t)D5  ""5X]]_55 sAA3A1 )A3)r correctionrmetadatac L# [R"XRSS9upxXpR:wa[SU35eUR SS[R "U53[R "UUUUUS.5S9IShvN n [R"U 5 gN7f) aCreate feedback from a presigned token or URL. Args: token_or_url (Union[str, uuid.UUID]): The token or URL from which to create feedback. score (Union[float, int, bool, None], optional): The score of the feedback. Defaults to None. value (Union[float, int, bool, str, dict, None], optional): The value of the feedback. Defaults to None. correction (Union[dict, None], optional): The correction of the feedback. Defaults to None. comment (Union[str, None], optional): The comment of the feedback. Defaults to None. metadata (Optional[dict], optional): Additional metadata for the feedback. Defaults to None. Raises: ValueError: If the source API URL is invalid. Returns: None: This method does not return anything. rQ) num_partszInvalid source API URL. r}z/feedback/tokens/)rrr!rr"rN) r#_parse_token_or_urlrGrrorrr rW) r* token_or_urlrrr!rr"source_api_url token_uuidrms r3create_feedback_from_token&AsyncClient.create_feedback_from_tokens@&/%B%B --1& " ]] *77GHI I44  2 2: >? @))""",& (  5    ++H5  sBB$B"B$) expirationfeedback_config feedback_idc# UUUU=(d [[R"55S.nUc[R"SSSS9US'O[ U[ R 5(aUR5US'Ox[ U[ R5(aA[R"URURS-URS-S -S9US'O[S [U5S 35eURS S [R"U5S9IShvN n[R "S0UR#5D6$N(7f)aCreate a pre-signed URL to send feedback data to. This is useful for giving browser-based clients a way to upload feedback data directly to LangSmith without accessing the API key. Args: run_id: feedback_key: expiration: The expiration time of the pre-signed URL. Either a datetime or a timedelta offset from now. Default to 3 hours. feedback_config: FeedbackConfig or None. If creating a feedback_key for the first time, this defines how the metric should be interpreted, such as a continuous score (w/ optional bounds), or distribution over categorical values. feedback_id: The ID of the feedback to create. If not provided, a new feedback will be created. Returns: The pre-signed URL for uploading feedback data. )r feedback_keyr,rNrr)dayshoursminutes expires_in expires_ati<zInvalid expiration type: z3. Expected datetime.datetime or datetime.timedelta.r}z/feedback/tokensrr7)rFrrrTimeDeltaInputr&datetimer timedeltar0secondsrtyperor#rFeedbackIngestTokenrw)r*rr/r+r,r-rrms r3create_presigned_feedback_token+AsyncClient.create_presigned_feedback_tokensBB(.2TZZ\!2    !+!:!:"D   H$5$5 6 6!+!5!5!7D   H$6$6 7 7!+!:!:__ ((D0#++d2r9"D  +D,<+=>DD  44  ))$/5   --@ @@  sDE E )E c# URSS[R"U535IShvN n[R"S0UR 5D6$N(7f)zRead feedback.ru /feedback/Nr7)ror#rrrrwr*r-rms r3 read_feedbackAsyncClient.read_feedbackBsU44 Z 2 2; ?@A  ""5X]]_55 r)rr/feedback_source_typersc `# U(a0UVs/sH"n[[R"U55PM$ snOSUb [US5OSS.UEnUbX'S'UbX7S'SnUR SUS9ShvN n [ R "S 0U D67v US - nUcM,X:dM3 gs snfN5 g7f) zList feedback.Nrt)rrsrsourcerrrvrQr7)rFr#rminr{rr) r*rr/rCrsrhrrOrfeedbacks r3 list_feedbackAsyncClient.list_feedbackKsFMA#Y'',-ARV(-(9S_s      #(5M  +38  "77 F7S (%%11 1 !GB R[B Ss? B.)B%9B.0B,4B*5B,8 B.B.#B.*B,,B.c# URSS[R"US535IShvN n[R"U5 gN7f)zDelete a feedback by ID. Args: feedback_id (Union[UUID, str]): The ID of the feedback to delete. Returns: None rr?r-Nror#rr rWr@s r3delete_feedbackAsyncClient.delete_feedbackgsK44  9#5#5k=#Q"RS   ++H5 s.AA A) queue_idsr name_containsrsc P# Ub9[U5VVs/sH upV[R"USUS35PM" snnOSUUUb [US5OSS.nSnUR SUS9ShvN n [ R "S 0U D67v US - nUcM,X:dM3 gs snnfN6 g7f) aList the annotation queues on the LangSmith API. Args: queue_ids (Optional[List[Union[UUID, str]]]): The IDs of the queues to filter by. name (Optional[str]): The name of the queue to filter by. name_contains (Optional[str]): The substring that the queue name should contain. limit (Optional[int]): The maximum number of queues to return. Yields: The annotation queues. Nz queue_ids[]rt)idsrrOrsr/annotation-queuesrvrQr7) enumerater#rrFr{rAnnotationQueue) r*rNrrOrsirrOrrGs r3list_annotation_queues"AsyncClient.list_annotation_queuesxs:(#,I"6"6&&sj1,=>"6 *(-(9S_s  "77 8  (,,8x8 8 !GB R[%  s?B&'B,B&'B$+B",B$/ B&B&B&"B$$B&) descriptionqueue_idc p# UUUb [U5O[[R"55S.nURSSUR 5VVs0sH upVUcM XV_M snnS9IShvN n[ R "U5 [R"S0UR5D6$s snnfND7f)a[Create an annotation queue on the LangSmith API. Args: name (str): The name of the annotation queue. description (Optional[str]): The description of the annotation queue. queue_id (Optional[Union[UUID, str]]): The ID of the annotation queue. Returns: AnnotationQueue: The created annotation queue object. N)rrYrr}rSrwr7) rFrrrorTr rWrrUrw)r*rrYrZrrirjrms r3create_annotation_queue#AsyncClient.create_annotation_queues*&#+#7#h-S=N  44  #'::<A<411$!$<A5   ++H5)) mmo  B s%AB6 B. B.& B6/B40AB6cZ# URU/S9R5IShvN $N7f)zRead an annotation queue with the specified queue ID. Args: queue_id (Union[UUID, str]): The ID of the annotation queue to read. Returns: AnnotationQueue: The annotation queue object. )rNN)rW __anext__)r*rZs r3read_annotation_queue!AsyncClient.read_annotation_queues,00H:0FPPRRRRs "+)+)rYc# URSS[R"US53UUS.S9IShvN n[R"U5 gN7f)a=Update an annotation queue with the specified queue_id. Args: queue_id (Union[UUID, str]): The ID of the annotation queue to update. name (str): The new name for the annotation queue. description (Optional[str]): The new description for the annotation queue. Defaults to None. Returns: None r/annotation-queues/rZ)rrYr\NrK)r*rZrrYrms r3update_annotation_queue#AsyncClient.update_annotation_queues\44 !)"4"4Xz"J!K L*5   ++H5 s0AAAc# URSS[R"US53SS0URRES9IShvN n[ R "U5 gN7f)zDelete an annotation queue with the specified queue ID. Args: queue_id (Union[UUID, str]): The ID of the annotation queue to delete. Returns: None rrdrZAcceptr)rN)ror#rrrr rW)r*rZrms r3delete_annotation_queue#AsyncClient.delete_annotation_queuesi44 !)"4"4Xz"J!K L1JT\\5I5IJ5   ++H5  sAA%A#A%c,# URSS[R"US5S3[U5VVs/sH)up4[ [R"USUS355PM+ snnS9IShvN n[ R "U5 gs snnfN!7f) zAdd runs to an annotation queue with the specified queue ID. Args: queue_id (Union[UUID, str]): The ID of the annotation queue. run_ids (List[Union[UUID, str]]): The IDs of the runs to be added to the annotation queue. Returns: None r}rdrZrzrun_ids[rQr\N)ror#rrTrFr rW)r*rZrrVrrms r3add_runs_to_annotation_queue(AsyncClient.add_runs_to_annotation_queues44 !)"4"4Xz"J!K5 Q(00FAI&&shqcO<=05   ++H5  s5B0B ' B0B1"Bc # URSS[R"US5S[R"US535IShvN n[R"U5 gN7f)aDelete a run from an annotation queue with the specified queue ID and run ID. Args: queue_id (Union[UUID, str]): The ID of the annotation queue. run_id (Union[UUID, str]): The ID of the run to be added to the annotation queue. Returns: None rrdrZrrNrK)r*rZrrms r3 delete_run_from_annotation_queue,AsyncClient.delete_run_from_annotation_queuesc44 !)"4"4Xz"J!K6R[RdRdekmuRvQw x   ++H5  AA&A$ A&c# S[R"US5S3nURSUSU35IShvN n[R"U5 [ R "S0UR5D6$N>7f)aGet a run from an annotation queue at the specified index. Args: queue_id (Union[UUID, str]): The ID of the annotation queue. index (int): The index of the run to retrieve. Returns: RunWithAnnotationQueueInfo: The run at the specified index. Raises: LangSmithNotFoundError: If the run is not found at the given index. LangSmithError: For other API-related errors. rdrZz/runru/Nr7)r#rror rWrRunWithAnnotationQueueInforw)r*rZindexrrms r3get_run_from_annotation_queue)AsyncClient.get_run_from_annotation_queue(sr )););Hj)Q(RRVW44Uxj%> !!88 LLH  / / 9'99LHMMOLDN~~ Ms#A7A5AA7ct# UR5IShvN nUS:H=(d URU:H$N7f)zCheck if the current workspace has the same handle as owner. Args: owner (str): The owner to check against. Returns: bool: True if the current tenant is the owner, False otherwise. N-)r tenant_handle)r*ownersettingss r3_current_tenant_is_owner$AsyncClient._current_tenant_is_owners7++--|>x55>>.s 86 8c# UR5IShvN n[R"SUSURSU35$N-7f)NzCannot z% for another tenant. Current tenant: z, Requested tenant: )rr LangSmithUserErrorr)r*actionrrs r3_owner_conflict_error!AsyncClient._owner_conflict_errorsW++--**fX'5567!!& )  .sAA.Arc# URSSUS3X#S.S9IShvN nUR5SnU(aUSS $S$N(7f) agGet the latest commit hash for a prompt. Args: prompt_owner_and_name (str): The owner and name of the prompt. limit (int, default=1): The maximum number of commits to fetch. Defaults to 1. offset (int, default=0): The number of commits to skip. Defaults to 0. Returns: Optional[str]: The latest commit hash, or None if no commits are found. ru /commits/rs)rsrrrvNcommitsr commit_hash)rorw)r*prompt_owner_and_namersrrrmrs r3_get_latest_commit_hash#AsyncClient._get_latest_commit_hashse44 -.a 0"55   --/),,3wqz-(==  sAA)Ac# [R"U5up4nURSSUSU3SU0S9IShvN nUR5 UR 5$N$7f)aRLike or unlike a prompt. Args: prompt_identifier (str): The identifier of the prompt. like (bool): True to like the prompt, False to unlike it. Returns: A dictionary with the key 'likes' and the count of likes as the value. Raises: requests.exceptions.HTTPError: If the prompt is not found or another error occurs. r}z/likes/rsliker\N)r parse_prompt_identifierroraise_for_statusrw)r*prompt_identifierrr prompt_name_rms r3_like_or_unlike_prompt"AsyncClient._like_or_unlike_promptsn !) @ @AR SA44 geWAk]364.5   !!#}}  s6AA%Ac # [R"U5up#nURU5(dURSUSUSUSS3$UR 5IShvN nURSUSUSSSUR 3$N(7f)zGet a URL for a prompt. Args: prompt_identifier (str): The identifier of the prompt. Returns: str: The URL for the prompt. z/hub/rs:Nz /prompts/z?organizationId=)r rrrLrr)r*rrrrrs r3_get_prompt_urlAsyncClient._get_prompt_urls+3*J*J + 'K,,U33nn%U5';-qRa@QR R++--~~i }Ak"1o5Fx{{m - .sAB B )B cV# URU5IShvN nU(aS$S$N7f)zCheck if a prompt exists. Args: prompt_identifier (str): The identifier of the prompt. Returns: bool: True if the prompt exists, False otherwise. NTF) get_prompt)r*rprompts r3_prompt_existsAsyncClient._prompt_exists6s+'899t(5(:s )')c># URUSS9IShvN $N7f)zLike a prompt. Args: prompt_identifier (str): The identifier of the prompt. Returns: Dict[str, int]: A dictionary with the key 'likes' and the count of likes as the value. TrNrr*rs r3 like_promptAsyncClient.like_promptBs$001B0NNNN c># URUSS9IShvN $N7f)zUnlike a prompt. Args: prompt_identifier (str): The identifier of the prompt. Returns: Dict[str, int]: A dictionary with the key 'likes' and the count of likes as the value. FrNrrs r3 unlike_promptAsyncClient.unlike_promptNs$001B0OOOOrrtFdesc)rsrr is_public is_archived sort_fieldsort_directionrc F# UUU(aSOUbSOSU(aSOS[U[R5(a UROUUUU(aSOSS.nUR SS[ U5S9IShvN n [R "S0U R5D6$N(7f) aList prompts with pagination. Args: limit (int, default=100): The maximum number of prompts to return. Defaults to 100. offset (int, default=0): The number of prompts to skip. Defaults to 0. is_public (Optional[bool]): Filter prompts by if they are public. is_archived (Optional[bool]): Filter prompts by if they are archived. sort_field (PromptSortField): The field to sort by. Defaults to "updated_at". sort_direction (Literal["desc", "asc"], default="desc"): The order to sort by. Defaults to "desc". query (Optional[str]): Filter prompts by a search query. Returns: ListPromptsResponse: A response object containing the list of prompts. trueNfalse)rsrrrrrrr match_prefixru/repos/rvr7)r&rPromptSortFieldrro _exclude_noneListPromptsResponserw) r*rsrrrrrrrrOrms r3 list_promptsAsyncClient.list_promptsZs:#I4It%06gj**D*DEE  ,&+F "44 9]6%:5  --@ @@ sA4B!6B7)B!c# [R"U5up#nURSSUSU35IShvN n[R"S0UR 5SD6$N+![R a gf=f7f)a[Get a specific prompt by its identifier. Args: prompt_identifier (str): The identifier of the prompt. The identifier should be in the format "prompt_name" or "owner/prompt_name". Returns: Optional[Prompt]: The prompt object. Raises: requests.exceptions.HTTPError: If the prompt is not found or another error occurs. rurrsNrepor7)r rrorPromptrwr_r*rrrrrms r3rAsyncClient.get_prompts!) @ @AR SA !88q 6H$$?x}}v'>? ?..  s8BA&A$*A&#B$A&&A=:B<A==BrYreadmetagsrc*# UR5IShvN nU(a'UR(d[R"S5e[R"U5upxn UR US9IShvN (dUR SU5IShvN eUU=(d SU=(d SU=(d /US.n URSSU S 9IShvN n U R5 [R"S 0U R5S D6$NNN{NA7f) aCreate a new prompt. Does not attach prompt object, just creates an empty prompt. Args: prompt_identifier (str): The identifier of the prompt. The identifier should be in the formatof owner/name:hash, name:hash, owner/name, or name description (Optional[str]): A description of the prompt. readme (Optional[str]): A readme for the prompt. tags (Optional[Sequence[str]]): A list of tags for the prompt. is_public (bool): Whether the prompt should be public. Defaults to False. Returns: Prompt: The created prompt object. Raises: ValueError: If the current tenant is not the owner. HTTPError: If the server request fails. NCannot create a public prompt without first creating a LangChain Hub handle. You can add a handle by creating a public prompt at: https://smith.langchain.com/prompts)rzcreate a prompt) repo_handlerYrrrr}rr\rr7) rrr rrrrrorrrrw) r*rrYrrrrrrrrwrms r3 create_promptAsyncClient.create_prompts8++-- X33--6 !) @ @AR SA33%3@@@334EuMM N'&,"lJB" < 44VYT4RR!!#  ;8==?6#:;;/.AMSsFDD AD4D 5DD;DD ))-B,C1[M*RSSSA= M  "  TsVD)DD)D A1D)/D#0D)D%3D)D'D) D  D)%D)'D))rYrrrrc# UR5IShvN nU(aUR(d [S5e0nUbX(S'UbX8S'UbXXS'UbXhS'UbXHS'[R"U5upn UR SS U S U 3US 9IShvN n U R 5 U R5$NN&7f) aUpdate a prompt's metadata. To update the content of a prompt, use push_prompt or create_commit instead. Args: prompt_identifier (str): The identifier of the prompt to update. description (Optional[str]): New description for the prompt. readme (Optional[str]): New readme for the prompt. tags (Optional[Sequence[str]]): New list of tags for the prompt. is_public (Optional[bool]): New public status for the prompt. is_archived (Optional[bool]): New archived status for the prompt. Returns: Dict[str, Any]: The updated prompt data as returned by the server. Raises: ValueError: If the prompt_identifier is empty. HTTPError: If the server request fails. NrrYrrrrrrrsr\)rrrr rrorrw) r*rrYrrrrrrwrrrrms r3 update_promptAsyncClient.update_prompts:++-- X336 <>  ""-   #N  )   ""-   L ( @ @AR SA44 wugQ{m445   !!#}}7.. s"B?B;A?B?B=%B?=B?c# [R"U5up#nURU5IShvN (dURSU5IShvN eUR SSUSU35IShvN nUR 5 gNTN7N7f)zDelete a prompt. Args: prompt_identifier (str): The identifier of the prompt to delete. Returns: bool: True if the prompt was successfully deleted, False otherwise. Raises: ValueError: If the current tenant is not the owner of the prompt. Nzdelete a promptrrrs)r rrrrorrs r3 delete_promptAsyncClient.delete_promptJs!) @ @AR SA33E:::334EuMM N44 wa }5   !!# ;M s3.B BB BB /B 0B B  B  include_modelc # [R"U5up4nURSSUSUSUU(aSOS35IShvN n[R"S0X4S.UR 5ED6$N,7f) zPull a prompt object from the LangSmith API. Args: prompt_identifier (str): The identifier of the prompt. Returns: PromptCommit: The prompt object. Raises: ValueError: If no commits are found for the prompt. rurrsz?include_model=truerNrrr7)r rror PromptCommitrw)r*rrrrrrms r3pull_prompt_commitAsyncClient.pull_prompt_commit_s"+3*J*J + 'K44 E7!K=+,9(rBD  && FhmmoF   sAA4A2-A4rsrrrc# [R"U5upVnUb [SU5OUUUS.nSn X8S'URSSUSUS3US 9IShvN n U R 5n U S n U S n U (dgU H/nUbX:a g[ R "S0XVS .UED67v U S - n M1 U[U 5- nX=:agMNq7f)aList commits for a given prompt. Args: prompt_identifier (str): The identifier of the prompt in the format 'owner/repo_name'. limit (Optional[int]): The maximum number of commits to return. If None, returns all commits. Defaults to None. offset (int, default=0): The number of commits to skip before starting to return results. Defaults to 0. include_model (bool, default=False): Whether to include the model information in the commit data. Defaults to False. Yields: A ListedPromptCommit object for each commit. Note: This method uses pagination to retrieve commits. It will make multiple API calls if necessary to retrieve all commits or up to the specified limit. NrtrrrrrurrsrvrtotalrrQr7)r rrFrorwrListedPromptCommitrx)r*rrsrrrrrrrOrVrmvalrTrits r3list_prompt_commitsAsyncClient.list_prompt_commits~s .!) @ @AR SA).(9Se_u*  %8 !88E7!K=29H --/C NELE$ 33 %AbAQ  c%j F/sACCA2Cc # SSKJn SSKJn SSKJn SSKJn SSKJ n SSK J nJ n SS KJn UR%XS 9IS hvN n U "5 U"[&R("U R*55n S S S 5 [-W U5(d+[-X5(a[-U R.U5(a[-X5(aU O8[-X5(a'[-U R.U5(a U R.OS n U c[0R2"S 5eU R4c0U lU R4R7U R8U R:U R<S.5 U(Gay[-X5(Gah[-U R.U5(GaL[?U R@5S:XGa2[-U RBU5(Gd[-U RBU5(a[-U RBRDU5(a[GXR.U RBRD-5n[?UR@5S:XaUUR@SnU "U R.URH"S00U RBRJED6URB5n U $Un U $[-U RBU5(aU R.U RB-n U $U $![a [S5ef=f![a [ R"S 5n GNf=fGN!,(df  GN=f7f)aPull a prompt and return it as a LangChain PromptTemplate. This method requires `langchain-core `__. Args: prompt_identifier (str): The identifier of the prompt. include_model (Optional[bool], default=False): Whether to include the model information in the prompt data. Returns: Any: The prompt object in the specified format. r)BaseLanguageModel)r)BaseOutputParser)BasePromptTemplate)StructuredPrompt)RunnableBindingRunnableSequenceztThe client.pull_prompt function requires the langchain-corepackage to run. Install with `pip install langchain-core`)suppress_langchain_beta_warningc3# Sv g7frEr7r7rIr3r@AsyncClient.pull_prompt..suppress_langchain_beta_warningssrNz-Prompt object is not a valid prompt template.) lc_hub_owner lc_hub_repolc_hub_commit_hashrRrrQr7)&#langchain_core.language_models.baserlangchain_core.load.loadrlangchain_core.output_parsersrlangchain_core.promptsr!langchain_core.prompts.structuredrlangchain_core.runnables.baserrrlangchain_core._apir contextlibcontextmanagerrrwrrr&firstr rar"updaterrrrxstepslastboundr bindrh)r*rrrrrrrrrr prompt_objectrprompt_templateseq rebound_llms r3 pull_promptAsyncClient.pull_prompts  M 6 F A J W   K#55 6  - .4::m&<&<=>F/ v1 2 2&336<<);<<f99"&;;"6<<1CDDLL &--C''/+-(  $ $ + +$1$7$7#0#5#5*7*C*C  6446<<)9::FLL!Q&z&++GW/X/X&++77J !!#4==+\\FKKQ&"%))A,K- #((B+Afkk.@.@+ABF !F FKK):;;+1<<&+++E  _ M     & & '    / .s]M&K2L ML2 M'L56I*AsyncClient.push_prompt..Cs/UeT!/UsrF)rrYrr)rr)ranyrrrr) r*rrrrrYrrurls r3 push_promptAsyncClient.push_promptsL$$%67 7 709/U((% +!' )$$!'0'<)%' %   >--@Q-RR R&&  1'    ; 8 S sWB5B+8B5B- B51B/2B5 B1 B5$B3%B5-B5/B51B53B5)rrrr)NNNNN) r+ Optional[str]r,r-r-zWOptional[Union[int, tuple[Optional[int], Optional[int], Optional[int], Optional[int]]]]r.zOptional[Mapping[str, Any]]r/r-)returnr)r.rF)rfrFrgrFrhrr.zhttpx.ResponserE)ryrFrOOptional[dict[str, Any]]r.zAsyncIterator[dict[str, Any]]) ryrFrOptional[dict]rrFrrFr.zAsyncIterator[dict])rrFrdict[str, Any]rrFrr-rOptional[ls_client.ID_TYPE]rhrr.None)rls_client.ID_TYPErhrr.r3)rr4r.zls_schemas.Run)$rz?Optional[Union[ls_client.ID_TYPE, Sequence[ls_client.ID_TYPE]]]rz#Optional[Union[str, Sequence[str]]]rr-rr2rr2rr-rr-rr-rr-rOptional[bool]rr2rzOptional[datetime.datetime]rr5r%Optional[Sequence[ls_client.ID_TYPE]]rOptional[Sequence[str]]rs Optional[int]rhrr.zAsyncIterator[ls_schemas.Run])rr4rr2r.rF)rr4r.bool)rr4r.r-)rrFrhrr.ls_schemas.TracerSession)NN)rr-rr2r.r:)rr-rr-r.r3)rrFrhrr.ls_schemas.Dataset)rr-rr2r.r;)rr4r.r3)rhrr.z!AsyncIterator[ls_schemas.Dataset])NNN) rr1r r/rr2rr-rhrr.ls_schemas.Example)rr4r.r<)rr2rr-rhrr.z!AsyncIterator[ls_schemas.Example])rr2rrFrzOptional[float]r Optional[Any]rr-rhrr.ls_schemas.Feedback)r&zUnion[str, uuid.UUID]rzUnion[float, int, bool, None]rz(Union[float, int, bool, str, dict, None]r!zUnion[dict, None]rzUnion[str, None]r"r0r.r3) rr4r/rFr+z0Optional[datetime.datetime | datetime.timedelta]r,z#Optional[ls_schemas.FeedbackConfig]r-r2r.zls_schemas.FeedbackIngestToken)r-r4r.r>) rr6r/r7rCz1Optional[Sequence[ls_schemas.FeedbackSourceType]]rsr8rhrr.z"AsyncIterator[ls_schemas.Feedback])r-ID_TYPEr.r3) rNzOptional[list[ID_TYPE]]rr-rOr-rsr8r.z)AsyncIterator[ls_schemas.AnnotationQueue])rrFrYr-rZzOptional[ID_TYPE]r.ls_schemas.AnnotationQueue)rZr?r.r@)rZr?rrFrYr-r.r3)rZr?r.r3)rZr?rz list[ID_TYPE]r.r3)rZr?rr?r.r3)rZr?rur'r.z%ls_schemas.RunWithAnnotationQueueInfo)rr4ryrFrhrr.r3)rr4rhrr.r3) rdictrsr'rr4rr-rhrr.zlist[ls_schemas.ExampleSearch])r.zls_schemas.LangSmithSettings)rrFr.r9)rrFrrFr.zls_utils.LangSmithUserError)rQr)rrFrsr'rrr'r.r-)rrFrr9r.dict[str, int])rrFr.rF)rrFr.r9)rrFr.rB)rsr'rrr'rr5rr5rzls_schemas.PromptSortFieldrzLiteral['desc', 'asc']rr-r.zls_schemas.ListPromptsResponse)rrFr.zOptional[ls_schemas.Prompt]) rrFrYr-rr-rr7rr9r.zls_schemas.Prompt)rrFrrrr-r.rF)rrFrYr-rr-rr7rr5rr5r.r1)rrFr.r3)rrFrr5r.zls_schemas.PromptCommit) rrFrsr8rrr'rr9r.z3AsyncGenerator[ls_schemas.ListedPromptCommit, None])rrFrr5r.r)rrFrr=rrFrr5rYr-rr-rr7r.rF)K__name__ __module__ __qualname____firstlineno____doc__ __slots__r4r9r@r<propertyrGrLror{rrrrrrrrrrrrrrrr rrrr)r<rArHrLrWr]rarerirlrorvls_beta warn_betar}rrrrrrrrrrrrr updated_atrrrrrrrrr!r+__static_attributes__r7rIr3rrs >EI"&!% 48!%!F!F!F !F2!F!FF$**CC: : :  :  : ~,0!!)! ' !2 $$ 00 0  0  0 0H'+37     $  1    0  !       1 <@"&04<@# $&*%)"&5926 $9=*.#)L L : L L.L:LLL$L#L L3L 0!L"#L$7%L&('L()L*+L, '-L^UY:':6Q: :< D. ; ; ; " ;'+260#000 " 0604QU , AN  0 5 5 5  5'+26*#*0*  *4 00 +0-126&* 55*50 5 $ 5  5 54537&* 000$ 0  0 + 0,"&#!% %6+%6%6 %6  %6  %6%6 %6T0436 ;?(,$(#'36+36-36 8 36 & 36"36!36 36tHL?C37?A!?A?A E ?A = ?A1?A (?AB6,6 6:>04RV# 7.  P    ,8 6(.2"'+# +++ + % +  + 3+b&*&* ! ! # ! $ ! $ ! F S S # SMQ66*-6%(>14>BE> >*!$,0 . . ) O P$(&+1;1K1K1V1V17#0A0A 0A " 0A $ 0A/0A/0A0A (0Ad6&* $(,3<3<# 3<  3< & 3<3< 3rUsb!" LL )+':  3 AAH:9rI