Revert "use StoppableWorkers in constructor"

This reverts commit b203203.
viamrobotics · Jan 24, 2025 · 8a66f53 · 8a66f53
1 parent b203203
commit 8a66f53
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