From d6d8aa2e59a18f3345d412fd7c81944926e9bbda Mon Sep 17 00:00:00 2001 From: Bashar Eid Date: Wed, 22 Jan 2025 19:17:16 -0500 Subject: [PATCH] lint --- rpc/wrtc_call_queue_mongodb.go | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) 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() })