try to use go1.25 waitgroup logic

modules/queue/workergroup.go

@@ -153,9 +153,7 @@ func resetIdleTicker(t *time.Ticker, dur time.Duration) {
 
 // doStartNewWorker starts a new worker for the queue, the worker reads from worker's channel and handles the items.
 func (q *WorkerPoolQueue[T]) doStartNewWorker(wp *workerGroup[T]) {
-wp.wg.Add(1)
-go func() {
-defer wp.wg.Done()
+wp.wg.Go(func() {
 log.Debug("Queue %q starts new worker", q.GetName())
 defer log.Debug("Queue %q stops idle worker", q.GetName())
 
@@ -190,7 +188,7 @@ func (q *WorkerPoolQueue[T]) doStartNewWorker(wp *workerGroup[T]) {
 q.workerNumMu.Unlock()
 }
 }
-}()
+})
 }
 
 // doFlush flushes the queue: it tries to read all items from the queue and handles them.