o bi] @sddlZddlmZddlmZddlmZddlmZm Z ddl m Z ddl m Z mZmZdZefd ed eed efd d Zefd ed edefddZdede fddZdS)N) defaultdict)List) GcsClient) ClusterStatusStats)ClusterStatusParser)ClusterResourceStateGetClusterResourceStateReplyGetClusterStatusReply gcs_address to_requesttimeoutc Cst|dks Jdtt}|D]}t|}||d7<qg}g}|D]\}}|t|||q)t|j|||ddS)aRequest resources from the autoscaler. This will add a cluster resource constraint to GCS. GCS will asynchronously pass the constraint to the autoscaler, and the autoscaler will try to provision the requested minimal bundles in `to_request`. If the cluster already has `to_request` resources, this will be an no-op. Future requests submitted through this API will overwrite the previous requests. Args: gcs_address: The GCS address to query. to_request: A list of resource bundles to request the cluster to have. Each bundle is a dict of resource name to resource quantity, e.g: [{"CPU": 1}, {"GPU": 1}]. timeout: Timeout in seconds for the request to be timeout rGCS address is not specified. timeout_sN) lenrint frozensetitemsappenddictr#request_cluster_resource_constraint) r r rresource_requests_by_countrequestbundlebundlescountscountr I/home/ubuntu/.local/lib/python3.10/site-packages/ray/autoscaler/v2/sdk.pyrequest_cluster_resourcess   r"returncCs^t|dks Jdt}t|j|d}t}t}||tj|t|||ddS)z Get the cluster status from the autoscaler. Args: gcs_address: The GCS address to query. timeout: Timeout in seconds for the request to be timeout Returns: A ClusterStatus object. rrr)gcs_request_time_s request_ts_s)stats) rtimerget_cluster_statusr ParseFromStringrfrom_get_cluster_status_replyr)r rreq_time str_reply reply_timereplyr r r!r(8s  r( gcs_clientcCs|}t}|||jS)z Get the cluster resource state from GCS. Args: gcs_client: The GCS client to query. Returns: A ClusterResourceState object Raises: Exception: If the request times out or failed. )get_cluster_resource_stater r)cluster_resource_state)r/r,r.r r r!r0Ss  r0)r' collectionsrtypingr ray._rayletrray.autoscaler.v2.schemarrray.autoscaler.v2.utilsr!ray.core.generated.autoscaler_pb2rr r DEFAULT_RPC_TIMEOUT_Sstrrrr"r(r0r r r r!s2     (