WIP

kube-tarian · May 2, 2024 · b374459 · b374459
1 parent 9f4ba34
commit b374459
Showing 1 changed file with 4 additions and 6 deletions.
diff --git a/pkg/server/ingestion_worker.go b/pkg/server/ingestion_worker.go
@@ -59,13 +59,11 @@ func (iw *IngestionWorker) loopConsumeQueue(queue protoqueue.QueueSubscriber) {
 		}
 	}()
 
-	go func() {
-		defer iw.logger.Info("stopped consuming events from ingestion queue")
+	defer iw.logger.Info("stopped consuming events from ingestion queue")
 
-		for event := range eventChan {
-			iw.processEvent(event)
-		}
-	}()
+	for event := range eventChan {
+		iw.processEvent(event)
+	}
 }
 
 func (iw *IngestionWorker) processEvent(event *tarianpb.Event) {