Revert "Revert "use StoppableWorkers in constructor""

This reverts commit 8a66f53.
viamrobotics · Jan 24, 2025 · ca36657 · ca36657
1 parent 8a66f53
commit ca36657
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/rpc/wrtc_call_queue_mongodb.go b/rpc/wrtc_call_queue_mongodb.go
@@ -216,9 +216,9 @@ func NewMongoDBWebRTCCallQueue(
 	}
 
 	// TODO(RSDK-8666): using StoppableWorkers is causing a data race
-	queue.activeBackgroundWorkers.Add(1)
-	utils.ManagedGo(queue.operatorLivenessLoop, queue.activeBackgroundWorkers.Done)
-	// queue.activeStoppableWorkers.Add(func(ctx context.Context) { queue.operatorLivenessLoop() })
+	// queue.activeBackgroundWorkers.Add(1)
+	// utils.ManagedGo(queue.operatorLivenessLoop, queue.activeBackgroundWorkers.Done)
+	queue.activeStoppableWorkers.Add(func(ctx context.Context) { queue.operatorLivenessLoop() })
 	queue.activeStoppableWorkers.Add(func(ctx context.Context) { queue.changeStreamManager() })
 
 	// wait for change stream to startup once before we start processing anything