Initial commit

armadaproject · Jun 22, 2023 · 11443f7 · 11443f7
1 parent 71dbe31
commit 11443f7
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/internal/armada/server/lease.go b/internal/armada/server/lease.go
@@ -267,7 +267,9 @@ func (q *AggregatedQueueServer) getJobs(ctx context.Context, req *api.StreamingL
 	activeClusterReports := scheduling.FilterActiveClusters(usageReports)
 	totalCapacity := make(armadaresource.ComputeResources)
 	for _, clusterReport := range activeClusterReports {
-		totalCapacity.Add(util.GetClusterAvailableCapacity(clusterReport))
+		if clusterReport.Pool == req.Pool {
+			totalCapacity.Add(util.GetClusterAvailableCapacity(clusterReport))
+		}
 	}
 
 	// Collect all allowed priorities.