=Ki2%SrSSKJr SSKrSSKrSSKrSSKrSSKrSSKrSSK r SSK r SSK J r J r JrJrJrJrJr SSKJr SSKJrJrJrJrJrJrJrJrJrJrJrJ r J!r!J"r"J#r# SSK$J%r%J&r&J'r'J(r( SSK)J*s J+r+ SSK,J-r. SS K,J/r/J0r0J1r1 SS K2J3r4 SS K5J6r6 SS K7J8r8 \(a SS K9J:r: SSK;J5r?\+R\+R\+R\+R\+R\+R\/R\/RS.rHS\IS'SrJSqKS\IS'SXSjrL\RSYSj5rNSZSjrOS[S\SjjrP\RSSSSSSSSS.S]Sjj5rQ\LrRS^SjrSSSSSSSSSSS. S_SjjrTS`SjrU"SS \S!S"9rV\"S#S$S%9rW\%"S&5rX\#"S'S(\\\X\W455rYSS).SaS*jjrZ\"SbS+j5r[\"ScSSSSSSSSSSS!SSS,. SdS-jjj5r[SeS.jr["S/S05r\SfS1jr]SgS2jr^1S3kr_"S4S5\S!S"9r`"S6S7\S!S"9raShS8jrbSiSjS9jjrcSkS:jrdS[SlS;jjreSmSnS<jjrfSmSoS=jjrgSpS>jrhSqS?jriSqS@jrjS[SrSAjjrkS[SsSBjjrl\R"SCSD9S[SsSEjj5rnS[SsSFjjroSSG.StSHjjrpS[SuSIjjrqS[SvSJjjrrSSK.SwSLjjrs\"SM5rt"SNSO\\t5ru"SPSQ\u\\t5rv"SRSS\u\\t5rwSxSTjrxSySUjrySzSVjrzS{SWjr{\+RrA\+RrB\+RrC\+RrD\+RrE\+Rr@g)|z1Decorator for creating a run tree from functions.) annotationsN)AsyncGenerator AsyncIterator Awaitable GeneratorIteratorMappingSequence) copy_context) TYPE_CHECKING AnnotatedAnyCallableGenericLiteralOptionalProtocol TypedDictTypeVarUnioncastget_type_hintsoverloadruntime_checkable) ParamSpec TypeGuardget_args get_originclient) run_treesschemasutils)_aiter) _runtime_env) WriteReplica) TracebackType)Runnableparent project_nametagsmetadataenabledr replicasdistributed_parent_idz!dict[str, contextvars.ContextVar] _CONTEXT_KEYSzlangsmith/run_helpers.pyOptional[bool]_OTEL_AVAILABLEc>[RR5$)zGet the current run tree.)_context_PARENT_RUN_TREEgetW/var/www/html/dynamic-report/venv/lib/python3.13/site-packages/langsmith/run_helpers.pyget_current_run_treer;Hs  $ $ ( ( **r9c## [RRU5nSv [RRU5 g![RRU5 f=f7f)aqSet a RunTree as the active tracing parent within this block. Unlike `tracing_context`, this only sets `_PARENT_RUN_TREE` and nothing else, making it safe to use in isolated threads where you want precise control over which run acts as the parent without inheriting or overwriting other context variables. Args: run_tree: The RunTree to use as the active parent. N)r5r6setreset)run_treetokens r:set_tracing_parentrAMsM  % % ) )( 3E/ !!''.!!''.s A+A A+!A((A+c [5nUc[RS5 gURR U5 g)z(Update metadata on the current run tree.NzFNo active run tree found. Call `set_run_metadata` inside a traced run.)r;LOGGERwarningr-update)r-r?s r:set_run_metadatarFbs=#%H T     * r9c ZUc[RR5[RR5[RR5[R R5[R R5[RR5[RR5[RR5S.$[R5VVs0sHupXRU5_M snn$s snnf)z Get the current tracing context.r)) r5r6r7 _PROJECT_NAME_TAGS _METADATA_TRACING_ENABLED_CLIENTr! _REPLICAS_DISTRIBUTED_PARENT_IDr1items)contextkvs r:get_tracing_contextrSns//335$22668NN&&( **..000446&&**,!++//1%.%E%E%I%I%K  +8*=*=*? @*?$!A{{1~ *? @@ @sD')r+r,r-r*r.r r/r0c +*# U(a[R"SUS3[5 [5n USLa%[ SU=(d UR S505OSn Un U cdU ba[ [U=(d /5[U R=(d /5-5n0U REU=(d 0EnU Rn UbUOU R S5n[U UUUUUUU S.5 Sv [U 5 g![U 5 f=f7f) aSet the tracing context for a block of code. Args: project_name: The name of the project to log the run to. tags: The tags to add to the run. metadata: The metadata to add to the run. parent: The parent run to use for the context. Can be a Run/`RunTree` object, request headers (for distributed tracing), or the dotted order string. client: The client to use for logging the run to LangSmith. enabled: Whether tracing is enabled. Defaults to `None`, meaning it will use the current context value or environment variables. replicas: A sequence of `WriteReplica` dictionaries to send runs to. Example: `[{"api_url": "https://api.example.com", "auth": {"api_key": "key"}, "project_name": "proj"}]` or `[{"project_name": "my_experiment", "updates": {"reference_example_id": None}}]` distributed_parent_id: The distributed parent ID for distributed tracing. Defaults to None. z Unrecognized keyword arguments: .Fr* parent_runNr.r)) warningswarnDeprecationWarningrS_get_parent_runr7sortedr=r,r-id_set_tracing_context) r+r,r-r*r.r r/r0kwargscurrent_contextrVdistributed_parent_id_to_uses r:tracing_contextrasB .vha 8  *+O   6#EVZZ -EFG  $9 #+ 0Fc$*"oJOO,Ar(BBC>j))>hn">'1}}$ ,g/2E2Ei2PG (  %A  . _-_-sC0D3D7 D DDc[U5=(de [U[R5=(a [UR5=(d( [ US5=(a [UR 5$)z.Check if a function is `@traceable` decorated.__call__)_is_traceable_function isinstance functoolspartialfunchasattrrcrhs r:is_traceable_functionrksU t$ Q tY.. / U4J4994U Q D* % O*@*Or9 namer-r,r reduce_fnr+process_inputsprocess_outputs process_chunkc T[U5(aU$[UUUUUUUUU S9 "U5$)z$Ensure that a function is traceable.rl)rk traceable) rhrmr-r,r rnr+rorprqs r:ensure_traceablertsFT""   !%'#    r9c[R"U5=(d3 [US5=(a [R"UR5$)z;Inspect function or wrapped function to see if it is async. __wrapped__)inspectiscoroutinefunctionrirvrjs r:is_asyncrys:  & &t , m$V)D)DTEUEU)Vr9c\rSrSr%SrS\S'S\S'S\S'S \S 'S \S 'S\S 'S\S'S\S'S\S'S\S'S\S'S\S'Srg)LangSmithExtraz> 88Qr9r{F)totalRT) covariantPc8\rSrSrSrSS.SSjjrSrg)SupportsLangsmithExtraizNImplementations of this Protocol accept an optional langsmith_extra parameter.Nlangsmith_extracg)a*Call the instance when it is called as a function. Args: *args: Variable length argument list. langsmith_extra: Optional dictionary containing additional parameters specific to Langsmith. **kwargs: Arbitrary keyword arguments. Returns: R: The return value of the method. Nr8)selfrargsr^s r:rcSupportsLangsmithExtra.__call__s$ r9r8)rzP.argsrOptional[LangSmithExtra]r^zP.kwargsreturnr)rrrrrrcrr8r9r:rrs:X 59  2     r9routputsc UR=(d 0RS5nU=(d 0RS5=(d U$)Nusage_metadata)r-r7)r?rr^ from_metadatas r:_extract_usager1s; &&,"112BCM Mr  / 0 AMAr9cgNr8rjs r:rsrs;s$'r9) rmr-r,r rnr+rorprq_invocation_params_fndangerously_allow_filesystemr.exceptions_to_handlec grr8)run_typermr-r,r rnr+rorprqrrr.rs r:rsrsAs "@Cr9c^^^^^^[[RU(a[US[5(aUSOUR SS5=(d S5mT[ ;a$[R"STS[ STS35 [U5S :a[R"S 5 S U;a[R"S [5 UR S S5mUR SS5m[UR S S5UR SS5UR SS5UR SS5UR SS5UR SS5TUR SS5UR SS5UR SS5UR SS5TUR SS5S9 mUR SS5m[R"[TS9mU(a6[R"S[UR!55S3[5 S UUUUUU4Sjjn[U5S :Xa%[#US5(aU(d U"US5$U$)!a+Trace a function with langsmith. Args: run_type: The type of run (span) to create. Examples: `llm`, `chain`, `tool`, `prompt`, `retriever`, etc. Defaults to "chain". name: The name of the run. Defaults to the function name. metadata: The metadata to add to the run. Defaults to `None`. tags: The tags to add to the run. Defaults to `None`. client: The client to use for logging the run to LangSmith. Defaults to `None`, which will use the default client. reduce_fn: A function to reduce the output of the function if the function returns a generator. Defaults to `None`, which means the values will be logged as a list. !!! note If the iterator is never exhausted (e.g. the function returns an infinite generator), this will never be called, and the run itself will be stuck in a pending state. project_name: The name of the project to log the run to. Defaults to `None`, which will use the default project. process_inputs: Custom serialization / processing function for inputs. Defaults to `None`. process_outputs: Custom serialization / processing function for outputs. Defaults to `None`. dangerously_allow_filesystem: Whether to allow filesystem access for attachments. Defaults to `False`. Traces that reference local filepaths will be uploaded to LangSmith. In general, network-hosted applications should not be using this because referenced files are usually on the user's machine, not the host machine. enabled: Whether tracing is enabled for this function. Defaults to `None`, which will use the default value from the current context. exceptions_to_handle: Exception types to ignore when logging errors. If an exception of one of these types is raised, the run will still be recorded but the error field will be `None` instead of containing the full traceback. Defaults to `None`. Returns: The decorated function. !!! note Requires that `LANGSMITH_TRACING_V2` be set to 'true' in the environment. Examples: !!! example "Basic usage" ```python @traceable def my_function(x: float, y: float) -> float: return x + y my_function(5, 6) @traceable async def my_async_function(query_params: dict) -> dict: async with httpx.AsyncClient() as http_client: response = await http_client.get( "https://api.example.com/data", params=query_params, ) return response.json() asyncio.run(my_async_function({"param": "value"})) ``` !!! example "Streaming data with a generator" ```python @traceable def my_generator(n: int) -> Iterable: for i in range(n): yield i for item in my_generator(5): print(item) ``` !!! example "Async streaming data" ```python @traceable async def my_async_generator(query_params: dict) -> Iterable: async with httpx.AsyncClient() as http_client: response = await http_client.get( "https://api.example.com/data", params=query_params, ) for item in response.json(): yield item async def async_code(): async for item in my_async_generator({"param": "value"}): print(item) asyncio.run(async_code()) ``` !!! example "Specifying a run type and name" ```python @traceable(name="CustomName", run_type="tool") def another_function(a: float, b: float) -> float: return a * b another_function(5, 6) ``` !!! example "Logging with custom metadata and tags" ```python @traceable( metadata={"version": "1.0", "author": "John Doe"}, tags=["beta", "test"] ) def tagged_function(x): return x**2 tagged_function(5) ``` !!! example "Specifying a custom client and project name" ```python custom_client = Client(api_key="your_api_key") @traceable(client=custom_client, project_name="My Special Project") def project_specific_function(data): return data project_specific_function({"data": "to process"}) ``` !!! example "Manually passing `langsmith_extra`" ```python @traceable def manual_extra_function(x): return x**2 manual_extra_function(5, langsmith_extra={"metadata": {"version": "1.0"}}) ``` !!! example "Handling specific exceptions" ```python @traceable(exceptions_to_handle=(ValueError, TypeError)) def function_with_handled_exceptions(x): if x < 0: raise ValueError("Negative value") # Won't send error in the trace return x**2 function_with_handled_exceptions(-5) ``` rrNchainzUnrecognized run_type: z. Must be one of: z . Did you mean @traceable(name='z')?zThe `traceable()` decorator only accepts one positional argument, which should be the run_type. All other arguments should be passed as keyword arguments.extrazJThe `extra` keyword argument is deprecated. Please use `metadata` instead.rnr.rmr-r,r r+rorqrrFr) extra_outerrmr-r,r r+rrorqinvocation_params_fnrr.rrp)outputs_processorzHThe following keyword arguments are not recognized and will be ignored: rUc >^^ ^ [R"T5nURRSS5SLm URRSS5SLm [R "T5SS.SU U UU U 4Sjjj5n[R "T5SS.SU U UU U U4Sjjj5n[R "T5SS.SU U UU 4Sjjj5n[R "T5SS.SU U UU UU4Sjjj5n[R "T5SS.SU U UU U U4Sjjj5n[R "T5SS.SU U UU U U4S jjj5n[R "T5(aUnOG[R"T5(aUnO)[T5(a T(aUnOUnO T(aUnOUn[US S 5 [US T RS 5TTT RS5T RS5TS.5 [R"U5n U RRS5(dU R/SU RR55Q[R"S[RRSS9PSU RR55QS9n XlU$)Nr?configrc >^^^ # T (dTRSS5 [R"[T T UTTS9IShvN n[R"5nT(aUSTS'[ US5m T (afUU UU 4SjnU(a&[ R"U"5USS9IShvN nO[S 0[US5D6 U"5IShvN nSSS5 OYT "T0TD6nU(a [ R"XsSS9IShvN nO*[S 0[US5D6 UIShvN nSSS5 [R"T UWS 9IShvN U$GNNN!,(df  N5=fNgNF!,(df  NJ=f![aCn[U5 [ R"[R"T X8S 95IShvN eSnAff=fN7f) z"Async version of wrapper function.rNcontainer_inputrrr^new_runr?cj># T T"T0TD6IShvN sSSS5 $N !,(df  g=f7frr8rrhr^otel_context_managersr:run_with_otel_contextRtraceable..decorator..async_wrapper..run_with_otel_contextds,1)-t)>v)>#>21#>21s 3 " " 3" 03rPrPerrorrr8) pop aitertools aio_to_thread _setup_runasyncio_accepts_context_maybe_create_otel_contextasyncio create_taskrarS BaseException_cleanup_tracebackshield)rrr^ run_containeraccepts_contextrfunction_resultfr_coroer _on_run_endrrhfunc_accepts_configfunc_accepts_parent_runs `` @r: async_wrapper3traceable..decorator..async_wrapperHs' 8T*",":": / / #M* ","D"D"F*)6y)AF:&'A!),($(??'070C0C13]9=U1+ -1- 2JK5J4K.KO #D3F3G&070C0C#9-E1+ -1- 2JK5GGG!F #E%% E3/F 2G3F 8E:: FF GF G7G G GGGc ># T (dURSS5 [R"[T T UUUS9IShvN n/nT(aUSUS'[ US5nT "U0UD6n[R "5n[ R"U5(aQU(a [R"XcSS9IShvN nO*[S 0[US5D6 UIShvN nSSS5 [UUUS(aUSRS:HOSUUT RS 5US 9ShvN nU7v MNN{NZ!,(df  N^=fN" O\![aOn [!U 5 [R""[R"T UU [%UT5S 95IShvN eSn A ff=f[R"T U[%UT5S 9IShvN g7f)Nrrrr?rPrllmFrq) generatorr is_llm_runrresultsrqrrrrr8)rrrrrrrw iscoroutinerrrarS_process_async_iteratorrr7rrr_get_function_result)rrr^rrrasync_gen_resultritemrrrrhrrrns r:async_generator_wrapper=traceable..decorator..async_generator_wrappers' 8T*",":": / / #M"$G2 *)6y)AF:& (B!),($$(#8#8 ","D"D"F&&'788&181D1D,I6N2,( -1- 2JK6F/E, #:."/)3&i099UB"$3#"1"5"5o"F)= # $Ja2,0F  #! "1%nn,,#% 4Wi H  **,Wi@  s:GD5GA6E;D7<ED;D9D;#AE%E)E *E-E5G7E9D;; E E EEG F)AF$F F$$F))&GGGc>^^^T (dTRSS5 [T T UTTS9n[R"T 5RR SS5SLnU(aUSTS'[ US5mT(aUU UU4SjnUSRU5nOUSR"T /TQ70TD6nT "X6S 9 U$![an[U5 T "X7S9 eSnAff=f) >Create a new run or create_child() if run is passed in kwargs.rNrr?rcN>T T"T0TD6sSSS5 $!,(df  g=frr8rsr:rLtraceable..decorator..wrapper..run_with_otel_contexts1#'#8#8211s $rPrr) rrrw signature parametersr7rrunrr) rrr^rrrrrrrrrhrs `` @r:wrapper-traceable..decorator..wrappers' 8T*& / / M!!$'2266z4HPTT $ *)6y)AF:&'A!),($(99'4I&>&B&B-'O'4I&>&B&B'#''-'O  ?" " ! "1%M3 sAC C C# CC#c ?4># T (dURSS5 [T T UUUS9n[R"T 5RR SS5SLn/nSnU(aUSUS'USR "T /UQ70UD6n[US5n[UUTS:HUT R S5US9ShvN nUbURU5 T "U[UT5S 9 U$N+![a#n [U 5 T "UU [UT5S 9 eSn A ff=f7f) Nrrr?rrPrrq)rrrqrrr) rrrwrrr7rr_process_iteratorappendrrr)rrr^rrrfunction_returngenerator_resultrrrrrhrrnrs r:generator_wrapper7traceable..decorator..generator_wrappersR' 8T*& / / M!!$'2266z4HPTT $"$G#'O *)6y)AF:�#;#?#?#Vt#Vv#V 'A!),($.?$!'50#"1"5"5o"F)= .##.NN?3  /CGY/W X" "-#! "1%!0)D  s=AD!AC(:C&;C(D&C(( D2DDDcn>T (dURSS5 [TTUUUS9nT (aUSUS'USR"T/UQ70UD6n[ US5(a [ XCT 5$[ US5(a [XCT 5$T"X4S 9 U$![an[ U5 T"X5S9 eSnAff=f) Nrrrr?rPr__iter__ __aiter__r)rrr Exceptionrri _TracedStream_TracedAsyncStream rrr^trace_containerstreamrrrrhrrrns r:stream_wrapper4traceable..decorator..stream_wrapper8s' 8T*( / / O *)8)CF:&(377NtNvN vz**$ViHH--)&9MM  8M "1%O5 s(B B4B//B4c ># T (dURSS5 [R"[TTUUUS9IShvN nT (aUSUS'T"U0UD6IShvN n[ US5(a [ XCT 5$[ US5(a [XCT 5$[R"TX4S9IShvN U$N}N_![a$n[R"TX5S9IShvN eSnAff=fN;7f) Nrrrr?rrrr)rrrrrrirrrs r:async_stream_wrapper:traceable..decorator..async_stream_wrapperYs' 8T*$.$<$< / / %O *)8)CF:&#T4V44 v{++)&9MM,,$ViHH**;X X XM35  ..{OUUU  Ys^:C2B;C2B?B=B?"AC24C05C2=B?? C- C(!C$"C((C--C2__langsmith_traceable__T__traceable_config__ror,r-)rorpr.r,r-wrappedc3z# UH1nUR[RR:wdM-Uv M3 g7frkindrw Parameter VAR_KEYWORD.0params r: /traceable..decorator..1%.decoratorCse$$T*"*"5"5"9"9*d"KSW"W&1155hETQ  9=? #? #5? #? # ? #? # ? #B  DHE E )AE TWE  E E  E N  9=+ #+ #5+ #+ # + #+ # + #Z  DH2 #2 #)A2 #TW2 # 2 #2 # 2 #n  DH  )A TW      @  DH  )A TW      @  % %d + +)@   ( ( . .0  d^^#7 #0 #1 #*  ";TB  ""1"5"56F"G#4"'++F3+// ;    01~~!!(++++%(^^%:%:%< %% '"3"3"@"@$ %(^^%:%:%<C".1 *r9)rhr)r ls_client RUN_TYPE_Trestrr_VALID_RUN_TYPESrWrXlenrY_ContainerInputrfrg_handle_container_endr[keyscallable) rr^rrrr.rrnrs @@@@@@r:rsrsUs(l 47C00 G**Z.9' H'' %hZ/ABRAST..6Zs <  4y1}  $ &     ;-IjjD)G%JJw- ZZ %J- ZZ %zz(D)ZZ5zz"2D9jj$7#ZZ(?F%+ZZ0NPU%V#ZZ(>EO  #4d;##+K  Vfkkm$%Q (  f f T  4yA~(47++Fa!! r9c \rSrSrSrS SSSSSSSSSSSS. SSjjjrSSjrSSjrSSjrSSS jjr SS jr SSS jjr S r g)traceia^Manage a LangSmith run in context. This class can be used as both a synchronous and asynchronous context manager. Args: name: Name of the run. run_type: Type of run (e.g., `'chain'`, `'llm'`, `'tool'`). inputs: Initial input data for the run. project_name: Project name to associate the run with. parent: Parent run. Can be a `RunTree`, dotted order string, or tracing headers. tags: List of tags for the run. metadata: Additional metadata for the run. client: LangSmith client for custom settings. run_id: Preset identifier for the run. reference_example_id: Associates run with a dataset example. Only for root runs in evaluation. exceptions_to_handle: Exception types to ignore. extra: Extra data to send to LangSmith. Use 'metadata' instead. Examples: Synchronous usage: ```python with trace("My Operation", run_type="tool", tags=["important"]) as run: result = "foo" # Perform operation run.metadata["some-key"] = "some-value" run.end(outputs={"result": result}) ``` Asynchronous usage: ```python async def main(): async with trace("Async Operation", run_type="tool", tags=["async"]) as run: result = "foo" # Await async operation run.metadata["some-key"] = "some-value" # "end" just adds the outputs and sets error to None # The actual patching of the run happens when the context exits run.end(outputs={"result": result}) asyncio.run(main()) ``` Handling specific exceptions: ```python import pytest import sys with trace("Test", exceptions_to_handle=(pytest.skip.Exception,)): if sys.platform == "win32": # Just an example pytest.skip("Skipping test for windows") result = "foo" # Perform test operation ``` N) inputsrr+r*r,r-r rrr attachmentsc  URSS5UlU(a6[R"S[ UR 55S3[ 5 XlX lX0l Xl X@l XPl X`l URS5UlXplXlXlXlXlXlSUlSUlg)zOInitialize the trace context manager. Warns if unsupported kwargs are passed. _end_on_exitTzEThe `trace` context manager no longer supports the following kwargs: rUr?N)rr.rWrXr[r'rYrmrr+r,rr+r*r7r?r,r-r rrrrold_ctx)rrmrr+rr+r*r,r-r rrrr,r^s r:__init__trace.__init__s0#JJ~t<  MMW&++-(),"     & (  :.     $8!$8!48 '+ r9c[5Ul[R"UR5n[R R 5=(d [Rn[RR 5=(d [RnUR=(d URR S5n[URURUURS.5n[[!UR"=(d /U=(d /-55n0UR$=(d 0EU=(d 0ESS0EnUR&=(d 0nXxS'[)UR5n UbTU(aMUR+UR,UR.UR0UUR2UUR4S9UlO[8R:"UR,[<R>"UR.5[<R>"UR@SS9UR0UU =(d S [8RBR 5UR2=(d 0UUUR4=(d 0S 9 UlUSLaUR6RE5 U(a[R R!U5 [RR!U5 [RFR!UR65 [RHR!U 5 [RJR!U5 UR6$) a-Set up the tracing context and create a new run. This method initializes the tracing context, merges tags and metadata, creates a new run (either as a child of an existing run or as a new root run), and sets up the necessary context variables. Returns: run_trees.RunTree: The newly created run. r )r*r?r r+ ls_methodr*r-)rmrrrr+r,r,T accept_nullr) rmr\rrrr+r/r+r,r r,)&rSr/r#tracing_is_enabledr5rIr7 _GLOBAL_TAGSrJ_GLOBAL_METADATAr rZr*r?r+r[r=r,r-r_get_project_name create_childrmrrr+r,rr!RunTreer  _ensure_uuidrrMpostr6rHrL) rr. outer_tagsouter_metadataclient_ parent_run_tags_r-r project_name_s r:_setup trace._setup$s+, **4<<8^^'')BX-B-B !++//1NX5N5N++;!1!1(!;%++ MM! $ 1 1   sDIIO 0@bABC }}" #    jj&B "*J)$*;*;<  "w&33YY{{!{{ ,,4DL%,,YY))$++6%.%;%;--4&!*7i",,002{{(b ,,2DL d? LL     NN  u %    " "8 ,  % % ) )$,, 7  " " & &} 5     )||r9cURcgUb.[X R5nURRUS9 URbf[ R "UR5nUSLa+UR(aURR5 [UR5 g[R"S[5 g)aClean up the tracing context and finalize the run. This method handles exceptions, ends the run if necessary, patches the run if it's not disabled, and resets the tracing context. Args: exc_type: The type of the exception that occurred, if any. exc_value: The exception instance that occurred, if any. traceback: The traceback object associated with the exception, if any. NrTz(Tracing context was not set up properly.) r'_format_error_with_exceptions_to_handlerendr/r#r6r.patchr]rWrXRuntimeWarning)rexc_type exc_value tracebacktbr.s r: _teardowntrace._teardownos <<    844B LL  2  & << #..t||>> @traceable ... def my_function(input_data): ... # Function implementation ... pass >>> runnable = as_runnable(my_function) r)RunnableConfigRunnableLambda)InputOutputzjas_runnable requires langchain-core to be installed. You can install it with `pip install langchain-core`.NzzRas_runnable expects a function wrapped by the LangSmith @traceable decorator. Got z defined as: c>^\rSrSrSrSSUUU4Sjjjr\S UUU4Sjj5r\S UUU4Sjj5rSr U=r $) &as_runnable..RunnableTraceableizyConverts a `@traceable` decorated function to a `Runnable`. This helps maintain a consistent LangSmith tracing context. c >SnURU5n[U5(a4Ub [S5e[[T/T4URU55nO5[ U5(a%[[T/T4UR U55nUc$[URRSU35e[TU]-U[[[T/[T4U55 g)NzFunc was provided as a coroutine function, but afunc was also provided. If providing both, func should be a regular function to avoid ambiguity.zG expects a function wrapped by the LangSmith @traceable decorator. Got ) _wrap_asyncry TypeErrorrrrk _wrap_sync ValueError __class__rsuperr0rr)rrhafuncrawrappedrrrsr{s r:r0/as_runnable..RunnableTraceable.__init__ s <@G''.H~~'#7 x8$:J:J4:PQ&t,,x8$//$:OP ~~../02269 G Xugy/@&@AB r9cD>^SU4Sjjn[[TT/T4U5$)z4Wrap a synchronous function to make it asynchronous.cz>[RR[[U55nT"S0UDSSU00D6$Nrr?r8r!r;from_runnable_configrdict)r+rr?rhs r:wrap_traceableIas_runnable..RunnableTraceable._wrap_sync..wrap_traceable/s8$,,AA$tVBTUMfMz86LMMr9r+rrrprr)rr)rhrrrrsrps` r:ry1as_runnable..RunnableTraceable._wrap_sync)s'  N%!8&!@A>R Rr9c>^Ucg[U5(d[SU35e[[S[T4U5mSU4Sjjn[[TT/[T4U5$)z.Wrap an async function to make it synchronous.NzXRunnableTraceable expects a function wrapped by the LangSmith @traceable decorator. Got .c># [RR[[U55nT"S0UDSSU00D6IShvN $N7frr)r+rr?afunc_s r:awrap_traceableKas_runnable..RunnableTraceable._wrap_async..awrap_traceableDsA$,,AA$tVBTU#UfUz8>TUUUUs?A AA r)rkrzrrr)r}rrrrrsrps @r:rw2as_runnable..RunnableTraceable._wrap_async5s }(// 227:(3 &(9#9:EBF V%0)F2CCDo r9r8r)rhrr}*Optional[Callable[..., Awaitable[Output]]]rrh)rhzCallable[..., Output]rz)Callable[[Input, RunnableConfig], Output])r}rrz>Optional[Callable[[Input, RunnableConfig], Awaitable[Output]]]) rrrrrr0 staticmethodryrwr __classcell__)r{rrrsrps@r:RunnableTraceablerus AE  >    @  S' S 6 S S  S  =  K    r9r) langchain_core.runnablesrprqlangchain_core.runnables.utilsrrrs ImportErrorrkrw getsourcerrz) traceable_fnrqrfn_srcrrrrsrps @@@r: as_runnablers*K@ ! . . ,&&|4F**6~fX O  GGNGR \ **q  D   ,+F ,s(A%B% B/ A;;B BB>rtoolrparserprompt embedding retrieverc\rSrSr%SrS\S'S\S'S\S'S\S 'S \S 'S \S 'S \S'S\S'S\S'S\S'S\S'Srg)_TraceableContaineri[3Typed response when initializing a run a traceable.rrr}r+ outer_projectrr?rr>rrrzcontextvars.ContextrPr2_token_event_loggedr.rerr8Nrr8r9r:rr[sG= ((  ,,##== 88  '' CCr9rc\rSrSr%SrS\S'S\S'S\S'S \S 'S \S 'S \S'S\S'S\S'S\S'S \S'S\S'S\S'S\S'S\S'Srg)r%ikrrrr}rmrr-rr,rr Optional[Callable]rnr+rcr Optional[Callable[[dict], dict]]rorqrr2rr.rerr8Nrr8r9r:r%r%ksY= &&  &&!!""44%%::"00 CCr9r%c|U(a[X5(ag[R"5n[U5SU3$)zGFormat error for logging, suppressing traceback for handled exceptions.Nz )rer# _format_excrepr)rr stacktraces r:rGrG~s7  5 G G""$J5k]$zl ++r9c.URS5nUcg[U[5(aUnOYUbR[US5(aA[ UR 5(a'[U[ 5(dUR SSS9nOS U0n[X4S 9=nbXcRS 'U(a[X RS 55nO3SnURS 5=n(a[ U5(a U"U5 UR!XGS9 URS5n U SLd["R$"5SLaUR'5 URS5=n (a[ U 5(a U "U5 ggg![a3n[RS[ U5SU35 S U0nSnAGN(SnAff=f![a#n[R"SU35 SnANSnAff=f![a#n[R"SU35 SnAgSnAff=f)z End the run.rN model_dumpTjson) exclude_nonemodez&Failed to use model_dump to serialize z to JSON: output)r?rrrrz$Failed to run _on_success function: rrr.rzFailed to run on_end function: )r7rerrir(rtyperrCdebugrr-rGrrWrXrHr#r6rI) containerrrr? dict_outputsrusage error_reprrr.rs r:_container_endrs }}Y'H'4    G\ * * W'' ( (7D)) /"--4f-ML!'* HHU.3*+ < ==!78  $==7 7K 7Xk=R=R JH% LLL8mmI&G$%224<--)))x/?/? A 8 0@)5 / LL8gzRSQTU %g.L  /$! J DQCHII J A MM;A3? @ @ AsH2E7.F7,G'7 F4(F//F47 G$GG$' H1HHcLURSS5nU(a0UEUEnU$UnU$)Nr)r7)rrr extra_inners r:_collect_extrars;##K6I22 2  " r9c :URS5nUS:Xag[U[R5(aU$[U[5(aF[RR UURS5[ URS55S9$[U[5(aH[RRUURS5[ URS55S9nU$URS5nU(aU$[5n[R"5bo[RRXRS5S9=n(a<U(a3UbURS5(dURUR:aU$U$) Nr*ignorer r+)r r+r?r callbacks)r7rer!r;r from_headersr9r"from_dotted_orderr;r%get_langchain_core_versionr dotted_order)rrr*dortr?crtrts r:rZrZsv  *F &)++,, &'""  -- "&&x0*?+>+>~+NO .  &#  22 "&&x0*?+>+>~+NO 3   "":.H  C..0<""77 ..x88  2 &6::k+B+B ??S%5%55 Jr9cv URS5=(d 0nURS5nURS5nURS5nURS5=(d Sn URSS5n [RR5n U=(d [5nURS 5=(d URS 5n URSU5=(d [RR5n [ 0UESU 0EURS 55n[RR5nU=(dl U(a UR OS =(dP URS 5=(d8 US =(d, [R=(d [R"5nURS 5nURS5nURS5nUSLd&USLaU(d[R"5(dl[R"[RS5 [S UU S S URS5URS5[5SURS5S9 $[ R""U5nU =(d [R$"U5n['XR5n[R(R5=(d [R*n[R,R5=(d [R.n[5n0URS5=(d 0EU=(d 0EnUR1[R(R2U5 UR5U=(d 05 SUS'UUS'[7U/UQ7SU0UD6unnURS5nU(a_U"U5R95VVs0sHunnUcM UU_M n nnU (a&[;U [<5(aUR5U 5 URS5n"U"(a U""U5nURS5=(d /U=(d /-n#UR1[R,R2U#5 U#U=(d /- n#UbUREUU UU#UUUS9n$O}UUU [FRH"USS9U[JRLR5UU#U UU S . n%Ub[FRH"U5U%S!'[JRN"S%0[Q[RU%5D6n$USLd[R"5SLaU$RU5 [U$UU UUURS5URS5USUURS5S#9 n&UR1[RR2U&S 5 UR1[XR2U&S$5 U&$s snnf![>a&n![@RCSUSU!35 S n!A!GNS n!A!ff=f![>a&n![@RCSUSU!35 S n!A!GNS n!A!ff=f![>a0n![@RCS"U$RVSU!35 S n!A!GN3S n!A!ff=f)&rrr-r,r rrrFrmrNr+rrr.Tz>LangSmith tracing is not enabled, returning original function.rrr) rr+rr?r>rrrPrrrsr3rhrz&Failed to infer invocation params for : rozFailed to filter inputs for )rmrr+r,rrr,r4) rmr+rrr+r/rr,r r,rr\zFailed to post run ) rr+rr?r>rrrPrr.rrr8)-r7r5rHr{rLrZrkrlr#rmr6log_onceloggingDEBUGrr rwr_get_function_namerrJr8rIr7rr=rE _get_inputs_and_attachments_saferOrerrrCrr:r r<r!rMr;rrr=r\r6)'rhrrrr^rr-r,r rrrrmr@rA project_cvselected_projectrid_r.rname_rr?r>rP metadata_r+r,rrQrRinvocation_paramsrrorBrrun_tree_kwargsresponse_containers' r:rrs)"%%m4:K"":.H   v &D   *F"":.9'H#2#6#6&$ **..0M%9)9O   v & E/*=*=f*ED!!(F3Mx7G7G7K7K7MG!.?.Hg. 80DK''++-J &(3K $ $ &   ~ .  & > *  &  ( (  &  # # %+../EF   h 'C!!),G %t4L4L4N4N  MM L #)''++M:"&&x0 N %!0!4!45K!L  !!$'I  2E,,T2E >K''++-J1J1JN##%>)>)>JnG   z * 0b  RI KK""&& 2 X^$(Ik'K :#'-FK+../EF P!5f!=!C!C!E!!EA1!E !!Z0A4%H%H  !23%(()9:N F#F+F  ( .B:3C DE KK""E* TZRE**#+  $-$:$:$$%-!++//1 &,H  ?$-$:$:3$?OD !##Ad3&@A$%224< B LLN-%#%""8,#'' 6!,001GH  KK&&**,>~,NO KK $$&8&CD I!  P LLA%1#N O O P  F LL7wbD E E FP B LL.wzzl"QC@ A A Bs`X8 XX 0XY 0Y>X Y"YY Y;Y66Y;> Z8%Z33Z8cUbU"U5n[XUS9 g![a+n[RS[ U535 SnAgSnAff=f)zHandle the end of run.Nrz!Unable to process trace outputs: )rrrCrDr)rrrrrs r:r&r&sOF  ('0Gy? F:47)DEEFs A !AA c[USS5$)NrF)getattrrjs r:rdrds 42E ::r9cUR"U0UD6nUR5 [UR5nUR SS5 UR SS5 UR R 5HZupVUR[RR:XdM/XT;dM6URXE5 UR U5 M\ U$)z:Return a dictionary of inputs from the function signature.rNcls) bind_partialapply_defaultsr argumentsrrrOrrwrr rE)rrr^boundr param_namer s r: _get_inputsrs  " "D 3F 3E U__%I MM&$ MM%&11779 ::**66 6&  !67 j) : r9c[U/UQ70UD6$![a)n[RSUSU35 XS.sSnA$SnAff=fNzFailed to get inputs for r)rr^)rrrCr)rrr^rs r:_get_inputs_safersO096t6v66 0 0 2aSAB//0s A?AAc<UR[R:XdG[UR5[:Xa+[ S[ UR555(agUb[UR[5(ay[USS9nURUR5nUbNU[R:H=(d4 [U5[:H=(a [ S[ U555$gg![[[4a gf=f)Nc3F# UHo[R:Hv M g7frr" Attachmentr args r:r !_is_attachment..sP5Ocw)))5Os!T)include_extrasc3H# UHnU[R:Hv M g7frrrs r:r rs"#@Cw111#@s "F) annotationr"rrr anyrrer"rr7rm NameErrorrxAttributeError)r rh type_hintsresolved_annotations r:_is_attachmentrs 7---5##$ 1 PXe>N>N5OP P P Ju'7'7== 'TBJ",.."< ".*g.@.@@23y@#+,?#@/ 9n5    s A5DDDcURR5VVs1sHup#[X15(dMUiM snn$s snnfr)rrOr)rrhrmr s r:_attachment_args_helperrsB %//557 7KD % & 7  s AAi)maxsizec[X5$r)rrrhs r:_cached_attachment_argsrs #9 33r9cP[X5$![a [X5s$f=fr)rrxrrs r:_attachment_argsrs,8&y77 8&y778s %%rjc[U/UQ70UD6n[X5nU(a.00pvUR5HupX;aXU'MXU'M Xg4$U04$![a+n [R SUSU 35 X#S.04sSn A $Sn A ff=fr)rrrOrrCrD) rrhrr^inferredattachment_argsr+r,rQrRrs r:rrs 4y:4:6:*9; "$bK ('%&N !1I ) & &| 429+RsCD/334s$AAA B  B?B B cUc/[R5HupURS5 M gUR5Hup[UnURU5 M! g)zSet the tracing context.N)r1rOr=)rPrQrRvars r:r]r]sQ!'')DA EE$K* A   r9c#4^^# U(aUU4SjnTSRU5nOTSR[T5nU(a U"U5nOUnU(aTS(axTRS5(dbTSRS[RR [R R5R5SU0S.5 STS'URU5 Uv M![an U RsSn A $Sn A ff=f7f) NTc>TRS5nU(a)[U5nU(aU [T5sSSS5 $[T5$!,(df  N=fNr)r7rnextr?fresh_otel_contextrrs r:next_with_otel_context1_process_iterator..next_with_otel_context)sI,00;H-G-Q*-!3'+I"4!3 ?*"4!3s A ArPrr new_tokenr@rmtimer^) rrr7 add_eventdatetimenowtimezoneutc isoformatr StopIterationvalue) rrrrrqrrr traced_itemrs `` r:rrs'#+( 2667MN$Y/33D)D+D1 " !),%))*?@@i(22 + ( 1 1 5 5$--11!#)+#*K"8 8< 34 NN; 'JIJ wws/DC/C55 D? D D DDD)rc^^# U(adUU4SjnU(a&[R"U"5TSS9IShvN nO[S 0[TS5D6 U"5IShvN nSSS5 OzU(a5[R"[R "T5TSS9IShvN nO>[S 0[TS5D6 [R "T5IShvN nSSS5 U(a U"W5n OWn U(aTS(axTR S5(dbTSRS[RR[RR5R5SU 0S .5 STS'URU 5 U7v GMGNdGN?!,(df  N=fGNN!,(df  N=f![a gf=f7f) NTc># TRS5nU(a<[U5nU(a*U [R"T5IShvN sSSS5 $[R"T5IShvN $N+!,(df  N.=fN7fr)r7rrpy_anextrs r:anext_with_otel_context8_process_async_iterator..anext_with_otel_context]si,00;H-G-Q*-!3-7-@-@-K'K"4!3!+!4!4Y!???(L"4!3?s:-B A8 A6 A8#B 1B 2B 6A88 BB rPrrrr r@r r8)rrrarSrrr7r r rrrrrStopAsyncIteration) rrrrrrqrrrrs `` r:rrOs; #@#!(!4!4/1 -i 8"D )-mI.FG&=%>> #!(!4!4"++I6 -i 8"D )-mI.FG&0%8%8%CC+D1 " !),%))*?@@i(22 + ( 1 1 5 5$--11!#)+#*K"8 8< 34 NN; 'Jq ?  D2    sG6G F G  F&$F#%F&)?G (F7)G F<F: F<$B=G #F&& F40G :F<< G G GGGGTcb\rSrSrSrS S SjjrSSjrSrSrSr S r S SS jjr S r g)_TracedStreamBaseiz%Base class for traced stream objects.NcXlX lSUlX0l/UlUS(aUSR S:HUlgSUlg)NFrr) __ls_stream____ls_trace_container____ls_completed____ls_reduce_fn____ls_accumulated_output__r__is_llm_run__)rrrrns r:r0_TracedStreamBase.__init__sZ $&5# % )24&y) I & / /5 8  r9c.[URU5$r)rr)rrms r: __getattr___TracedStreamBase.__getattr__st))400r9c|[[[UR5[UR5-55$r)listr=dirr{rrRs r:__dir___TracedStreamBase.__dir__s+CDNN+c$2D2D.EEFGGr9c$SUR<S3$)Nz Traceable())rrRs r:__repr___TracedStreamBase.__repr__sD..133r9c,[UR5$r)r"rrRs r:__str___TracedStreamBase.__str__s4%%&&r9cUR(dUR5 URR 5 g![a N(f=f![a gf=fr)r! _end_tracerr__del__rRs r:r7_TracedStreamBase.__del__sX ((!     & & (      s !?A A  A  AAcUR(agUR(aURUR5nO URn[URUUS9 SUlg!SUlf=f)NrT)r!r"r#rr )rrreduced_outputs r:r6_TracedStreamBase._end_tracesg   )$$!%!6!6t7U7U!V!%!?!? ++&  %)D !DD !s AA** A3)r$r#r!r"rr r)rz$Union[Iterator[T], AsyncIterator[T]]rrrnr)rmr"rrg) rrrrrr0r'r,r0r3r7r6rr8r9r:rrsO/ )-  4 - &  "1H4' ))r9rcf^\rSrSrSrS S U4SjjjrS SjrS SjrSrSr Sr U=r $) riz>A wrapper for synchronous stream objects that handles tracing.c>[TU]UUUS9 Xl[URURUR UR US9Ulg)Nrrrn)rrrq)r|r0rrr r$r# __ls__gen__rrrrnrqr{s r:r0_TracedStream.__init__s\ +  $,     ' '**22'  r9cl[UR5$![a UR5 ef=fr)rr@rr6rRs r:__next___TracedStream.__next__s4 (() )  OO   s3c## URShvN UR5 gN![a n[U5 URUS9 eSnAff=f7fNr)r@r6rr)rrs r:r_TracedStream.__iter__sR '' ' ' OO  (  q ! OO!O $  s0A+)+A+ AAAAc:URR5 U$r)rrSrRs r:rS_TracedStream.__enter__s $$& r9cURRXU5URU(aUS9 $SS9 $!URU(aUS9 fSS9 f=frG)rrVr6rrKexc_valexc_tbs r:rV_TracedStream.__exit__sM A%%..x&I OOX'O @4O @DOOX'O @4O @s 9A)r@rNN)r Iterator[T]rrrnrrqrrr)rrQ) rrrrrr0rDrrSrVrrr{s@r:rrsYH )-,0   - &  *   *AAr9rct^\rSrSrSrS S U4SjjjrS S SjjrSSjrSSjrSr Sr S r U=r $)ri z?A wrapper for asynchronous stream objects that handles tracing.c >[TU]UUUS9 Xl[URURUR [ R"5URUS9Ul g)Nr?)rrrrrrq) r|r0rrr r$rrr#_TracedAsyncStream__ls_genrAs r:r0_TracedAsyncStream.__init__ sg +  $/((55**&>>@22'   r9c# [5n[R"[R"UR XS95IShvN [ [U55 gN7f)NrY)r rrrrr6r]rS)rrr[s r: _aend_trace_TracedAsyncStream._aend_trace#sKnnn  $ $T__e G    056 sAAAAc# [[[R"UR5IShvN 5$N![ a UR 5IShvN ef=f7fr)rrrrrVrrYrRs r: __anext___TracedAsyncStream.__anext__*sO !4!4T]]!CCD DC! ""$ $ $  s1A$-<: <A$<A!AA!!A$c# URShvN nU7v MN UR5IShvN g![a UR5IShvN ef=f7fr)rVrYr)rrs r:r_TracedAsyncStream.__aiter__1s] %"mm d  m ""$ $ $  ""$ $ $  sFA% =" "="=A%9A%A"AA""A%cV# URR5IShvN U$N7fr)rr]rRs r:r]_TracedAsyncStream.__aenter__;s'  ++---  .s )')c# URRXU5IShvN UR5IShvN $NN!UR5IShvN f=f7fr)rr`rYrLs r:r`_TracedAsyncStream.__aexit__?sP %++55hPP""$ $ $Q $$""$ $ $sGA"AAAA"AA"AA"AAAA")__ls_genrrP)rAsyncIterator[T]rrrnrrqrrr<rR)rre) rrrrrr0rYr\rr]r`rrrSs@r:rr s\I )-,0    - &  *   ,7%%%r9rcU(aUb U"U5$U$g![a!n[RU5 UsSnA$SnAff=fr)rrCr)rrnrs r:rrFsI    )) N!  Q s A=AAchURnU(aURbURRRR [ 5(aSURnURb:URRRR [ 5(aMSXlggr) __traceback__tb_nexttb_framef_code co_filenameendswith_EXCLUDED_FRAME_FNAME)rtb_s r:rrRs //C kk%#,,*=*=*I*I*R*R !+ + ++Ckk%#,,*=*=*I*I*R*R !+ +   r9cd[c SSKnSq[$[$![a Sq[$f=f)zCache for otel import check.NrTF)r3opentelemetry.tracer) opentelemetrys r:_is_otel_availablers\s@ $ &"O ? $#O  $s  //c:U(a"S5(dg[5(dgSSKJnJnJnJnJn SSK J nJ n U"UR5nU"UR5n U"UU SU"UR5U"5S9n U"U 5n U"U 5$)zCreate OpenTelemetry context manager if OTEL is enabled and available. Args: run_tree: The current run tree. Returns: Context manager for use_span or None if not available. OTEL_ENABLEDNr)NonRecordingSpan SpanContext TraceFlags TraceStateuse_span)get_otel_span_id_from_uuidget_otel_trace_id_from_uuidF)trace_idspan_id is_remote trace_flags trace_state)r#is_env_var_truishrsrqrvrwrxryrzlangsmith._internal._otel_utilsr{r|r}r\SAMPLED) r?rvrwrxryrzr{r|r}r~ span_contextnon_recording_spans r:rris 522>BB    +8+<+<=H(5Gz112L L*,7 & ''r9)rr)r?rfrGenerator[None, None, None])r-rrrhr)rPzOptional[contextvars.Context]rdict[str, Any])r+r}r,rr-rr*z@Optional[Union[run_trees.RunTree, Mapping, str, Literal[False]]]r.z'Optional[Union[bool, Literal['local']]]r rr/z Optional[Sequence[WriteReplica]]r0r}r^rrr)rhrrz'TypeGuard[SupportsLangsmithExtra[P, R]])rhCallable[P, R]rmr}r-rdr,rr rrn0Optional[Callable[[Sequence], Union[dict, str]]]r+r}rorrpOptional[Callable[..., dict]]rqrrSupportsLangsmithExtra[P, R])rhrrbool)r?rfrrr^rrz(Optional[schemas.ExtractedUsageMetadata])rhrrrrb)rrcrmr}r-rdr,rr rrnrr+r}rorrprrqrrrrrr.r2rrerz8Callable[[Callable[P, R]], SupportsLangsmithExtra[P, R]])rrr^rrz/Union[Callable, Callable[[Callable], Callable]])r+r}rr})rrrr()rzBaseException | Nonerrerr}rP)rrr Optional[Any]rrgrrh)rrrr{rr)rr{rrrrri) rhrrr%rrrrr^rrr) rrrrrrgrrrrh)rhrrr)rinspect.Signaturerrr^rrr)r zinspect.Parameterrhrrr)rrrhrrzset[str]) rrrrrhrr^rrz tuple[dict, schemas.Attachments])rPr)rrQrrrrr list[Any]rqrrrrzGenerator[T, None, Any])rrerrrrrrrrrqrrrrzAsyncGenerator[T, None])rr*rnrrr)rr)rr)r?r)|r __future__rr contextlib contextvarsr rfrwrrWcollections.abcrrrrrr r r typingr r rrrrrrrrrrrrrtyping_extensionsrrrrlangsmith._internal._context _internalr5 langsmithr r r!r"r#langsmith._internalr$r langsmith.envr%langsmith.run_treesr&typesr'rr( getLoggerrrCr6rHrIrJrKrLrMrNr1rrnr3r;contextmanagerrArFrSraget_run_tree_contextrkrtryr{rrrrrsr*r9rr#rr%rGrrrZrr&rdrrrr lru_cacherrrr]rrrrrrrrrsrr8r9r:rs7"%$IH//)//4&,#1   8 $''** NN""((##&== 4 0 3"&&+  // //(  .2A *AA$ #' $)-OS7;)-15+/B.B. B.' B. M B. 5 B. 'B./B.)B.B.!B.B.L,,0 $)-BF"&7;59(,    *    '  @   5 3 & " :RYeR: C4  cN Xwq!t}  6#BBB B . B ' '!' '  %,C,0 $)-BF"&7;59(,>B)."FJC"C C* C  C ' C@C C5C3C&C<C#'CCDC >!C C&[  [ [ 5[ |W7W7t p+h D)5 D DiuD& ,  ,C , ,"%)2A"2A 2A #2A 2Aj"1#1 1!1n15 T T$T.T  T  T  Tr"%)7; F" F  F # F5 F  F; ),8;(0 0),08;008>B (:  T"=A4 4(:4 4#4>B8 8(:8 8 $4 4 4 4 4 & 4.$+/00&00  0 & 0(00v+/E E &E  E  E  E &E (E E P CL9) 9)x1A%wqz1Ah9%*GAJ9%x  '(V&&     ,,   ,,r9