diff --git a/server/worker.go b/server/worker.go index a8dfe8e..009d6e6 100644 --- a/server/worker.go +++ b/server/worker.go @@ -191,7 +191,8 @@ func updateWorkerTaskStatus(ctx context.Context) { return } - for _, tsr := range taskStatusRequests { + for _, taskStatusRequest := range taskStatusRequests { + tsr := taskStatusRequest wg.Add(1) go func() {