diff --git a/internal/cmd/scheduler.go b/internal/cmd/scheduler.go index 9ae1292..8fc7bd0 100644 --- a/internal/cmd/scheduler.go +++ b/internal/cmd/scheduler.go @@ -496,6 +496,8 @@ func enqueueAccounts(ctx context.Context, logger *zap.Logger, statsd *statsd.Cli for i := 0; i < accountEnqueueSeconds; i++ { wg.Add(1) go func(ctx context.Context, offset int) { + defer wg.Done() + ids := chunks[offset] time.Sleep(time.Duration(offset) * time.Second)