fix: worker tests deadlock

raystack · Jun 8, 2024 · 6232247 · 6232247
1 parent 8a3827f
commit 6232247
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/worker/worker.go b/worker/worker.go
@@ -38,7 +38,7 @@ func CreateWorkerPool(size int, eventsChannel <-chan collection.CollectRequest,
 	}
 }
 
-func (w *Pool) newWorker(name string) {
+func (w *Pool) worker(name string) {
 
 	logger.Info("Running worker: " + name)
 	for request := range w.EventsChannel {
@@ -98,7 +98,7 @@ func (w *Pool) newWorker(name string) {
 func (w *Pool) StartWorkers() {
 	w.wg.Add(w.Size)
 	for i := 0; i < w.Size; i++ {
-		w.newWorker(fmt.Sprintf("worker-%d", i))
+		go w.worker(fmt.Sprintf("worker-%d", i))
 	}
 }