From 52419f3e36a8d73620ee4fe1a88a0145e4f5a550 Mon Sep 17 00:00:00 2001
From: Jaime Soriano Pastor <jaime.soriano@elastic.co>
Date: Thu, 12 Feb 2026 12:35:17 +0100
Subject: [PATCH] Revert use of waitgroup.Go

---
 workers/taskpool.go | 6 ++++--
 1 file changed, 4 insertions(+), 2 deletions(-)

diff --git a/workers/taskpool.go b/workers/taskpool.go
index e6f8854de..20c9a7042 100644
--- a/workers/taskpool.go
+++ b/workers/taskpool.go
@@ -27,12 +27,14 @@ func NewTaskPool(size int) *taskPool {
 // Do runs the task in a goroutine, ensuring no more tasks are running than the size of the pool.
 func (p *taskPool) Do(task func() error) {
 	p.pool <- struct{}{}
-	p.wg.Go(func() {
+	p.wg.Add(1)
+	go func() {
+		defer p.wg.Done()
 		defer func() { <-p.pool }()
 
 		err := task()
 		p.recordError(err)
-	})
+	}()
 }
 
 func (p *taskPool) recordError(err error) {