lQjuSrSSKJr SSKrSSKrSSKrSSKrSSKrSSKrSSK r SSK r SSK r SSK r SSK r SSKrSSKrSSKJrJrJrJrJr SSKJrJr SSKJrJrJrJrJrJrJ r J!r! SSK"J#r$ SSK%r%SSK&r&SSK'J(r( SS K)J*r* SS K+J,r- \R\"\/5r0"S S \15r2"S S\25r3"SS\25r4"SS\25r5"SS\25r6"SS\25r7"SS\25r8"SS\25r9"SS\25r:"SS\25r;S\Sjr<"S S!\=5r>"S"S#\>5r?S]S^S$jjr@S_S%jrAS`S&jrBSaS'jrCSbS(jrD\R"S)S*9ScS+j5rFSdS,jrGSeS-jrHSfS.jrISgS/jrJShS0jrKSiS1jrLSjS2jrM\R"S)S*9SkS3j5rNSlS4jrOSmS5jrPSnS6jrQ\!S7S8.SoS9jj5rR\!S]S7S8.SpS:jjj5rR\R"S;S*9S]S7S8.SqS<jjj5rR\R"S)S*9SrSsS=jj5rS"S>S?\R5rU"S@SA\R5rV"SBSC\*5rW\R"5rY\RStSDj5r[SuSEjr\SSSF.SvSGjjr]\RSwSxSHjj5r^\RSwSySIjj5r_SzSJjr`\"SK5raS{S|SLjjrbS}SMjrcS~SNjrdSSOjreSSPjrf\("SQ5rg"SRSS\5rhSSTjriSSUjrjSSVjrkSSWjrl\R"SXS*9SSYj5rmSSSZjjrnSS[jrog)zGeneric utility functions.) annotationsN) GeneratorIterableIteratorMappingSequence)FutureThreadPoolExecutor)AnyCallableLiteralOptionalTypeVarUnioncastoverload)parse) ParamSpec)Retry)schemasc\rSrSrSrSrg)LangSmithError*z=An error occurred while communicating with the LangSmith API.N__name__ __module__ __qualname____firstlineno____doc____static_attributes__rL/home/mande/repo/quber/.venv/lib/python3.13/site-packages/langsmith/utils.pyrr*sGr"rc\rSrSrSrSrg)LangSmithAPIError.z9Internal server error while communicating with LangSmith.rNrrr"r#r%r%.sCr"r%c\rSrSrSrSrg)LangSmithRequestTimeout2z*Client took too long to send request body.rNrrr"r#r(r(2s4r"r(c\rSrSrSrSrg)LangSmithUserError6zAUser error caused an exception when communicating with LangSmith.rNrrr"r#r+r+6sKr"r+c\rSrSrSrSrg)LangSmithRateLimitError:z7You have exceeded the rate limit for the LangSmith API.rNrrr"r#r.r.:sAr"r.c\rSrSrSrSrg)LangSmithAuthError>z-Couldn't authenticate with the LangSmith API.rNrrr"r#r1r1>s7r"r1c\rSrSrSrSrg)LangSmithNotFoundErrorBz%Couldn't find the requested resource.rNrrr"r#r4r4Bs/r"r4c\rSrSrSrSrg)LangSmithConflictErrorFzThe resource already exists.rNrrr"r#r7r7F&r"r7c\rSrSrSrSrg)LangSmithConnectionErrorJz&Couldn't connect to the LangSmith API.rNrrr"r#r;r;J0r"r;c@^\rSrSrSrSU4SjjrSrU=r$)LangSmithExceptionGroupNz%Port of ExceptionGroup for Py < 3.11.c2>[TU]"U0UD6 Xlg)z Initialize.N)super__init__ exceptions)selfrDargskwargs __class__s r#rC LangSmithExceptionGroup.__init__Qs $)&)$r")rD)rFr rDzSequence[Exception]rGr returnNone)rrrrr rCr! __classcell__rHs@r#r?r?Ns0/%%&9%EH% %%r"r?cSUS3$)a Get the error message for an invalid prompt identifier. Used consistently across the codebase when parsing prompt identifiers fails. Args: identifier: The invalid identifier that was provided. Returns: A formatted error message explaining the valid formats. z#Invalid prompt identifier format: "z". Expected one of: - "prompt-name" (for private prompts) - "owner/prompt-name" (for prompts with explicit owner) - "prompt-name:commit-hash" (with commit reference) - "owner/prompt-name:commit-hash" (with owner and commit)r identifiers r#!get_invalid_prompt_identifier_msgrQYs .j\:F Gr"c\rSrSrSrSrg)LangSmithWarningqzBase class for warnings.rNrrr"r#rSrSqs"r"rSc\rSrSrSrSrg)LangSmithMissingAPIKeyWarninguzWarning for missing API key.rNrrr"r#rVrVur9r"rVcSSKJs Jn SSKJnJn U=(d U"5nUSbUS$U"5(agUR b UR $[S[SSS 9S 9nUS :H$) z"Return True if tracing is enabled.rN)get_current_run_treeget_tracing_contextenabledT TRACING_V2TRACINGdefaulttrue)langsmith._internal._context _internal_contextlangsmith.run_helpersrYrZ_GLOBAL_TRACING_ENABLED get_env_var)ctxrdrYrZtc var_results r#tracing_is_enabledrkyst43O %#%B  )} )}''3///\;yRT3UVJ  r"c[SSS9S:H$)z"Return True if testing is enabled. TEST_TRACKINGr^r_falsergrr"r#test_tracking_is_disabledrps  3w >>r"c^SU4SjjnU$)z7Validate specified keyword args are mutually exclusive.cN>^[R"T5SUU4Sjj5nU$)Nc^>^TVs/sHn[U4SjU55PM nn[U5VVs/sHupEUS:wdM UPM nnnU(aAUVs/sHnSRTU5PM nn[SSRU535eT "U0TD6$s snfs snnfs snf)z3Validate exactly one arg in each group is not None.c3P># UHnTRU5cMSv M g7f)N)get).0argrGs r# ?xor_args..decorator..wrapper..sJ#fjjoAAs& &ruz, zFExactly one argument in each of the following groups must be defined: )sum enumeratejoin ValueError) rFrG arg_groupcountsicountinvalid_groupsinvalid_group_names arg_groupsfuncs ` r#wrapper,xor_args..decorator..wrappers ",!+IJJJ!+ 1:&0AP0AHAUaZa0ANPIW&XAtyyA'?#&X  "5679 (( (Q&XsB B$B$B*)rFr rGr rJr ) functoolswraps)rrrs` r# decoratorxor_args..decorators%   )  ) r")rr rJr r)rrs` r#xor_argsrs( r"cTUR5 g![Ra0n[R"[U5UR5UeSnAf[ R a>n[ R "[U5SUR3URUS9UeSnAff=f)z&Raise an error with the response text.Nz: )requestresponse)raise_for_statusrequests HTTPErrorstrtexthttpxHTTPStatusErrorr)res r#raise_for_status_with_textrs !!#   ?  Q7Q>  ##1vhb ($$   s B'+AB')9B""B'c\[U[R5(a UR$U$)zGet the value of a string enum.) isinstanceenumEnumvalue)enus r#get_enum_valuers"#tyy!!yy Jr"ru)maxsizec.[RX5 g)z4Log a message at the specified level, but only once.N)_LOGGERlog)levelmessages r#log_oncers KKr"cU(d [S5eSU;a;SU;a[SUS35eUSSRSS5R5$S U;a[S US 35eUS $) NMessage is empty.lcid*Unexpected format for serialized message: z Message does not have an id.Messager^type&Unexpected format for stored message: z Message does not have a type.)r~replacelowerrs r#_get_message_typers ,-- w w  E C JZV0Dc%J  r"c2Ucg[[U55$)z2Check if the given environment variable is truish.F) is_truishrg)rs r#is_env_var_truishrs } [' ((r") LANGSMITH LANGCHAIN) namespacescgNrnamer`rs r#rgrgs r"cgrrrs r#rgrgs r"dcUVs/sH o3SU3PM nnUH?n[RRU5nUcM'UR5S:wdM=Us $ U$s snf)aRetrieve an environment variable from a list of namespaces. Args: name: The name of the environment variable. default: The default value to return if the environment variable is not found. namespaces: A tuple of namespaces to search for the environment variable. Defaults to `('LANGSMITH', 'LANGCHAINs')`. Returns: The value of the environment variable if found, otherwise the default value. _r^)osenvironrvstrip)rr`r namespacenamesrs r#rgrgsb&5? ?Jy{!D6 "JE ? t$  "!4L N @sAc t[RRS[S[SU(aSOSS9S95$)z,Get the project name for a LangSmith tracer.HOSTED_LANGSERVE_PROJECT_NAMEPROJECTSESSIONr`Nr_)rrrvrg)return_default_values r#get_tracer_projectrs= ::>> (  0D9$   r"c>^\rSrSrSrSSU4SjjjrSSjrSrU=r$) FilterPoolFullWarningizGFilter `urllib3` warnings logged when the connection pool isn't reused.c0>[TU]U5 X lg)zInitialize the `FilterPoolFullWarning` filter. Args: name: The name of the filter. Defaults to `""`. host: The host to filter. Defaults to `""`. N)rBrC_host)rErhostrHs r#rCFilterPoolFullWarning.__init__s  r"cNUR5nSU;agURU;$)zJurllib3.connectionpool:Connection pool is full, discarding connection: ...z.Connection pool is full, discarding connectionT) getMessagerrErecordmsgs r#filterFilterPoolFullWarning.filters*! ;3 Fzz$$r")r)r^r^)rrrrrJrKrJbool) rrrrr rCr r!rLrMs@r#rrsQ%%r"rc"\rSrSrSrSSjrSrg)FilterLangSmithRetryiz!Filter for retries from this lib.c,UR5nSU;$)z!Filter retries from this library.LangSmithRetry)rr s r#r FilterLangSmithRetry.filters!s**r"rNr)rrrrr r r!rr"r#rrs ++r"rc\rSrSrSrSrg)riz&Wrapper to filter logs with this name.rNrrr"r#rrr=r"rc## [ UHnURU5 M SSS5 Sv [ UHnURU5 M SSS5 g!,(df  N>=f![a [R S5 MUf=f!,(df  g=f![ UH;nURU5 M![a [R S5 M9f=f SSS5 f!,(df  f=f=f7f)zTemporarily adds specified filters to a logger. Parameters: - logger: The logger to which the filters will be added. - filters: A sequence of `logging.Filter` objects to be temporarily added to the logger. NzFailed to remove filter) _FILTER_LOCK addFilter removeFilter BaseExceptionrwarning)loggerfiltersr s r# filter_logsrs F   V $ ? !?''/"\ %?OO$=>? \\!?''/$?OO$=>?"\\sD AD B$D BA-B D  A*&D -B BBB B!D $D+C62CC6C( $C6'C( (C6- D6 D DD c UbU$[SSS9$)zGet the testing cache directory. Args: cache: The cache path. Returns: The cache path if provided, otherwise the value from the `LANGSMITH_TEST_CACHE` environment variable. N TEST_CACHEr_ro)caches r# get_cache_dirr"s  |T 22r" ignore_hosts allow_hostsc2^^U(a[U4SjU55(agU(aT[R"TR5nUR =(d Sm[UU4SjU55nU(dg0TlT$![a gf=f)zAFilter request headers based on `ignore_hosts` and `allow_hosts`.c3Z># UH nTRRU5v M" g7fr)url startswith)rwrrs r#ry)filter_request_headers..(s#R\TGKK22488\s(+Nr^c3># UHVnURS5(aTRRU5OTU:H=(d TRSU35v MX g7f))zhttp://zhttps://rN)r)r(endswith)rwrr request_hosts r#ryr*3sa  $??#:;; &&t,!T)N\-B-BQtf:-NO$sAA!)any urllib_parseurlparser( Exceptionhostnameheaders)rr$r% parsed_url host_matchesr-s` @r#filter_request_headersr6 sR\RRR %..w{{;J"**0b   $   GO N'  s B BBc #^^# SSKnSSKJn UR 5 [ R RU5upVURURS5(dURS5(aSOSUS /S QS S /UU4S jS9nURU5 Sv SSS5 g![a [S5ef=f!,(df  g=f7f)Use a cache for requests.rNzNvcrpy is required to use caching. Install with:pip install -U "langsmith[vcr]")_patchz.yamlz.ymlyamljson new_episodes)urimethodpathbody authorizationz Set-Cookiec>[UTTS9$)Nr#)r6)rr%r$s r#with_cache..es.D ,K/ r") serializercassette_library_dir record_modematch_onfilter_headersbefore_record_request) vcr ImportErrorlangsmith._internalr9 patch_urllib3rr?splitVCRr, use_cassette)r?r$r%rKrN cache_dir cache_filels_vcrs `` r# with_cacherUDs <!GGMM$/I WW""7++z/B/B6/J/J &#2'6 F   Z (  ) (9   .   8 ) (s4CB+BCC" C+CC CCc#p# Ub[XU5 Sv SSS5 gSv g!,(df  g=f7f)r8N)rU)r?r$r%s r#with_optional_cacherWms/  K 8 9 8 9 8s6%6 36c[R"[R"56nUVs/sH nSU;dM UPM nnSR U5$s snf)Nz langsmith/r^) tracebackformat_exceptionsysexc_infor})tb_lineslinefiltered_liness r# _format_excr`{sH))3<<>:H'/Lxt ""Ms AATc ^^^[U5n[USS5nUb U"T5$TT:aU$[U[5(aDUR 5VVs0sH&upg[ UTTTS-5[ UTTTS-5_M( snn$[U[5(a"UVs/sHn[ UTTTS-5PM sn$[U[5(a[UUU4SjU55$[U[5(a"UVs1sHn[ UTTTS-5iM sn$U$![a GN f=fs snnfs snfs snf)N __deepcopy__ruc3F># UHn[UTTTS-5v M g7f)ruN) _middle_copy)rwitem_depth max_depthmemos r#ry_middle_copy..s%UQT\$i!DDQTs!) rrrrritemsrelisttupleset) valrirhrgclscopierkvrfs ``` r#reresO s)C S.$ /F  $<  #t   $ D)VaZ 8,4FQJ; $   #tLOPCD T4FQJ?CPP#uUQTUUU#sLOPCD T4FQJ?CPP J%     QQs#D%-D6"D<E% D32D3c0n[R"X5$![a4n[R S[ U55 [ X5sSnA$SnAff=f)zDeep copy a value with a compromise for uncopyable objects. Args: val: The value to be deep copied. Returns: The deep copied value. zFailed to deepcopy input: %sN)copydeepcopyrrdebugreprre)rorirs r# deepish_copyrysMD'}}S'' '  4d1g>C&& 's A)A AAcZSSKJn URU5nURU5nX4:$)zGCheck if the current version is greater or equal to the target version.r)version) packagingr{r)current_versiontarget_versionr{currenttargets r#is_version_greater_or_equalrs*!mmO,G ]]> *F  r"cU(aAURS5S:d,URS5(dURS5(a[[ U55eUR SS5nUSn[ U5S:aUSOSnSU;a:UR SS5upEU(aU(d[[ U55eXEU4$U(d[[ U55eSX#4$)aParse a string in the format of `owner/name:hash`, `name:hash`, `owner/name`, or `name`. Args: identifier: The prompt identifier to parse. Returns: A tuple containing `(owner, name, hash)`. Raises: ValueError: If the identifier doesn't match the expected formats. /ru:rlatest-)rr)r,r~rQrOr)rPparts owner_namecommitownerrs r#parse_prompt_identifierrs    C 1 $   % %   s # #::FGG   S! $EqJUaU1XXF j &&sA. D>zJK KF"">zJK KJ&&r"c[U5$)aGParse a hub repo identifier (``owner/name:hash``, ``name``, etc.). Agents, skills, and prompts share the same identifier grammar on Hub. Args: identifier: The hub identifier to parse. Returns: A tuple containing ``(owner, name, hash)``. Raises: ValueError: If the identifier doesn't match the expected formats. )rrOs r#parse_hub_identifierrs #: ..r"Pcl^\rSrSrSrS U4SjjrSSS.S U4SjjjrSrU=r$) ContextThreadPoolExecutoriz?ThreadPoolExecutor that copies the context to the child thread.c >[TU][[S[4[ R "[R"5RU/UQ70UD655$)a Submit a function to the executor. Args: func (Callable[..., T]): The function to submit. *args (Any): The positional arguments to the function. **kwargs (Any): The keyword arguments to the function. Returns: Future[T]: The future for the function. .) rBsubmitrr rarpartial contextvars copy_contextrun)rErrFrGrHs r#r ContextThreadPoolExecutor.submits\ w~ a !!,,.22D;?CI   r"Nrutimeout chunksizec>^^[[US55Vs/sHn[R"5PM snmSUU4Sjjn[TU]"U/UQ7UUS.6$s snf)aAReturn an iterator equivalent to stdlib map. Each function will receive its own copy of the context from the parent thread. Args: fn: A callable that will take as many arguments as there are passed iterables. timeout: The maximum number of seconds to wait. If None, then there is no limit on the wait time. chunksize: The size of the chunks the iterable will be broken into before being passed to a child process. This argument is only used by ProcessPoolExecutor; it is ignored by ThreadPoolExecutor. Returns: An iterator equivalent to: map(func, *iterables) but the calls may be evaluated out-of-order. Raises: TimeoutError: If the entire result iterator could not be generated before the given timeout. Exception: If fn(*args) raises for any values. rcF>TR5R"T/UQ76$r)popr)rFcontextsfns r# _wrapped_fn2ContextThreadPoolExecutor.map.._wrapped_fn4s<<>%%b040 0r"r)rFr rJra)rangerrrrBmap) rErrr iterablesrrrrHs ` @r#rContextThreadPoolExecutor.mapsm<9>c)A,>O8PQ8P1K,,.8PQ 1 1w{      RsAr)rzCallable[P, T]rFzP.argsrGzP.kwargsrJz Future[T]) rzCallable[..., T]rz Iterable[Any]rzOptional[float]rintrJz Iterator[T]) rrrrr rrr!rLrMs@r#rrssI       :$( ( ( "( ! (  (  ( ( r"rcU=(d [[[SSS95nUR5(d [ S5eUR5RS5RS5R S5$)zBGet the LangSmith API URL from the environment or the given value.ENDPOINTzhttps://api.smith.langchain.comr_z!LangSmith API URL cannot be empty"'r)rrrgrr+rstrip)api_url_api_urls r# get_api_urlr?sm$  5 H >>   !DEE >>  ! !# & , ,S 1 8 8 ==r"cUbUO [SSS9nUbUR5(dgUR5RS5RS5$)z8Get the API key from the environment or the given value.NAPI_KEYr_rrrgr)api_keyapi_key_s r# get_api_keyrMsN!-w;yRV3WHx~~// >>  ! !# & , ,S 11r"cUbUO [SSS9nUbUR5(dgUR5RS5RS5$)zGet workspace ID.N WORKSPACE_IDr_rrr) workspace_id workspace_id_s r#get_workspace_idrUs\  #   6 M$7$7$9$9    & &s + 1 1# 66r"c2[R"U5RRS5Sn[R "U5nUS:H=(d) UR S5=(d UR S5$![Ra gf=f)zCheck if the URL is localhost. Parameters ---------- url : str The URL to check. Returns: ------- bool True if the URL is localhost, False otherwise. rrz 127.0.0.1z0.0.0.0z::F)r/urlsplitnetlocrOsocket gethostbynamer)gaierror)r(rips r# _is_localhostrasz&&s+2288=a@  ! !& )[ SBMM)$<S d@SS ??sArs "    LL9   ) '+   H %HYHDD5n5LLBnB880^0'^'1~1%n%0#{#'$4' 0? 4 6     Q   &&8P&9:L2 $ Q 4 $) 3        3        S!"3      "4 Q &%GNN%*+7>>+1U1  ? ?%=? ??2 3$-1+/ ! !*!) !  !H -1+/% "%)%)%! %%P -1+/  , ) ) !  # CLEF  -0>A<'* 'F/"cND 2D N >2 7* Q 8$ r"