wassname/ray
1
0
Fork 0
mirror of https://github.com/wassname/ray.git synced 2026-06-28 04:07:01 +08:00
Code Issues Packages Projects Releases Wiki Activity

[hotfix] Autoscaler monitor fix unit tests

Browse Source
This commit is contained in:
Alex Wu
2020-08-27 14:26:41 -07:00
committed by GitHub
parent 76898d4ebc
commit 7dbc1f439c
1 changed files with 9 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files
python/ray/monitor.py
+9 -10
View File
@@ -100,16 +100,15 @@ class Monitor:
"""
waiting_bundles, infeasible_bundles = [], []
try:
if not self.autoscaler:
return
for resource_demand_pb in list(
resource_load_by_shape.resource_demands):
request_shape = dict(resource_demand_pb.shape)
for _ in range(resource_demand_pb.num_ready_requests_queued):
waiting_bundles.append(request_shape)
for _ in range(
resource_demand_pb.num_infeasible_requests_queued):
infeasible_bundles.append(request_shape)
if self.autoscaler:
for resource_demand_pb in list(
resource_load_by_shape.resource_demands):
request_shape = dict(resource_demand_pb.shape)
for _ in range(resource_demand_pb.num_ready_requests_queued):
waiting_bundles.append(request_shape)
for _ in range(
resource_demand_pb.num_infeasible_requests_queued):
infeasible_bundles.append(request_shape)
except Exception as e:
logger.exception(e)
return waiting_bundles, infeasible_bundles