[autoscaler] fix too many values to unpack (expected 2) bug (#36231) (#…

…36482) Signed-off-by: Lonnie Liu <[email protected]>
ray-project · Jun 16, 2023 · 142b462 · 142b462
1 parent 128cf37
commit 142b462
Showing 1 changed file with 10 additions and 6 deletions.
diff --git a/python/ray/autoscaler/_private/monitor.py b/python/ray/autoscaler/_private/monitor.py
@@ -399,11 +399,15 @@ def _run(self):
  self.autoscaler.update()
  status["autoscaler_update_time"] = time.time() - update_start_time
  autoscaler_summary = self.autoscaler.summary()
- self.emit_metrics(
- load_metrics_summary,
- autoscaler_summary,
- self.autoscaler.all_node_types,
- )
+ try:
+ self.emit_metrics(
+ load_metrics_summary,
+ autoscaler_summary,
+ self.autoscaler.all_node_types,
+ )
+ except Exception:
+ logger.exception("Error emitting metrics")
+
  if autoscaler_summary:
  status["autoscaler_report"] = asdict(autoscaler_summary)
  status[
@@ -463,7 +467,7 @@ def emit_metrics(self, load_metrics_summary, autoscaler_summary, node_types):
  for _, node_type, _ in autoscaler_summary.pending_nodes:
  pending_node_count[node_type] += 1
 
- for node_type, count in autoscaler_summary.pending_launches:
+ for node_type, count in autoscaler_summary.pending_launches.items():
  pending_node_count[node_type] += count
 
  for node_type in node_types: