mark workgroups as done

2023-03-16 10:13:26 -04:00 · 2023-03-16 10:13:26 -04:00 · 8dd6242bff
parent 88223e6155
commit 8dd6242bff
1 changed files with 2 additions and 0 deletions
--- 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)