o 1 i, @sddlZddlmZmZmZmZmZddlmZm Z ddl m Z ddl m Z ddlmZddlmZeeZedd e d d    d d ddddededeeeefdede dedededdeeeefdeeeffddZedd e dd ddZdS)!N)AnyDictListOptionalTuple)_explicitly_enable_client_mode_set_client_hook_status)get_ray_doc_version) JobConfig) Deprecated)rayzfUse 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 Z is_connectedgetloggerinfoZ get_contextZ client_workerZconnection_info RuntimeErrorrrconnect) rrrrrrrrrrconnr c/home/app/PaddleOCR-VL-test/.venv_paddleocr/lib/python3.10/site-packages/ray/util/client_connect.pyrs0  rz5Use 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)loggingtypingrrrrrZray._private.client_mode_hookrrZray._private.utilsr Zray.job_configr Zray.util.annotationsr Zray.util.clientr getLogger__name__rformatstrboolintrr"r r r r!sd         /