&`i$ ddlZddlmZddlmZddlmZmZmZm Z m Z m Z m Z m Z ddlmZddlmZddlmZmZddlmZdd lmZejeZe d Ze d ZGd d ee eefZedGddZdede defdZ!dddddddede de e de e eefde ee efde eee gefde"defdZ#dd dede d!eee fd"eeefde ee efdeee gefde efd#Z$d$ede ee efdefd%Z%ded!eee fde fd&Z&dS)'N)deepcopy) dataclass)AnyCallableDictGenericListOptionalTypeVarUnion) _PyObjScanner)SERVE_LOGGER_NAME) Application Deployment)DeploymentHandle) LoggingConfigKVc`eZdZdZdedeffd Zdedeffd Zdeffd Zde ffd Z xZ S) IDDictzDictionary that uses id() for keys instead of hash(). This is necessary because Application objects aren't hashable and we want each instance to map to a unique key. keyreturnct|tst|}t|SN) isinstanceintidsuper __getitem__selfr __class__s p/home/jaya/work/projects/VOICE-AGENT/VIET/agent-env/lib/python3.11/site-packages/ray/serve/_private/build_app.pyrzIDDict.__getitem__8#s## S''Cww""3'''valuect|tst|}t||Sr)rrrr __setitem__)r!rr&r"s r#r(zIDDict.__setitem__s:#s## S''Cww""3...r%ct|tst|}t|Sr)rrrr __delitem__r s r#r*zIDDict.__delitem__#r$r%ct|tst|}t|Sr)rrrr __contains__r s r#r,zIDDict.__contains__(s8#s## S''Cww##C(((r%) __name__ __module__ __qualname____doc__rrrr(r*objectr, __classcell__)r"s@r#rrs (q(Q(((((( /q/////// (q(((((( )))))))))))r%rT)frozenceZdZUeed<eeed<eeed<eed<eeed<e ee fed<e ed<dS) BuiltApplicationname route_prefixlogging_configingress_deployment_name deploymentsdeployment_handlesexternal_scaler_enabledN) r-r.r/str__annotations__r rr rrrboolr%r#r5r5.s III3-]++++!   j!!!!S"223333!!!!!!r%r5 deploymentapp_namerc.t|j|S)N)rB)rr6)rArBs r#_make_deployment_handle_defaultrD?s#    r%F)r7r8default_runtime_envmake_deployment_handler<appr6r7r8rErFr<c  |t}t}t t||| ||}t||||jj| fd|D|S)aBuilds the application into a list of finalized deployments. The following transformations are made: - Application objects in constructor args/kwargs are converted to DeploymentHandles for injection at runtime. - Name conflicts from deployments that use the same class are handled by appending a monotonically increasing suffix (e.g., SomeClass_1). Returns: BuiltApplication N)rBhandlesdeployment_namesrErFc(i|]\}}||Sr@r@).0rGhandlerJs r# zbuild_app..qs2   .9c6 S !6   r%)r6r7r8r9r:r;r<)rDr_build_app_recursiver5_bound_deploymentr6items) rGr6r7r8rErFr<rIr:rJs @r# build_apprRHs,%!@hhGxx& )/5 K  !% # 5 :    =D]]__   !8    r%)rErJrIc ||vrgSg}tt} ||jj|jjf}|D]*} |t| |||||+||\} } |j t||| | } t| |} || |||<|| gz| S#| wxYw)aNRecursively traverses the graph of Application objects. Each Application will have an associated DeploymentHandle created that will replace it in any occurrences in other Applications' args or kwargs. Also collects a list of the unique Applications encountered and returns them as deployable Deployment objects. ) source_type)rBrIrJrFrE)r6 _init_args _init_kwargs) r r find_nodesrP init_args init_kwargsextendrO replace_nodesoptions$_get_unique_deployment_name_memoized_set_default_runtime_envclear) rGrBrJrIrErFr:scanner child_apps child_app new_init_argsnew_init_kwargsfinal_deployments r#rOrOxsX( g~~ K 444G%''  " ,c.C.O P  $  I   $%#%5+A(;     *1)>)>w)G)G& 0885c;KLL$(9   4 1   .-     .//  s B?C33D dc|s|St|jpi}|dd}d|vr||d<n||dd|||S)ahConfigures the deployment with the provided default runtime_env. If the deployment does not have a runtime_env configured, the default will be set. If it does have a runtime_env configured but that runtime_env does not have a working_dir, only the working_dir field will be set. Else the deployment's runtime_env will be left untouched. working_dirN runtime_env)ray_actor_options)rrjget setdefaultr\)rfrErjdefault_working_dirs r#r^r^s  !4!:;;-11-FF---+>-((  (-(33MCVWWW 99'89 9 99r%c*||vr||Sd}|jj}||vr,|jjd|}|dz }||v,|dkr+td|jjd|d|||<|S)aGenerates a name for the deployment. This is used to handle collisions when the user does not specify a name explicitly, so typically we'd use the class name as the default. In that case, we append a monotonically increasing suffix to the name, e.g., Deployment, then Deployment_1, then Deployment_2, ... Names are memoized in the `deployment_names` dict, which should be passed to subsequent calls to this function. _z3There are multiple deployments with the same name 'z'. Renaming one to 'z'.)rPr6valuesloggerwarning)rGrJidxr6s r#r]r]s $$ C  %D "))++ + +',44s44 q "))++ + + axx I%* I I@D I I I   !S Kr%)'loggingcopyr dataclassesrtypingrrrrr r r r ray.dag.py_obj_scannerr ray.serve._private.constantsrray.serve.deploymentrrray.serve.handlerray.serve.schemar getLoggerrrrrdictrr5r=rDr?rRrOr^r]r@r%r#rsm!!!!!!OOOOOOOOOOOOOOOOOOOO000000::::::88888888------******  , - - GCLL GCLL)))))T71a4=)))8 $ " " " " " " " " &)#';?48 $)--- - -3- - U4#678 - "$sCx.1 -%*c"$445-"-----l59 >>> >>[#-. > K!11 2 > "$sCx.1 >%j#%68H%HI> *>>>>B::(0c3h(@:::::2 (.{C/?(@r%