o ciq@sHddlZddlZddlZddlZddlmZmZmZmZddl Z ddl Z ddl m Z ddl mZmZddlmZddlmZddlmZeeZ     dd ed ed ed eeeeeeffd eedeedeedefddZ   ddedededeeefdeedeed edeedefddZdedefddZdS)N)AnyDictOptionalUnion) DeploymentID)DeploymentConfig ReplicaConfig)SERVE_LOGGER_NAME)DeploymentInfo)ServeApplicationSchemaFnamereplica_configingressdeployment_configversion route_prefix docs_pathreturncCsb|duri}t|trt|}n t|tstd||_||||t ||d}|S)zs Takes a deployment's configuration, and returns the arguments needed for the controller to deploy it. Nz2config must be a DeploymentConfig or a dictionary.)deployment_namedeployment_config_proto_bytesreplica_config_proto_bytesrdeployer_job_idrr) isinstancedictr parse_obj TypeErrorrto_proto_bytesrayget_runtime_context get_job_id)r r rrrrrcontroller_deploy_argsr!S/home/ubuntu/.local/lib/python3.10/site-packages/ray/serve/_private/deploy_utils.pyget_deploy_argss       r#rrrrapp_namec Kstt|} | j} t|| } t|tr!tj t |d }t t||d| | | |t td|||d S)z}Takes deployment args passed to the controller after building an application and constructs a DeploymentInfo object. little)r r$i) actor_namerrr r start_time_msrrr)rfrom_proto_bytesrr needs_picklerbytesrJobIDfrom_intint from_byteshexr rto_replica_actor_class_nametime) rrrrrr$rrkwargsrrr r!r!r"deploy_args_to_deployment_info6s2   r3 app_configcCs0tj|j|j|jdddd}t|S)zReturns the code version of an application. Args: app_config: The application config. Returns: a hash of the import path and (application level) runtime env representing the code version of the application. ) import_path runtime_envargsT) sort_keyszutf-8) jsondumpsr5r6r7encodehashlibsha1 hexdigest)r4encodedr!r!r"get_app_code_version`s r@)FNNNN)NFN)r<r9loggingr1typingrrrrrray.util.serialization_addonsray.serve._private.commonrray.serve._private.configrrray.serve._private.constantsr "ray.serve._private.deployment_infor ray.serve.schemar getLoggerloggerstrboolr#r*r3r@r!r!r!r"st      *  *