ci ddlZddlZddlZddlmZddlmZddlmZddlm Z ddlm Z ddl m Z dd l mZdd l mZej ZGd d e j$ZGd de j(Zy)N)Dict)Optional) aiplatform) initializer)client_builder)VertexRayTemplate)_validation_utils) _gapic_utilscXeZdZdZdedeeefdejddffd ZdZ xZ S) _VertexRayClientContextzCustom ClientContext.persistent_resource_id ray_head_urisray_client_contextreturnNc h|jd}| td|dtjdvrHt|||j |j|j|j|jntjdk(rSt|||j |j|j|j|j|jn tdtjd d z||_ tt|_|jd |_y) NRAY_DASHBOARD_URIz Ray Cluster z$ failed to start Head node properly.)z2.47.1z2.42.0z2.33.0) dashboard_urlpython_version ray_version ray_commit _num_clients_context_to_restorez2.9.3)rrrrprotocol_versionrrz([Ray on Vertex AI]: Unsupported version .z5Only 2.47.1, 2.42.0, 2.33.0, and 2.9.3 are supported.#RAY_HEAD_NODE_INTERACTIVE_SHELL_URI)get ValueErrorray __version__super__init__rrrrrr ImportErrorrstrVERTEX_SDK_VERSIONvertex_sdk_version shell_uri)selfrrr dashboard_uri __class__s @/tmp/pip-target-z3e9_cxr/lib/python/vertex_ray/client_builder.pyr"z _VertexRayClientContext.__init__%s0 &))*=>  &6  ??< < G +1@@.::-88/<<$6$J$J  __ ' G +1@@.::-88!3!D!D/<<$6$J$J  :3??:K1MIJ '=#"%&8"9&**+PQc d}|j%tdj|j}tdj|j|j|j |j |j|S)Nzcontext_shellurirow.html.j2)r'zcontext_table.html.j2)rrr&rr shell_uri_row)r'r renderrrr&rr)r(r.s r+_context_table_templatez/_VertexRayClientContext._context_table_templateNs >> %-.KLSS..TM!!89@@..((#66,,#'#>#>' A  r,) __name__ __module__ __qualname____doc__r$rr ClientContextr"r0 __classcell__r*s@r+r r "sJ'R #'RCH~'R+88 'R  'RR r,r cBeZdZdZdeeddffd Zdeffd ZxZ S)VertexRayClientBuilderzAClass to initialize a Ray client with vertex on ray capabilities.addressrNc tj|}tj|d|_d|_||_t jd||_tj|j|_ |jjjjd}|jjjjd}|jjj j"}||}|rt%d|d|}|+|jj'dd}t%d|dt j(d |tj*|j }| t%d tj,}|j.|k7r|j0j2Stj4j|j.}t jd |d |j.d|dnt jd|zt6 |q|y)NzU[Ray on Vertex AI]: Using cluster resource name to access head address with GAPIC APIRAY_HEAD_NODE_INTERNAL_IPRAY_CLIENT_ENDPOINTz [Ray on Vertex AI]: Ray Cluster z failed to start Head node properly because custom service account isn't supported in peered VPC network. Use public endpoint instead (createa a cluster without specifying VPC network)./zW Head node is not reachable. Please ensure that a valid VPC network has been specified.z-[Ray on Vertex AI]: Resolved head node ip: %s)persistent_resourcez[Ray on Vertex AI]: Please delete and recreate the cluster (The cluster is not a Ray cluster or the cluster image is outdated).z/[Ray on Vertex]: Local runtime has Ray version z(, but the requested cluster runtime has z. Please ensure that the Ray versions match for client connectivity. You may "pip install --user --force-reinstall ray[default]==z0" and restart runtime before cluster connection.zt[Ray on Vertex]: Local runtime has Ray version %s.Please ensure that the Ray versions match for client connectivity.)r maybe_reconstruct_resource_namevalid_resource_name _credentials _metadatavertex_addresslogginginfo resource_namer get_persistent_resourceresponseresource_runtime access_urisrresource_runtime_specservice_account_specservice_accountrsplitdebugpersistent_resource_to_clusterget_local_ray_versionrhead_node_type custom_imageSUPPORTED_RAY_VERSIONSr!r") r(r:private_addresspublic_addressrOrclusterlocal_ray_verioninstall_ray_versionr*s r+r"zVertexRayClientBuilder.__init__bs#CCGL--g6 % c %$<Q S Y&' !r,ctjd|jjjj d}|jjjj d}|rr|spt j|_tj}ddj|fddjtjjfg|_t |E}|jjj}|j$j'dd }t)||| S) Nz![Ray on Vertex AI]: Connecting...r=r< authorizationz Bearer {}zx-goog-user-projectz{}r>r?)rrr)rFrGrJrKrLrgrpcssl_channel_credentialsrCr get_bearer_tokenformatr global_configprojectrDr!connectrHrPr )r(rXrW bearer_tokenrrrr*s r+rdzVertexRayClientBuilder.connects 8977CCGG ! --88DDHH '  / $ < < >D ,==?L +"4"4\"BC& K4M4M4U4U(VWDN#W_. 66BB "&!3!3!9!9#!>q!A '1  r,) r1r2r3r4rr$r"r rdr6r7s@r+r9r9_s3KI" I"$I"V 0  r,r9)r^rFrtypingrr google.cloudrgoogle.cloud.aiplatformrrr/r utilr r r r%r5r ClientBuilderr9r,r+rls]"  #/%# ++: n::: zj ^99j r,