From 11443f7b69113f5d8eedd4f2270c47ca5803a72f Mon Sep 17 00:00:00 2001 From: Albin Severinson Date: Thu, 22 Jun 2023 08:53:13 +0100 Subject: [PATCH] Initial commit --- internal/armada/server/lease.go | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/internal/armada/server/lease.go b/internal/armada/server/lease.go index f8641d32ffc..a8559ea6932 100644 --- 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.