clusters update

2024-11-19 19:31:31 +03:00
parent 232d40c6b6
commit fa1f8b2ed6
1 changed files with 4 additions and 1 deletions
@@ -72,7 +72,10 @@ async def get_least_loaded_cluster() -> str:
        logger.warning("No valid clusters found in config, returning 'cluster1'.")
        return "cluster1"

-    least_loaded_cluster = min(cluster_loads, key=cluster_loads.get)
+    least_loaded_cluster = min(
+        cluster_loads, key=lambda k: (cluster_loads.get(k, 0), k)
+    )
+
    logger.info(f"Least loaded cluster selected: {least_loaded_cluster}")

    return least_loaded_cluster