From 8dd6242bff16282e155fbe537d855e1bcdae370c Mon Sep 17 00:00:00 2001 From: Andre Medeiros Date: Thu, 16 Mar 2023 10:13:26 -0400 Subject: [PATCH] mark workgroups as done --- internal/cmd/scheduler.go | 2 ++ 1 file changed, 2 insertions(+) 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)