diff --git a/rpc/wrtc_call_queue_mongodb.go b/rpc/wrtc_call_queue_mongodb.go index 5ae7821b..aa0b3e6c 100644 --- a/rpc/wrtc_call_queue_mongodb.go +++ b/rpc/wrtc_call_queue_mongodb.go @@ -215,9 +215,9 @@ func NewMongoDBWebRTCCallQueue( activeAnswerersfunc: &activeAnswerersfunc, } - queue.activeBackgroundWorkers.Add(1) // TODO(RSDK-866): remove - utils.ManagedGo(queue.operatorLivenessLoop, queue.activeBackgroundWorkers.Done) // TODO(RSDK-866): remove - //utils.ManagedGo(queue.changeStreamManager, queue.activeBackgroundWorkers.Done) // TODO(RSDK-866): remove + queue.activeBackgroundWorkers.Add(1) // TODO(RSDK-8666): remove + utils.ManagedGo(queue.operatorLivenessLoop, queue.activeBackgroundWorkers.Done) // TODO(RSDK-8666): remove + // utils.ManagedGo(queue.changeStreamManager, queue.activeBackgroundWorkers.Done) // TODO(RSDK-8666): remove // queue.activeStoppableWorkers.Add(func(ctx context.Context) { queue.operatorLivenessLoop() }) queue.activeStoppableWorkers.Add(func(ctx context.Context) { queue.changeStreamManager() })