fix: correct worker count for services

nitrictech · Nov 21, 2024 · 4189dbd · 4189dbd
1 parent c610c92
commit 4189dbd
Showing 1 changed file with 9 additions and 3 deletions.
diff --git a/pkg/collector/service.go b/pkg/collector/service.go
@@ -108,9 +108,15 @@ func (s *ServiceRequirements) HasDatabases() bool {
 func (s *ServiceRequirements) WorkerCount() int {
 	workerCount := len(lo.Values(s.routes)) +
 		len(s.listeners) +
-		len(s.schedules) +
-		len(lo.Values(s.subscriptions)) +
-		len(lo.Values(s.websockets))
+		len(s.schedules)
+
+	for _, sub := range s.subscriptions {
+		workerCount += len(sub)
+	}
+
+	for _, ws := range s.websockets {
+		workerCount += len(ws)
+	}
 
 	if s.proxy != nil {
 		workerCount++