f3fidZddlmZddlZddlZddlZddlZddlZddlm Z m Z m Z m Z ddl mZmZmZmZmZddlZddlmZddlmZddlmZdd lmZdd lmZeej@e!fZ"Gd d Z#dd Z$y)zThe Async LangSmith Client.) annotationsN)AsyncGenerator AsyncIteratorMappingSequence)AnyLiteralOptionalUnioncast)client)schemas)utils)_beta_decorator) AsyncCacheceZdZdZdZ db dcdZdddZdZdZe d Z e ded Z dfd Z dg dhd Z dd dd didZddd djdZ dkdZdldZddddddddddddddddd dmdZdd dndZdodZdpdZ dqdZ dr dsdZddd dtdZ dudZ dr dvd Zdwd!Z dxd"Z dy dzd#Zd{d$Zddd% d|d&Z dy d}d'Z dgddddd( d~d)Z!dddd* dd+Z" dd,Z#ddddd- dd.Z$dd/Z%ddddd0 dd1Z&ddd2 dd3Z' dd4Z(dd5 dd6Z)dd7Z* dd8Z+ dd9Z, dd:Z-e.j^d;d< dd=Z0e.j^ dd>Z1e.j^dd? dd@Z2ddAZ3ddBZ4 ddCZ5 d ddEZ6 ddFZ7 ddGZ8ddHZ9ddIZ:ddJZ;ddKZdD,QH  E *:Va!-a$hTAVWHH((h    AE D=0: DK z *DKDKWsDcnK|j"|jjd{|S7w)zEnter the async client.N)rstartr+s r5 __aenter__zAsyncClient.__aenter__^s0 ;; "++##% % %  &s *535c@K|jd{y7w)zExit the async client.N)aclose)r+exc_typeexc_valexc_tbs r5 __aexit__zAsyncClient.__aexit__dskkms cK|j"|jjd{|jjd{y7'7w)zClose the async client.N)rstoprr<r9s r5r<zAsyncClient.aclosehsE ;; "++""$ $ $ll!!### %#s!*AA!AAAAc@t|jjSN)strrrr9s r5_api_urlzAsyncClient._api_urlns4<<(())cVtj|j|jS)zThe web host url.)r! get_host_urlrrFr9s r5 _host_urlzAsyncClient._host_urlrs$$T]]DMMBBrGc FKtt|jjdd}d|vr0|d}|j Dcic] \}}| || }}}||d<t |D]A} |j j||fi|d{} tj| | cStjdcc}}w79#tj$rW}  jdk(r'tjd|d|dt| | jd k(rtjd ||| jd k(r$tj d |d t| | jdk(r$tj"d|d t| | jdk(r$tj$d|d t| | jdk(r$tj&d|d t| tj(d|d|dt| d} ~ wtj*$rU} | |dz k(r!tj,dt| t/j0d| zd{7Yd} ~ -d} ~ wwxYww)z(Make an async HTTP request with retries.rrparamsNizServer error caused failure to  z in LangSmith API. iz(Client took too long to send request to izRate limit exceeded for z. izAuthentication failed for izResource not found for iz Conflict for z Failed to zRequest error: z0Unexpected error connecting to the LangSmith API)r r(rgetitemsrangerrequestr!raise_for_status_with_textr*HTTPStatusError status_codeLangSmithAPIErrorreprLangSmithRequestTimeoutLangSmithRateLimitErrorLangSmithAuthErrorLangSmithNotFoundErrorLangSmithConflictErrorLangSmithError RequestErrorLangSmithConnectionErrorasynciosleep) r+methodendpointkwargsrrLkvfiltered_paramsattemptresponsees r5_arequest_with_retriesz"AsyncClient._arequest_with_retriesws3 2 2 6 6}a HI  v H%F06 P1!-q!tPOP.F8 [)' 0G& 0!5!5!5fh!Q&!QQ33H= ' 0P(( >  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%% 0kAo-";;odSTgY") # List LLM and Chat runs in the last 24 hours todays_llm_runs = client.list_runs( project_name="", start_time=datetime.now() - timedelta(days=1), run_type="llm", ) # List root traces in a project root_runs = client.list_runs(project_name="", is_root=1) # List runs without errors correct_runs = client.list_runs(project_name="", error=False) # List runs and only return their inputs/outputs (to speed up the query) input_output_runs = client.list_runs( project_name="", select=["inputs", "outputs"] ) # List runs by run ID 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 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 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 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 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_runrrrtracerrorrz /runs/query)rzrNr)r'rUUIDrEappendlistextendragather read_projectrwarningswarnDeprecationWarning isoformatr$rrQrrr)r+rrrrrrrrrrrrrrrrore project_idsrprojectsproject body_queryid_rfrgrzixrs r5 list_runszAsyncClient.list_runssb j499c"2 3   z *  D )   z *  #,, ,~ $^^COP4$###6PH   (Cw C D o/ MMa"  '2{t *>%&D(&'4>*..0D#& $%& ( 8C%14I&&s+,%Jy !",!1!1!3EAq}1EE 99-d9S  #..'3' ' !GB R5[QQ D:%F SsA>GF:G F?!G4GAG#%GG! G ,G 1G G GG G2G8GGGG)share_idcnKtj|d}t|t|xstjd}|j dd|dtj |d{}tj||jd}|jd |d S7>w) amGet a share link for a run asynchronously. Args: run_id (ID_TYPE): The ID of the run to share. share_id: Custom share ID. If not provided, a random UUID will be generated. Returns: The URL of the shared run. Raises: httpx.HTTPStatusError: If the API request fails. r)r share_tokenPUTr/sharer~Nr/public//r) r$rrErrrlrr!rTrsrJ)r+rrrun_id_rrjrs r5 share_runzAsyncClient.share_runs"$$VX6'lx74::<8 44 WIV $))$/5   ++H5mmom4 ..!+b99 sA2B54B35?B5cpK|jtj|dd{}|duS7w)z)Get share state for a run asynchronously.rN)read_run_shared_linkr$r)r+rlinks r5 run_is_sharedzAsyncClient.run_is_shareds7..y/A/A&(/STT4Us )64 6cK|jddtj|ddd{}tj||j }|d|vry|j d|ddS7Ew) aNRetrieve 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. rqrrrNrrr)rlr$rr!rTrsrJ)r+rrjresults r5rz AsyncClient.read_run_shared_links44 Y''9:& A   ++H5 >]&8..!&*?)@CC s.A8A6AA8cKd|i|}|jddtj|d{}tjdi|j S7'w)zCreate a project.rrx /sessionsr~Nr)rlr$rr TracerSessionrs)r+rrerrjs r5create_projectzAsyncClient.create_projectsd  //44 K)>)>t)D5  '':(--/:: 1AA(AcK|r1|jddtj|d{}n,|r|jddd|id{}n td|j }t |t r3|stjd|d tjd i|d Stjd i|S77zw) zRead a project.rq /sessions/Nrrrr2Either project_name or project_id must be providedzProject not foundrr) rlr$r ValueErrorrsr'rr!r\rr)r+rrrjrs r5rzAsyncClient.read_projects !88I$6$6z$B#CDH!88{FL+A9HQR R}} dD !55|nJ7++6d1g6 6''/$//#".CC  CC A9C C)rrcK| | td|/|j|d{}t|j}|s td|j ddt j |d{y7W7w)zDelete a project from LangSmith. Args: project_name: The name of the project to delete. project_id: The ID of the project to delete. NrrzProject not foundDELETEr)rrrErrlr$r)r+rrrs r5delete_projectzAsyncClient.delete_projects  ,"6QR R   --<-HHGWZZJ01 1)) ++J78 9   I s"'BBAB;B<BBcKd|i|}|jddtj|d{}tjdi|j S7'w)zCreate a dataset.rrx /datasetsr~Nr)rlr$rrDatasetrs)r+ dataset_namererrjs r5create_datasetzAsyncClient.create_dataset-sd  //44 K)>)>t)D5  !!4HMMO44 rcK|r1|jddtj|d{}n,|r|jddd|id{}n td|j }t |t r3|stjd|d tjd i|d Stjd i|S77zw) zRead a dataset.rq /datasets/Nrrrrz2Either dataset_name or dataset_id must be providedzDataset rrr) rlr$rrrsr'rr!r\rr)r+r dataset_idrjrs r5 read_datasetzAsyncClient.read_dataset9s !88I$6$6z$B#CDH!88{FL+A9HQR R}} dD !55|nJ7%%0Q0 0!!)D))#rcpK|jddtj|d{y7w)zDelete a dataset.rrN)rlr$r)r+rs r5delete_datasetzAsyncClient.delete_datasetSs7)) ++J78 9   s ,646c |K|jd|23d{}tjdi|"76yw)zList datasets.rrrNr)rwrr)r+redatasets r5 list_datasetszAsyncClient.list_datasetsZsD "66{66R 0 0'$$/w/ / 0Rs<:8:<:<cFK| | td|&|j|d{}|j}||t|d|}|j ddt j |d{}tjdi|jS7s7)w) zCreate an example.Nz2Either dataset_id or dataset_name must be providedr)routputsrrx /examplesr~r) rrrrErlr$rrExamplers) r+rrrrrerrrjs r5create_examplezAsyncClient.create_examplebs  ,"6QR R   --<-HHG Jj/    44 K)>)>t)D5  !!4HMMO44I s"'B!BA B!5B6(B!B!cK|jddtj|d{}tjdi|j S7'w)zRead an example.rqz /examples/Nr)rlr$rrrrs)r+ example_idrjs r5 read_examplezAsyncClient.read_example|sT44 Z 2 2: >?@  !!4HMMO44 r)rrc ,K|j}|rtj||d<n+|r)|j|d{}|j|d<|j d|23d{}t jdi|"7H76yw)zList examples.rrNrrrr)rr$rrrrwrr)r+rrrerLrexamples r5 list_exampleszAsyncClient.list_exampless  ) 2 2: >F9   --<-HHG ' F9 !66{66R 0 0'$$/w/ / I 0Rs6ABB&B,B0B1B4BBBcKtj|d||||d|}|jddtj|d{}t j di|j S7'w) aCreate feedback for a run. Args: run_id: The ID of the run to provide feedback for. Can be `None` for project-level feedback. key: The name of the metric or aspect this feedback is about. score: The score to rate this run on the metric or aspect. value: The display value or non-numeric value for this feedback. comment: A comment about this feedback. **kwargs: Additional keyword arguments to include in the feedback data. Returns: The created feedback object. Raises: httpx.HTTPStatusError: If the API request fails. T) accept_null)rkeyscorevaluecommentrx /feedbackr~Nr)r$ _ensure_uuidrlrrFeedbackrs) r+rrrrrrerrjs r5create_feedbackzAsyncClient.create_feedbacks8 ,,VF    44 K)>)>t)D5  ""5X]]_55 sA A6 A4 (A6)r correctionrmetadatac TKtj||jd\}}||jk7rtd||j ddtj |tj |||||dd{} tj| y7w) a!Create feedback from a presigned token or URL. Args: token_or_url: The token or URL from which to create feedback. score: The score of the feedback. value: The value of the feedback. correction: The correction of the feedback. comment: The comment of the feedback. metadata: Additional metadata for the feedback. Raises: ValueError: If the source API URL is invalid. Returns: This method does not return anything. rN) num_partszInvalid source API URL. rxz/feedback/tokens/)rrr rr r~N) r$_parse_token_or_urlrFrrlrrr!rT) r+ token_or_urlrrr rr source_api_url token_uuidrjs r5create_feedback_from_tokenz&AsyncClient.create_feedback_from_tokens4&/%B%B $--1& "  T]] *77GHI I44  2 2: >? @))""",& (  5    ++H5  sB B( B& B() expirationfeedback_config feedback_idcK||||xsttjd}|tjddd|d<nt |t j r|j|d<nut |t jrCtj|j|jdz|jdzd z|d<ntd t|d |jd d tj|d{}tj di|j#S7'w)a&Create 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 (Union[UUID, str]): The ID of the run to provide feedback for. feedback_key: The name of the metric or aspect this feedback is about. 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_keyrrNrr)dayshoursminutes expires_in expires_ati<zInvalid expiration type: z3. Expected datetime.datetime or datetime.timedelta.rxz/feedback/tokensr~r)rErrrTimeDeltaInputr'datetimer timedeltarsecondsrtyperlr$rFeedbackIngestTokenrs)r+rrrrrrzrjs r5create_presigned_feedback_tokenz+AsyncClient.create_presigned_feedback_tokens=H(.2TZZ\!2    !+!:!:"D   H$5$5 6!+!5!5!7D   H$6$6 7!+!:!:__ ((D0#++d2r9"D  +D,<+=>DD  44  ))$/5   --@ @@  sDD>D<(D>cK|jddtj|d{}tjdi|j S7'w)zRead feedback.rq /feedback/Nr)rlr$rrrrsr+rrjs r5 read_feedbackzAsyncClient.read_feedback0sV44 Z 2 2; ?@A  ""5X]]_55 r)rrfeedback_source_typeroc JK|r,|Dcgc] }ttj|"c}nd| t|dndd|}|||d<|||d<d}|j d|23d{} t j d i| |d z }|)||k\s/ycc}w716yw) zList feedback.Nrp)rrorsourcerrrrrNr)rEr$rminrwrr) r+rrr)rorerrLrfeedbacks r5 list_feedbackzAsyncClient.list_feedback9sFMA#Y'',-ARV(-(9S_s      #(F5M  +3F8  "77 F7S  (%%11 1 !GB R5[B Ss?B#%B;B#)B!-B.B!1 B#B#B#B!!B#cK|jddtj|dd{}tj|y7w)z~Delete a feedback by ID. Args: feedback_id (Union[UUID, str]): The ID of the feedback to delete. rr&rNrlr$rr!rTr's r5delete_feedbackzAsyncClient.delete_feedbackUsL 44  9#5#5k=#Q"RS   ++H5 s-A A A ) queue_idsr name_containsroc DK|6t|Dcgc]\}}tj|d|d!c}}nd||| t|dndd}d}|j d|23d{} t j d i| |d z }|)||k\s/ycc}}w726yw) 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: The name of the queue to filter by. name_contains: The substring that the queue name should contain. limit: The maximum number of queues to return. Yields: The annotation queues. Nz queue_ids[]rp)idsrr3ror/annotation-queuesrrrNr) enumerater$rr,rwrAnnotationQueue) r+r2rr3roirrLrr-s r5list_annotation_queuesz"AsyncClient.list_annotation_queuesbs4(#,I"63&&sj1,=> *(-(9S_s  "77 8   (,,8x8 8 !GB R5[%  s?B $B.B %B)B*B- B B B BB ) descriptionqueue_idc hK||| t|nttjd}|jdd|j Dcic] \}}| || c}}d{}t j |tjdi|jScc}}w7Bw)aTCreate an annotation queue on the LangSmith API. Args: name: The name of the annotation queue. description: The description of the annotation queue. queue_id (Optional[Union[UUID, str]]): The ID of the annotation queue. Returns: The created annotation queue object. N)rr<rrxr7rsr) rErrrlrQr!rTrr9rs)r+rr<r=rzrfrgrjs r5create_annotation_queuez#AsyncClient.create_annotation_queues$&#+#7#h-S=N  44  #'::<A41a1=!Q$A5   ++H5)) mmo  B s%AB2 B*B*! B2-B0.AB2c`K|j|gjd{S7w)zRead an annotation queue with the specified `queue_id`. Args: queue_id (Union[UUID, str]): The ID of the annotation queue to read. Returns: The annotation queue object. )r2N)r; __anext__)r+r=s r5read_annotation_queuez!AsyncClient.read_annotation_queues-00H:0FPPRRRRs %.,.)r<cK|jddtj|d||dd{}tj|y7w)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: The new name for the annotation queue. description: The new description for the annotation queue. r/annotation-queues/r=)rr<r?Nr0)r+r=rr<rjs r5update_annotation_queuez#AsyncClient.update_annotation_queues]44 !)"4"4Xz"J!K L*5   ++H5 s2AAAcK|jddtj|dddi|jjd{}t j |y7w)zDelete an annotation queue with the specified `queue_id`. Args: queue_id (Union[UUID, str]): The ID of the annotation queue to delete. rrEr=Acceptr)rN)rlr$rrrr!rT)r+r=rjs r5delete_annotation_queuez#AsyncClient.delete_annotation_queuesj 44 !)"4"4Xz"J!K L1JT\\5I5IJ5   ++H5  AA& A$ A&c(K|jddtj|ddt|Dcgc](\}}t tj|d|d*c}}d{}t j |ycc}}w7 w) aAdd 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. rxrEr=rzrun_ids[r5r?N)rlr$rr8rEr!rT)r+r=rr:rrjs r5add_runs_to_annotation_queuez(AsyncClient.add_runs_to_annotation_queues44 !)"4"4Xz"J!K5 Q(0AsI&&shqcO<=5   ++H5  s4B-B # B/B0!Bc K|jddtj|ddtj|dd{}tj|y7w)a Delete 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. rrEr=rrNr0)r+r=rrjs r5 delete_run_from_annotation_queuez,AsyncClient.delete_run_from_annotation_queuesd44 !)"4"4Xz"J!K6R[RdRdekmuRvQw x   ++H5  sAA#A!A#cKdtj|dd}|jd|d|d{}tj|t j di|jS7<w)aGet a run from an annotation queue at the specified index. Args: queue_id (Union[UUID, str]): The ID of the annotation queue. index: The index of the run to retrieve. Returns: The run at the specified index. Raises: LangSmithNotFoundError: If the run is not found at the given index. LangSmithError: For other API-related errors. rEr=z/runrq/Nr)r$rrlr!rTrRunWithAnnotationQueueInfors)r+r=indexrrjs r5get_run_from_annotation_queuez)AsyncClient.get_run_from_annotation_queuess )););Hj)Q(RRVW44Uxj%> !!88 LLH  / / 9'99LHMMOLDN~~ Ms"A4A2AA4cjK|jd{}|dk(xs|j|k(S7w)zCheck if the current workspace has the same handle as owner. Args: owner: The owner to check against. Returns: bool: `True` if the current tenant is the owner, `False` otherwise. N-)rd tenant_handle)r+ownersettingss r5_current_tenant_is_ownerz$AsyncClient._current_tenant_is_owners8++--|>x55>>.s 313cK|jd{}tjd|d|jd|S7,w)NzCannot z% for another tenant. Current tenant: z, Requested tenant: )rdr!LangSmithUserErrorrg)r+actionrhris r5_owner_conflict_errorz!AsyncClient._owner_conflict_errorsX++--**fX'5567!!& )  .sAA-ArcK|jdd|d||dd{}|jd}|r|dd SdS7#w) aLGet the latest commit hash for a prompt. Args: prompt_owner_and_name: The owner and name of the prompt. limit: The maximum number of commits to fetch. offset: The number of commits to skip. Returns: The latest commit hash, or `None` if no commits are found. rq /commits/rP)rornrrNcommitsr commit_hash)rlrs)r+prompt_owner_and_namerornrjrqs r5_get_latest_commit_hashz#AsyncClient._get_latest_commit_hashsh44 -.a 0"f55   --/),,3wqz-(==  sAA$AcKt|tr|gn|}dfd }tj|Dcgc] }|| c}d{ycc}w7 w)a^Update tags for a prompt commit. Args: prompt_owner_and_name: The owner and name of the prompt in the format 'owner/repo'. commit_id: The commit ID to tag. tags: A single tag or list of tags to apply to the commit. Raises: requests.exceptions.HTTPError: If the request fails. cK|d}jddd|d{}tj|y7w)N)tag_name commit_idrx/repos/z/tagsr?)rlr!rT)rUpayloadrjrxrsr+s r5 create_tagz3AsyncClient._create_commit_tags..create_tagsW&G"88'"7!8>W9H  / / 9s!A?AN)rUrE)r'rErar)r+rsrxtagstag_listr{rUs``` r5_create_commit_tagszAsyncClient._create_commit_tagssI(c2D6 :nn(C3z#CDDDCDs1AAA A AcKtj|\}}}|jdd|d|d|id{}|j|j S7$w)aLike or unlike a prompt. Args: prompt_identifier: The identifier of the prompt. like: 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. rxz/likes/rPliker?N)r!parse_prompt_identifierrlraise_for_statusrs)r+prompt_identifierrrh prompt_name_rjs r5_like_or_unlike_promptz"AsyncClient._like_or_unlike_promptsq !) @ @AR S{A44 geWAk]364.5   !!#}}  s9A"A %A"c Ktj|\}}}|j|s|jd|d|d|ddS|j d{}|jd|d|ddd|j S7(w)zGet a URL for a prompt. Args: prompt_identifier: The identifier of the prompt. Returns: The URL for the prompt. z/hub/rP:Nz /prompts/z?organizationId=)r!rrjrJrdr)r+rrhrrrris r5_get_prompt_urlzAsyncClient._get_prompt_urls+3*J*J + '{K,,U3nn%U5';-qRa@QR R++--~~i }Ak"1o5Fx{{m - .sABB)BcLK|j|d{}|rdSdS7 w)zCheck if a prompt exists. Args: prompt_identifier: The identifier of the prompt. Returns: `True` if the prompt exists, `False` otherwise. NTF) get_prompt)r+rprompts r5_prompt_existszAsyncClient._prompt_exists6s,'899t(5(:s $" $cDK|j|dd{S7w)zLike a prompt. Args: prompt_identifier: The identifier of the prompt. Returns: A dictionary with the key `'likes'` and the count of likes as the value. TrNrr+rs r5 like_promptzAsyncClient.like_promptBs%001B0NNNN   cDK|j|dd{S7w)zUnlike a prompt. Args: prompt_identifier: The identifier of the prompt. Returns: A dictionary with the key `'likes'` and the count of likes as the value. FrNrrs r5 unlike_promptzAsyncClient.unlike_promptMs%001B0OOOOrrpdesc)rorn is_public is_archived sort_fieldsort_directionrc  K|||rdn|dnd|rdndt|tjr |jn||||rdndd}|j ddt |d{} tj di| jS7'w) aFList prompts with pagination. Args: limit: The maximum number of prompts to return. offset: The number of prompts to skip. is_public: Filter prompts by if they are public. is_archived: Filter prompts by if they are archived. sort_field (PromptSortField): The field to sort by. Defaults to `'updated_at'`. sort_direction: The order to sort by. query: Filter prompts by a search query. Returns: A response object containing the list of prompts. trueNfalse)rornrrrrr match_prefixrqryrrr)r'rPromptSortFieldrrl _exclude_noneListPromptsResponsers) r+rornrrrrrrLrjs r5 list_promptszAsyncClient.list_promptsXs8#I4It%06gj**D*DE  ,&+F "44 9]6%:5  --@ @@ sA"B$B %(BcKtj|\}}} |jdd|d|d{}tjdi|j dS7*#tj $rYywxYww)aGet a specific prompt by its identifier. Args: prompt_identifier: The identifier of the prompt. The identifier should be in the format `'prompt_name'` or `'owner/prompt_name'`. Returns: The prompt object. Raises: requests.exceptions.HTTPError: If the prompt is not found or another error occurs. rqryrPNrepor)r!rrlrPromptrsr\r+rrhrrrjs r5rzAsyncClient.get_prompts !) @ @AR S{A !88q 6H$$?x}}v'>? ?..  s8A>A%A#)A%"A>#A%%A;8A>:A;;A>r<readmer|rcK|jd{}|r!|jstjdtj|\}}} |j |d{s|j d|d{||xsd|xsd|xsg|d} |jdd| d{} | jtjd i| jd S777n7@w) aCreate a new prompt. Does not attach prompt object, just creates an empty prompt. Args: prompt_identifier: The identifier of the prompt. The identifier should be in the format of `owner/name:hash`, `name:hash`, `owner/name`, or `name` description: A description of the prompt. readme: A readme for the prompt. tags: A list of tags for the prompt. is_public: Whether the prompt should be public. Returns: 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)rhzcreate a prompt) repo_handler<rr|rrxryr?rr) rdrgr!rlrrjrnrlrrrrs) r+rr<rr|rrirhrrrsrjs r5 create_promptzAsyncClient.create_prompts<++-- X33--6 !) @ @AR S{A33%3@@@334EuMM N'&,"lJB" < 44VYT4RR!!#  ;8==?6#:;;/.AMSsFC9C1AC9,C3-C9C5/C96C77;C93C95C97C9parent_commit_hashr|cK|j|d{stjdtj|}t |t r d|vrd|vr|}n$ ddlm}||}tj|}tj|\} } } | d| } |d k(s||j| d{}||d } |jd d | | d{}|jd}|d}|d}|r|j| ||d{|j!| d|d{S7*#t$r tdwxYw77y7A7%w)a>Create a commit for an existing prompt. Args: prompt_identifier: The identifier of the prompt. object: The LangChain object to commit. parent_commit_hash: The hash of the parent commit. Defaults to latest commit. tags: A single tag or list of tags to apply to the commit. Defaults to `None`. Returns: The url of the prompt commit. Raises: HTTPError: If the server request fails. ValueError: If the prompt does not exist. Nz0Prompt does not exist, you must create it first.rlcr)dumpszvThe client.create_commit function requires the langchain-corepackage to run. Install with `pip install langchain-core`rPrT) parent_commitmanifestrxrpr?commitrrr)rr!r\r$prep_obj_for_pushr'dictlangchain_core.loadr ImportErrorrsloadsrrtrlr~r)r+robjectrr|prepped manifest_dictr json_objectrhrrrs request_dictrj commit_jsonrrrxs r5 create_commitzAsyncClient.create_commits6))*;<<<11B  --f5 gt $TW_#M 5 .K JJ{3M ( @ @AR S{A#(';- 8  )-?-G'+'C'C%(" *<W 44 i 567l5  mmoh/ !-0 % **+@)TR R R))-B,C1[M*RSSSQ= !Q "   SSskE$EA E$"E(AE$E#E$$E%9E$E E$<E"=E$EE$E$ E$"E$)r<rr|rrctK|jd{}|r|js tdi}|||d<|||d<|||d<|||d<|||d<tj|\} } } |j dd | d | | d{} | j | jS77&w) aUpdate a prompt's metadata. To update the content of a prompt, use push_prompt or create_commit instead. Args: prompt_identifier: The identifier of the prompt to update. description: New description for the prompt. readme: New readme for the prompt. tags: New list of tags for the prompt. is_public: New public status for the prompt. is_archived: New archived status for the prompt. Returns: The updated prompt data as returned by the server. Raises: ValueError: If the `prompt_identifier` is empty. HTTPError: If the server request fails. Nrr<rrrr|rryrPr?)rdrgrr!rrlrrs) r+rr<rr|rrrirsrhrrrjs r5 update_promptzAsyncClient.update_prompts:++-- X336 <>  ""-D   #DN  )D   ""-D   DL ( @ @AR S{A44 wugQ{m445   !!#}}7.. s"B8B4A8B8B6%B86B8cKtj|\}}}|j|d{s|jd|d{|j dd|d|d{}|j y7O777w)a.Delete a prompt. Args: prompt_identifier: The identifier of the prompt to delete. Returns: `True` if the prompt was successfully deleted, `False` otherwise. Raises: ValueError: If the current tenant is not the owner of the prompt. Nzdelete a promptrryrP)r!rrjrnrlrrs r5 delete_promptzAsyncClient.delete_promptXs!) @ @AR S{A33E:::334EuMM N44 wa }5   !!# ;M s3.BBB B B*B+BBBc|rdnd}||S)zGenerate a cache key for a prompt. Args: prompt_identifier: The prompt identifier. include_model: Whether model info is included. Returns: The cache key string. z :with_modelrr)r+r include_modelsuffixs r5_get_cache_keyzAsyncClient._get_cache_keyms#0R#$VH--rGc Ktj|\}}}|jdd|d|d||rdndd{}tjdi||d|j S7,w) zFetch a prompt from the API (no caching). Args: prompt_identifier: The prompt identifier. include_model: Whether to include model information. Returns: The `PromptCommit` object. rqrprPz?include_model=truerNrhrr)r!rrlr PromptCommitrs)r+rrrhrrrrjs r5_afetch_prompt_from_apiz#AsyncClient._afetch_prompt_from_api|s+3*J*J + '{K44 E7!K=+,9(rBD  && {FhmmoF   s>A/A--A/r skip_cachec<K|s=|j1|j||}|jj|}||S|j||d{}|s:|j.|j||}|jj |||S7Bw)aPull a prompt object from the LangSmith API. Args: prompt_identifier: The identifier of the prompt. include_model: Whether to include model information. skip_cache: Whether to skip the prompt cache. Defaults to `False`. Returns: The prompt object. Raises: ValueError: If no commits are found for the prompt. N)rrrPrset)r+rrr cache_keycachedrs r5pull_prompt_commitzAsyncClient.pull_prompt_commits.dkk5++,=}MI[[__Y/F! 334E}UUdkk5++,=}MI KKOOIv . VsABBABrornrcKtj|\}}}| td|n|||d}d} ||d<|jdd|d|d| d{} | j } | d } | d } | sy| D]-}|| |k\ryt j di||d || d z } /|t| z }|| k\ry7hw)aList commits for a given prompt. Args: prompt_identifier: The identifier of the prompt in the format `owner/repo_name`. limit: The maximum number of commits to return. If `None`, returns all commits. offset: The number of commits to skip before starting to return results. include_model: Whether to include the model information in the commit data. 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. NrprrrnrqrprPrrrqtotalrrNr)r!rr,rlrsrListedPromptCommitrt)r+rrornrrhrrrLr:rjvalrQrits r5list_prompt_commitszAsyncClient.list_prompt_commitss4!) @ @AR S{A).(9Se_u*  %F8 !88E7!K=29H --/C NELE $e 33 %{AbAQ   c%j F/sACB?A)C)rsecretssecrets_from_envrcxK|j|||d{}tj||||S7w)aPull a prompt and return it as a LangChain `PromptTemplate`. This method requires [`langchain-core`](https://pypi.org/project/langchain-core). Args: prompt_identifier: The identifier of the prompt. include_model: Whether to include the model information in the prompt data. secrets: A map of secrets to use when loading, e.g. `{'OPENAI_API_KEY': 'sk-...'}`. If a secret is not found in the map, it will be loaded from the environment if `secrets_from_env` is `True`. Should only be needed when `include_model=True`. secrets_from_env: Whether to load secrets from the environment. **SECURITY NOTE**: Should only be set to `True` when pulling trusted prompts. skip_cache: Whether to skip the prompt cache. Defaults to `False`. Returns: The prompt object in the specified format. !!! warning "Behavior changed in `langsmith` 0.5.1" Updated to take arguments `secrets` and `secrets_from_env` which default to None and False, respectively. By default secrets needed to initialize a pulled object will no longer be read from environment variables. This is relevant when `include_model=True`. For example, to load an OpenAI model you need to have an OPENAI_API_KEY. Previously this was read from environment variables by default. To do so now you must specify `secrets={"OPENAI_API_KEY": "sk-..."}` or `secrets_from_env=True`. `secrets_from_env` should only be used when pulling trusted prompts. These updates were made to remediate vulnerability [GHSA-c67j-w6g6-q2cm](https://github.com/langchain-ai/langchain/security/advisories/GHSA-c67j-w6g6-q2cm) in the `langchain-core` package which this method (but not the entire langsmith package) depends on. rN)rrr)rr$_process_prompt_manifest)r+rrrrr prompt_objects r5 pull_promptzAsyncClient.pull_promptsPb#55 ]z6  11 '-    s :8:)rrrr<rr| commit_tagsctK|j|d{r5td||||fDrA|j|||||d{n"|j|||nd|||d{||j |d{S|j ||||d{} | S77d7C7)7w)aPush a prompt to the LangSmith API. Can be used to update prompt metadata or prompt content. If the prompt does not exist, it will be created. If the prompt exists, it will be updated. Args: prompt_identifier: The identifier of the prompt. object: The LangChain object to push. parent_commit_hash: The parent commit hash. is_public: Whether the prompt should be public. If `None` (default), the current visibility status is maintained for existing prompts. For new prompts, `None` defaults to private. Set to `True` to make public, or `False` to make private. description: A description of the prompt. Defaults to an empty string. readme: A readme for the prompt. Defaults to an empty string. tags: A list of tags for the prompt. Defaults to an empty list. commit_tags: A single tag or list of tags for the prompt commit. Defaults to an empty list. Returns: The URL of the prompt. Nc3$K|]}|du ywrDr).0params r5 z*AsyncClient.push_prompt..gs&+T!srF)rr<rr|)rr)ranyrrrr) r+rrrrr<rr|rurls r5 push_promptzAsyncClient.push_prompt5s b$$%67 7 709;PT/U((% +!' )$$!'0'<)%' %   >--@Q-RR R&&  1 '    = 8 S sWB8B.3B8 B0 "B8.B2/B8 B4 B8'B6(B80B82B84B86B8)NNNNNF) r, Optional[str]r-rr.zWOptional[Union[int, tuple[Optional[int], Optional[int], Optional[int], Optional[int]]]]r/zOptional[Mapping[str, Any]]r0rr1zUnion[AsyncCache, bool])returnr)rrE)rcrErdrErerrzhttpx.ResponserD)rurErLOptional[dict[str, Any]]rzAsyncIterator[dict[str, Any]]) rurErzOptional[dict]r{rEr|rErzAsyncIterator[dict])rrErdict[str, Any]rrErrrOptional[ls_client.ID_TYPE]rerrNone)rls_client.ID_TYPErerrr)rrrzls_schemas.Run)$rz?Optional[Union[ls_client.ID_TYPE, Sequence[ls_client.ID_TYPE]]]rz#Optional[Union[str, Sequence[str]]]rrrrrrrrrrrrrrrOptional[bool]rrrzOptional[datetime.datetime]rrr%Optional[Sequence[ls_client.ID_TYPE]]rOptional[Sequence[str]]ro Optional[int]rerrzAsyncIterator[ls_schemas.Run])rrrrrrE)rrrbool)rrrr)rrErerrls_schemas.TracerSession)NN)rrrrrr)rrrrrr)rrErerrls_schemas.Dataset)rrrrrr)rrrr)rerrz!AsyncIterator[ls_schemas.Dataset])NNN) rrrrrrrrrerrls_schemas.Example)rrrr)rrrrrerrz!AsyncIterator[ls_schemas.Example])rrrrErzOptional[float]r(Union[float, int, bool, str, dict, None]rrrerrls_schemas.Feedback)rzUnion[str, uuid.UUID]rzUnion[float, int, bool, None]rrr zUnion[dict, None]rzUnion[str, None]r rrr) rrrrErz0Optional[datetime.datetime | datetime.timedelta]rz#Optional[ls_schemas.FeedbackConfig]rrrzls_schemas.FeedbackIngestToken)rrrr) rrrrr)z1Optional[Sequence[ls_schemas.FeedbackSourceType]]rorrerrz"AsyncIterator[ls_schemas.Feedback])rID_TYPErr) r2zOptional[list[ID_TYPE]]rrr3rrorrz)AsyncIterator[ls_schemas.AnnotationQueue])rrEr<rr=zOptional[ID_TYPE]rls_schemas.AnnotationQueue)r=rrr)r=rrrEr<rrr)r=rrr)r=rrz list[ID_TYPE]rr)r=rrrrr)r=rrRr(rz%ls_schemas.RunWithAnnotationQueueInfo)rrrUrErerrr)rrrerrr) rrror(rrrrrerrzlist[ls_schemas.ExampleSearch])rzls_schemas.LangSmithSettings)rhrErr)rmrErhrErzls_utils.LangSmithUserError)rNr)rsrEror(rnr(rr)rsrErxrEr|zUnion[str, list[str]]rr)rrErrrdict[str, int])rrErrE)rrErr)rrErr)ror(rnr(rrrrrzls_schemas.PromptSortFieldrzLiteral['desc', 'asc']rrrzls_schemas.ListPromptsResponse)rrErzOptional[ls_schemas.Prompt]) rrEr<rrrr|rrrrzls_schemas.Prompt) rrErrrrr|Optional[str | list[str]]rrE)rrEr<rrrr|rrrrrrr)rrErr)F)rrErrrrE)rrErrrls_schemas.PromptCommit)rrErrrrrr) rrErorrnr(rrrz3AsyncGenerator[ls_schemas.ListedPromptCommit, None]) rrErz bool | Nonerzdict[str, str] | Nonerrrrrr)rrErz Optional[Any]rrErrr<rrrr|rrrrrE)L__name__ __module__ __qualname____doc__ __slots__r6r:r@r<propertyrFrJrlrwrrrrrrrrrrrrrrrrrrr rr$r(r.r1r;r@rCrFrIrLrNrSls_beta warn_betarYr[rardrjrnrtr~rrrrrrr updated_atrrrrrrrrrrrrrrGr5rrsc >OI"&!% 48!%).999 9299'9v $ **CC: : :  :  : ~,0!!)! ' !2 $$ 00 0  0  0 0H'+37     $  1    0  !       1 <@"&04<@# $&*%)"&5926 $9=*.#)b b : b b.b:bbb$b#b b3b 0!b"#b$7%b&('b()b*+b, '-bJUY:':6Q: :> D. ; ; ; " ;'+260#000 " 0604QU , AN  * 5 5 5  5'+26*#*0*  *4 00 +0-126&* 55*50 5 $ 5  5 54537&* 000$ 0  0 + 0,"&:>!% &6+&6&6 &6 8 &6  &6&6 &6V04-6 ;?(,$(#'-6+-6--6 8 -6 & -6"-6!-6 -6hHL?C37BA!BABA E BA = BA1BA (BAH6,6 6:>04RV# 7.  P    ,8 6 .2"'+# (+( ( % (  ( 3(\&*&*   #  $  $  @ S S # SMQ66*-6%(>14>BE> >*E%(E58E@UE E:!$,0 . . ) O P$(&+1;1K1K1V1V17#/A/A /A " /A $ /A//A//A/A (/Ab:&* $(,5<5<# 5<  5< & 5<5< 5rsb!" LL )+':&  3 ffR;9rG