add TODO comment

viamrobotics · Jan 23, 2025 · 657a560 · 657a560
1 parent ef5b3d3
commit 657a560
Showing 1 changed file with 4 additions and 3 deletions.
diff --git a/rpc/wrtc_call_queue_mongodb.go b/rpc/wrtc_call_queue_mongodb.go
@@ -215,9 +215,10 @@ func NewMongoDBWebRTCCallQueue(
 		activeAnswerersfunc:   &activeAnswerersfunc,
 	}
 
-	// queue.activeBackgroundWorkers.Add(1)                                            // TODO(RSDK-8666): remove
-	// utils.ManagedGo(queue.operatorLivenessLoop, queue.activeBackgroundWorkers.Done) // TODO(RSDK-8666): remove
-	queue.activeStoppableWorkers.Add(func(ctx context.Context) { queue.operatorLivenessLoop() })
+	// 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.activeStoppableWorkers.Add(func(ctx context.Context) { queue.changeStreamManager() })
 
 	// wait for change stream to startup once before we start processing anything