&`i( LddlZddlZddlmZddlmZmZmZddlZddl m Z ddl m Z ddl mZddlmZddlmZmZmZdd lmZdd lmZmZdd lmZmZdd lmZdd lm Z ddl!m"Z"ej#eZ$dedee%efddfdZ& ddede%efdede%efdede%e"fdefdZ' ddede%efdede%efdede%e"fdefdZ( ddede%efdede%efdede%e"fdefdZ)deeefdee*efdefdZ+dS)N) FunctionType)AnyDictUnion)is_subclass_of_base_model) usage_lib) ActorHandle)ServeControllerClient)HTTP_PROXY_TIMEOUTSERVE_LOGGER_NAMESERVE_NAMESPACE)get_controller_impl) HTTPOptions gRPCOptions)_get_global_client_set_global_client) Application)RayServeException) LoggingConfigclient http_optionsreturncZ|r|j}t|tr|ntj|}g}|j}|D]9}t ||t ||kr||:t|r"t d|ddSdSdS)NzRThe new client HTTP config differs from the existing one in the following fields: z!. The new HTTP config is ignored.) http_config isinstancer parse_obj__dict__getattrappendlenloggerwarning)rrclient_http_optionsnew_http_optionsdifferent_fieldsall_http_option_fieldsfields j/home/jaya/work/projects/VOICE-AGENT/VIET/agent-env/lib/python3.11/site-packages/ray/serve/_private/api.py_check_http_optionsr)s$0, 44 5LL&|44  !1!:+ / /E'//7;NPU3V3VVV ''...    NN2,<222        grpc_optionsglobal_logging_configc dtjjj_tjstjtgd}|D]$}||vrt|d|d||d%t|trtj |}|t}t|tr tdi|}|t}n!t|tr tdi|}t}||||}tj|j}t'|d kri tjd |Dt* n0#tjj$rt1d t*d wxYw|S)zStart Ray Serve controller. The function makes sure controller is ready to start deploying apps after it returns. Parameters are same as ray.serve._private.api.serve_start(). Returns: controller actor handle. F) namespace) http_host http_porthttp_middlewaresz6 is deprecated, please use serve.start(http_options={"z": z }) instead.N)rr+r,rc@g|]}|jS)readyremote).0handles r( z%_start_controller..hs&LLL6$$&&LLLr*)timeoutz!HTTP proxies not available after zs.r3)ray_privateworker global_worker_filter_logs_by_jobis_initializedinitr ValueErrorrdictrrrrrr5get get_proxiesr valuesr exceptionsGetTimeoutError TimeoutError) rr+r,kwargshttp_deprecated_argskeycontroller_impl controller proxy_handless r(_start_controllerrO2s*"=BCL%9    , ?++++JII# &==8888$Sk888   ,%%;",\:: "}} ,%%3"22\22 $ - )4 0 0G - F F0E F F)++O ''!!3(J GJ299;;<")). Args: http_options (Optional[Dict, serve.HTTPOptions]): Configuration options for HTTP proxy. You can pass in a dictionary or HTTPOptions object with fields: - host(str, None): Host for HTTP servers to listen on. Defaults to "127.0.0.1". To expose Serve publicly, you probably want to set this to "0.0.0.0". - port(int): Port for HTTP server. Defaults to 8000. - root_path(str): Root path to mount the serve application (for example, "/serve"). All deployment routes will be prefixed with this path. Defaults to "". - middlewares(list): A list of Starlette middlewares that will be applied to the HTTP servers in the cluster. Defaults to []. - location(str, serve.config.DeploymentMode): The deployment location of HTTP servers: - "HeadOnly": start one HTTP server on the head node. Serve assumes the head node is the node you executed serve.start on. This is the default. - "EveryNode": start one HTTP server per node. - "NoServer" or None: disable HTTP server. - num_cpus (int): The number of CPU cores to reserve for each internal Serve HTTP proxy actor. Defaults to 0. grpc_options: [Experimental] Configuration options for gRPC proxy. You can pass in a gRPCOptions object with fields: - port(int): Port for gRPC server. Defaults to 9000. - grpc_servicer_functions(list): List of import paths for gRPC `add_servicer_to_server` functions to add to Serve's gRPC proxy. Default empty list, meaning not to start the gRPC server. rQTrRrTrUrWrX) rrYrr!rZr r)rrOr rr\s r( serve_startr_s\"7+++  #TBBB  5o 5 5 5     6  5 5 5      #l$9=CJ#Fv KKBBBBCCC MsAA A*)A*builderargsct|tr$t|dkrtd|St|ts t dt |dtj|}t|j dkrt d|j t|j d}tj |j r.t|j r|j |}||}t|ts t dt |d|S)abCalls a user-provided function that returns Serve application. If an Application object is passed, this is a no-op. Else, we validate the signature of the function, convert the args dictionary to the user-annotated Pydantic model if provided, and call the function. The output of the function is returned (must be an Application). rzbArguments can only be passed to an application builder function, not an already built application.zOExpected a built Serve application or an application builder function but got: .znApplication builder functions should take exactly one parameter, a dictionary containing the passed arguments.zhApplication builder functions must return an `Application` returned `from `Deployment.bind()`, but got: )rrr rAr TypeErrortypeinspect signature parameterslistkeysisclass annotationrr)r`rarhparamapps r(,call_user_app_builder_with_args_if_necessaryrps';''  t99q==4   . .  )W  ) ) )   !'**I 9   A%% <     i&:&?&?&A&A!B!B1!E FEu'((0-F ..0))$// '$--C c; ' '  @3799 @ @ @   Jr*)NNN),rgloggingtypesrtypingrrrr:ray._common.pydantic_compatrray._common.usager ray.actorr ray.serve._private.clientr ray.serve._private.constantsr r r ray.serve._private.default_implrray.serve.configrrray.serve.contextrrray.serve.deploymentrray.serve.exceptionsrray.serve.schemar getLoggerr!rBr)rOr]r_strrpr3r*r(rs(########## AAAAAA''''''!!!!!!;;;;;; @?????55555555DDDDDDDD,,,,,,222222******  , - - !16t[7H1I 24837>B==dK/0=dK/0=!t]!:;=  ====B4837>B))dK/0)dK/0)!t]!:;)  ))))Z4837>BEEdK/0EdK/0E!t]!:;E  EEEEP3 ; , -3 sCx.3333333r*