o ci, @sddlmZmZmZmZmZddlZddlmZm Z ddl m Z ddl m Z ddlmZddlmZeeZe dd ed d    d d ddddededeeeefdede dedededdeeeefdeeeffddZe dd edd ddZdS)!)AnyDictListOptionalTupleN)_explicitly_enable_client_mode_set_client_hook_status) JobConfig) Deprecated)ray)get_ray_doc_versionzfUse ray.init(ray://:) instead. See detailed usage at {}.zhttps://docs.ray.io/en/z#/ray-core/package-ref.html#ray-init)messageF)ignore_version _credentialsray_init_kwargsconn_strsecuremetadataconnection_retries job_config namespacerrzgrpc.ChannelCredentialsrreturnc Csftr|dd} | rtdtjStdt dt tj |||||||||d } | S)Nignore_reinit_errorFzfCalling ray.init() again after it has already been called. Reusing the existing Ray client connection.z`Ray Client is already connected. Maybe you called ray.init("ray://
") twice by accident?T)rrrrrrrr) r is_connectedgetloggerinfo get_context client_workerconnection_info RuntimeErrorrrconnect) rrrrrrrrrrconnr$K/home/ubuntu/.local/lib/python3.10/site-packages/ray/util/client_connect.pyr"s0  r"z5Use ray.shutdown() instead. See detailed usage at {}.z'/ray-core/package-ref.html#ray-shutdowncCstS)z'Disconnects from server; is idempotent.)r disconnectr$r$r$r%r&Esr&)FNrNN)typingrrrrrloggingray._private.client_mode_hookrrray.job_configr ray.util.annotationsr ray.util.clientr ray._private.utilsr getLogger__name__rformatstrboolintr"r&r$r$r$r%sd         /