XiLdZddlmZddlZddlZddlZddlZddlZddlm Z m Z m Z m Z ddl mZddlmZmZmZmZmZddlZddlmZddlmZdd lmZdd lmZmZeej@e!fZ"Gd d Z#dd Z$y)zThe Async LangSmith Client.) annotationsN)AsyncGenerator AsyncIteratorMappingSequence)partial)AnyLiteralOptionalUnioncast)client)schemas)utils)AsyncPromptCacheasync_prompt_cache_singletonceZdZdZdZ dd dedZdfdZdZdZe d Z e dgd Z dhd Z di djd Z dd dd dkdZddd dldZ dmdZdndZddddddddddddddddd dodZdd dpdZdqdZdrdZ dsdZ dt dudZddd dvdZ dwdZ dt dxd Zdyd!Z dzd"Z d{ d|d#Zd}d$Zddd% d~d&Z d{ dd'Z diddddd( dd)Z!dddd* dd+Z" dd,Z#ddddd- dd.Z$dd/Z%ddddd0 dd1Z&ddddd2 dd3Z' dd4Z(ddddd5 dd6Z)dd7Z* dd8Z+ dd9Z, dd:Z-dd; dd<Z.dddd=d> dd?Z/ddd@ ddAZ0ddBZ1ddCZ2ddDZ3 ddEZ4 d ddFZ5 ddGZ6 ddHZ7ddIZ8ddJZ9ddKZ:ddLZ;dMd=ddedD,QH  E *:Va!-a$hTAVWHH((h    AE  !5  HMM1#      HMMR#  ~:> $: $ %6DKDKYWsEcnK|j"|jjd{|S7w)zEnter the async client.N)rstartr1s r< __aenter__zAsyncClient.__aenter__~s0 ;; "++##% % %  &s *535c@K|jd{y7w)zExit the async client.N)aclose)r1exc_typeexc_valexc_tbs r< __aexit__zAsyncClient.__aexit__skkms cK|j"|jjd{|jjd{y7'7w)zClose the async client.N)rstoprrCr@s r<rCzAsyncClient.aclosesE ;; "++""$ $ $ll!!### %#s!*AA!AAAAc@t|jjSN)strrrr@s r<_api_urlzAsyncClient._api_urls4<<(())cVtj|j|jS)zThe web host url.)r$ get_host_urlrrMr@s r< _host_urlzAsyncClient._host_urls$$T]]DMMBBrNc 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: r"z0Unexpected error connecting to the LangSmith API)r r+rgetitemsrangerrequestr$raise_for_status_with_textr-HTTPStatusError status_codeLangSmithAPIErrorreprLangSmithRequestTimeoutLangSmithRateLimitErrorLangSmithAuthErrorLangSmithNotFoundErrorLangSmithConflictErrorLangSmithError RequestErrorLangSmithConnectionErrorasynciosleep) r1methodendpointkwargsrrSkvfiltered_paramsattemptresponsees r<_arequest_with_retriesz"AsyncClient._arequest_with_retriess3 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_runrrrtracerrurrz /runs/query)rrUr)r*rUUIDrLappendlistextendrggather read_projectrr.r/r0 isoformatr'rrWrrr)r1rrrrrrrrrrrrrrrrurk project_idsrprojectsproject body_queryid_rlrmrixrs r< list_runszAsyncClient.list_runs3sb 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/sharerNr/public//r) r'rrLrrrrrr$rZryrQ)r1rrrun_id_rrprs r< 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)r1rlinks r< 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. rwrrrNrrr)rrr'rr$rZryrQ)r1rrpresults r<rz AsyncClient.read_run_shared_links44 Y''9:& A   ++H5 >]&8..!&*?)@CC s.A8A6AA8cKd|i|}|jddtj|d{}tjdi|j S7'w)zCreate a project.rr~ /sessionsrNr)rrr'rr TracerSessionry)r1rrkrrps r<create_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.rw /sessions/Nrrrx2Either project_name or project_id must be providedzProject not foundrr) rrr'r ValueErrorryr*rr$rbrr)r1rrrprs r<rzAsyncClient.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)rrrLrrrr'r)r1rrrs r<delete_projectzAsyncClient.delete_project8s  ,"6QR R   --<-HHGWZZJ01 1)) ++J78 9   I s"'BBAB;B<BBcKd|i|}|jddtj|d{}tjdi|j S7'w)zCreate a dataset.rr~ /datasetsrNr)rrr'rrDatasetry)r1 dataset_namerkrrps r<create_datasetzAsyncClient.create_datasetMsd  //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.rw /datasets/Nrrrxz2Either dataset_name or dataset_id must be providedzDataset rrr) rrr'rrryr*rr$rbrr)r1r dataset_idrprs r< read_datasetzAsyncClient.read_datasetYs !88I$6$6z$B#CDH!88{FL+A9HQR R}} dD !55|nJ7%%0Q0 0!!)D))#rcpK|jddtj|d{y7w)zDelete a dataset.rrN)rrr'r)r1rs r<delete_datasetzAsyncClient.delete_datasetss7)) ++J78 9   s ,646c |K|jd|23d{}tjdi|"76yw)zList datasets.rrxNr)r}rr)r1rkdatasets r< 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)routputsrr~ /examplesrr) rrrrLrrr'rrExamplery) r1rrrrrkrrrps r<create_examplezAsyncClient.create_examples  ,"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.rwz /examples/Nr)rrr'rrrry)r1 example_idrps r< read_examplezAsyncClient.read_examplesT44 Z 2 2: >?@  !!4HMMO44 r)rrc ,K|j}|rtj||d<n+|r)|j|d{}|j|d<|j d|23d{}t jdi|"7H76yw)zList examples.rrNrrxr)rr'rrrr}rr)r1rrrkrSrexamples r< 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)rkeyscorevaluecommentr~ /feedbackrNr)r' _ensure_uuidrrrrFeedbackry) r1rrrrrrkrrps r<create_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. rU) num_partszInvalid source API URL. r~z/feedback/tokens/)rrr rrrN) r'_parse_token_or_urlrMrrrrrr$rZ) r1 token_or_urlrrr rrsource_api_url token_uuidrps r<create_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.r~z/feedback/tokensrr)rLrrrTimeDeltaInputr*datetimer timedeltarsecondsrtyperrr'rFeedbackIngestTokenry)r1rrrrrrrps r<create_presigned_feedback_tokenz+AsyncClient.create_presigned_feedback_token s=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.rw /feedback/Nr)rrr'rrr ryr1rrps r< read_feedbackzAsyncClient.read_feedbackPsV44 Z 2 2; ?@A  ""5X]]_55 r)rrfeedback_source_typeruc 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.Nrv)rrursourcerr rxrUr)rLr'rminr}rr ) r1rrr,rurkrrSrfeedbacks r< list_feedbackzAsyncClient.list_feedbackYsFMA#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)rNrrr'rr$rZr*s r<delete_feedbackzAsyncClient.delete_feedbackusL 44  9#5#5k=#Q"RS   ++H5 s-A A A ) queue_idsr name_containsruc 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[]rv)idsrr6rur/annotation-queuesrxrUr) enumerater'rr/r}rAnnotationQueue) r1r5rr6ruirrSrr0s r<list_annotation_queuesz"AsyncClient.list_annotation_queuess4(#,I"63&&sj1,=> *(-(9S_s  "77 8   (,,8x8 8 !GB R5[%  s?B $B.B %B)B*B- B B B BB ) descriptionqueue_idrubric_instructions rubric_itemsc xK||| t|nttj|d}|||d<|jdd|j Dcic] \}}| || c}}d{} t j | tjdi| jScc}}w7Bw)aCreate 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. rubric_instructions: The rubric instructions for the annotation queue. rubric_items: The feedback configs to assign to this queue's rubric. Returns: The created annotation queue object. N)rr?rrArBr~r:ryr) rLrrrrrWr$rZrr<ry) r1rr?r@rArBrrlrmrps r<create_annotation_queuez#AsyncClient.create_annotation_queues,&#+#7#h-S=N#6    ##/D 44  #'::<A41a1=!Q$A5   ++H5)) mmo  B s%AB: B2$B2) B:5B86AB:c`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. )r5N)r> __anext__)r1r@s r<read_annotation_queuez!AsyncClient.read_annotation_queues-00H:0FPPRRRRs %.,.)rr?rArBcKi}|||d<|||d<|||d<|||d<|jddtj|d| d{}tj|y7w) aUpdate 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. rubric_instructions: The new rubric instructions for the queue. rubric_items: The feedback configs to assign to this queue's rubric. Nrr?rArBr/annotation-queues/r@rDr3)r1r@rr?rArBrrps r<update_annotation_queuez#AsyncClient.update_annotation_queues$ "  DL  ""-D   **=D& '  ##/D 44 !)"4"4Xz"J!K L5   ++H5  sA A,A*A,cK|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. rrJr@Acceptr)r N)rrr'rrr r$rZ)r1r@rps r<delete_annotation_queuez#AsyncClient.delete_annotation_queuesj 44 !)"4"4Xz"J!K L1JT\\5I5IJ5   ++H5  sAA& 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. r~rJr@rzrun_ids[r8rDN)rrr'rr;rLr$rZ)r1r@rr=rrps r<add_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. rrJr@rrNr3)r1r@rrps r< delete_run_from_annotation_queuez,AsyncClient.delete_run_from_annotation_queue$sd44 !)"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. rJr@z/runrw/Nr)r'rrrr$rZrRunWithAnnotationQueueInfory)r1r@indexrrps r<get_run_from_annotation_queuez)AsyncClient.get_run_from_annotation_queue4ss )););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-)rj tenant_handle)r1ownersettingss r<_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: )rjr$LangSmithUserErrorrm)r1actionrnros r<_owner_conflict_errorz!AsyncClient._owner_conflict_errorsX++--**fX'5567!!& )  .sAA-AcK|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. rw /commits/rTr`rxNcommitsr commit_hash)rrry)r1prompt_owner_and_namerurtrprws r<_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_idr~/repos/z/tagsrDrf)tagpayloadrpr~ryr1s r< create_tagz3AsyncClient._create_commit_tags..create_tagsW&G"88'"7!8>W9H  / / 9s!A?AN)rrL)r*rLrgr)r1ryr~tagstag_listrrs``` r<_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. r~z/likes/rTlikerDN)r$parse_prompt_identifierrrraise_for_statusry)r1prompt_identifierrrn prompt_name_rps r<_like_or_unlike_promptz"AsyncClient._like_or_unlike_promptsq !) @ @AR S{A44 geWAk]364.5   !!#}}  s9A"A %A"c "Ktj|\}}}|j|d{s|jd|d|d|ddS|j d{}|jd|d|ddd|j S7Z7*w)zGet a URL for a prompt. Args: prompt_identifier: The identifier of the prompt. Returns: The URL for the prompt. Nz/hub/rT:z /prompts/z?organizationId=)r$rrprQrjr)r1rrnrrxros r<_get_prompt_urlzAsyncClient._get_prompt_url3s+3*J*J + '{K33E:::nn%U5';-qRa@QR R++--~~i }Ak"1o5Fx{{m - ;.s!.BB 1B"B #)B 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)r1rprompts r<_prompt_existszAsyncClient._prompt_existsJs,'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. TrNrr1rs r< like_promptzAsyncClient.like_promptVs%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 r< unlike_promptzAsyncClient.unlike_promptas%001B0OOOOrrvdesc)rurt 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)rurtrrrrr match_prefixrwrrxr)r*rPromptSortFieldrrr _exclude_noneListPromptsResponsery) r1rurtrrrrrrSrps r< list_promptszAsyncClient.list_promptsls8#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. rwrrTNrepor)r$rrrrPromptryrbr1rrnrrrps r<rzAsyncClient.get_prompts !) @ @AR S{A !88q 6H$$?x}}v'>? ?..  s8A>A%A#)A%"A>#A%%A;8A>:A;;A>r?readmerrcK|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)rnzcreate a prompt) repo_handler?rrrr~rrDrr) rjrmr$rrrrprtrrrrrry) r1rr?rrrrornrrryrps r< create_promptzAsyncClient.create_prompts<++-- X33--6 !) @ @AR S{A33%3@@@334EuMM N'&,"lJB" < 44VYT4RR!!#  ;8==?6#:;;/.AMSsFC9C1AC9,C3-C9C5/C96C77;C93C95C97C9parent_commit_hashrr?cK|j|d{stjdtj|}t |t r d|vrd|vr|}n$ ddlm}||} tj| }tj|\} } } | d| } |d k(s||j| d{}||d }|||d <|jd d | |d{}|jd}|d}|d}|r|j| ||d{|j!| d|d{S71#t$r tdwxYw77y7A7%w)aCreate 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`. description: Optional human-readable description for the commit (max 1000 chars). 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`rTlatest) parent_commitmanifestr?r~rvrDcommitrxr)rr$rbr'prep_obj_for_pushr*dictlangchain_core.loadr ImportErrorryloadsrrzrrrr)r1robjectrrr?prepped manifest_dictr json_objectrnrrry request_dictrp commit_jsonrxr~s r< create_commitzAsyncClient.create_commits<))*;<<<11B  --f5 gt $TW_#M 5 .K JJ{3M ( @ @AR S{A#(';- 8  )-?-G'+'C'C%("  0%(   "*5L '44 i 567l5  mmoh/ !-0 % **+@)TR R R))-B,C1[M*RSSS[= !Q "  SSskE+EA E+"E (AE+E#*E++E%,9E+%E'&E+E)E+ E  E+%E+'E+)E+)r?rrrrctK|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?rrrrrrrTrD)rjrmrr$rrrrry) r1rr?rrrrroryrnrrrps r< update_promptzAsyncClient.update_prompt:s:++-- 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 promptrrrT)r$rrprtrrrrs r< delete_promptzAsyncClient.delete_promptts!) @ @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)r1r include_modelsuffixs r<_get_cache_keyzAsyncClient._get_cache_keys#0R#$VH--rNc 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. rwrvrTz?include_model=truerNrnrr)r$rrrr PromptCommitry)r1rrrnrrxrps r<_afetch_prompt_from_apiz#AsyncClient._afetch_prompt_from_apis+3*J*J + '{K44 E7!K=+,9(rBD  && {FhmmoF   s>A/A--A/r skip_cacheclKt|j||}|s>|j2|j||}|jj ||}||S|d{}|sC|j7|j||}|jj |||d{|S7K7w)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)rrrrrVaset)r1rrr refresh_func cache_keycachedrs r<pull_prompt_commitzAsyncClient.pull_prompt_commits.  ( (*;] dkk5++,=}MI[[__Y =F! $~%dkk5++,=}MI++""9flC C C & Ds%A"B4$B0%AB4)B2*B42B4rurtrcKtj|\}}}| 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. NrvrrrtrwrvrTrxrwtotalrrUr)r$rr/rrryrListedPromptCommitrz)r1rrurtrrnrrrSr=rpvalrWrits r<list_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)r1rrrrr prompt_objects r< pull_promptzAsyncClient.pull_promptsPb#55 ]z6  11 '-    s :8:r)rrrr?rr commit_tagscommit_descriptioncvK|j|d{r5td||||fDrA|j|||||d{n"|j|||nd|||d{||j |d{S|j ||||| d{} | S77e7D7*7w)a"Push 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. commit_description: Optional human-readable description for the commit (max 1000 chars). Defaults to `None`. Returns: The URL of the prompt. Nc3$K|]}|du ywrKr).0params r< z*AsyncClient.push_prompt..s&+T!srF)rr?rr)rr)ranyrrrr) r1rrrrr?rrrrurls r< push_promptzAsyncClient.push_promptVsh$$%67 7 709;PT/U((% +!' )$$!'0'<)%' %   >--@Q-RR R&&  1* '   ? 8 S sWB9B/3B9 B1 "B9.B3/B9 B5 B9(B7)B91B93B95B97B9)NNNNNFN)r2 Optional[str]r3rr4zWOptional[Union[int, tuple[Optional[int], Optional[int], Optional[int], Optional[int]]]]r5zOptional[Mapping[str, Any]]r6rr7boolr8z'Optional[Union[bool, AsyncPromptCache]])returnr)rrL)rirLrjrLrkr rzhttpx.ResponserK)r{rLrSOptional[dict[str, Any]]rzAsyncIterator[dict[str, Any]]) r{rLrOptional[dict]rrLrrLrzAsyncIterator[dict])rrLrdict[str, Any]rrLrrrOptional[ls_client.ID_TYPE]rkr rNone)rls_client.ID_TYPErkr rr)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]]ru Optional[int]rkr rzAsyncIterator[ls_schemas.Run])rrrrrrL)rrrr)rrrr)rrLrkr rls_schemas.TracerSession)NN)rrrrrr)rrrrrr)rrLrkr rls_schemas.Dataset)rrrrrr)rrrr)rkr rz!AsyncIterator[ls_schemas.Dataset])NNN) rrrrrrrrrkr rls_schemas.Example)rrrr)rrrrrkr rz!AsyncIterator[ls_schemas.Example])rrrrLrzOptional[float]r(Union[float, int, bool, str, dict, None]rrrkr rls_schemas.Feedback)rzUnion[str, uuid.UUID]rzUnion[float, int, bool, None]rrr zUnion[dict, None]rzUnion[str, None]rrrr) rrrrLrz0Optional[datetime.datetime | datetime.timedelta]r#Optional[ls_schemas.FeedbackConfig]rrrzls_schemas.FeedbackIngestToken)rrrr) rrrrr,z1Optional[Sequence[ls_schemas.FeedbackSourceType]]rurrkr rz"AsyncIterator[ls_schemas.Feedback])rID_TYPErr) r5zOptional[list[ID_TYPE]]rrr6rrurrz)AsyncIterator[ls_schemas.AnnotationQueue]) rrLr?rr@zOptional[ID_TYPE]rArrB4Optional[list[ls_schemas.AnnotationQueueRubricItem]]rls_schemas.AnnotationQueue)r@r rr ) r@r rrr?rrArrBr rr)r@r rr)r@r rz list[ID_TYPE]rr)r@r rr rr)r@r rVr+rz%ls_schemas.RunWithAnnotationQueueInfo)rrLrzls_schemas.FeedbackConfigrXrrls_schemas.FeedbackConfigSchema) rrr6rrurrtr+rz.AsyncIterator[ls_schemas.FeedbackConfigSchema])rrLrrrXrrr )rrLrr)rzls_schemas.LangSmithSettings)rnrLrr)rsrLrnrLrzls_utils.LangSmithUserError)rUr)ryrLrur+rtr+rr)ryrLr~rLrzUnion[str, list[str]]rr)rrLrrrdict[str, int])rrLrrL)rrLrr)rrLrr )rur+rtr+rrrrrzls_schemas.PromptSortFieldrzLiteral['desc', 'asc']rrrzls_schemas.ListPromptsResponse)rrLrzOptional[ls_schemas.Prompt]) rrLr?rrrrrrrrzls_schemas.Prompt) rrLrr rrrOptional[str | list[str]]r?rrrL)rrLr?rrrrrrrrrrr)rrLrr)F)rrLrrrrL)rrLrrrls_schemas.PromptCommit)rrLrrrrrr) rrLrurrtr+rrrz3AsyncGenerator[ls_schemas.ListedPromptCommit, None]) rrLrz bool | Nonerzdict[str, str] | Nonerrrrrr )rrLrz Optional[Any]rrLrrr?rrrrrrrrrrrL)K__name__ __module__ __qualname____doc__ __slots__r=rArGrCpropertyrMrQrrr}rrrrrrrrrrrrrrrrrrr rr'r+r1r4r>rErHrKrNrPrRrWr^rbrdrgrjrprtrzrrrrrrrr updated_atrrrrrrrrrrrrrrNr<rrs >OI"&!% 48!%%*9=YYY Y2YY#Y7Yv $ **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(\&*&*-1MQ% % # % $ % + % K%  $% N S S # S$#%)-1MQ 6 6 6 # 6 + 6K 6  6D 666-:6 6(66,36 6 HH+.H .H816 #B#B3 #B . #B ) #BP15'+# "."% "  "  " 8"P@D04 !B!B= !B . !B ) !BF6  ?  "% $ IJ>%(>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 )+'Q  3 KK\<9rN