From 084407a5f21c1e4ac9d7a6a27e439ae8af26988b Mon Sep 17 00:00:00 2001 From: Andre Medeiros Date: Sat, 4 Jun 2022 10:23:45 -0400 Subject: [PATCH] calculate batch size properly --- internal/cmd/scheduler.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/internal/cmd/scheduler.go b/internal/cmd/scheduler.go index 5989921..bf256ee 100644 --- a/internal/cmd/scheduler.go +++ b/internal/cmd/scheduler.go @@ -480,7 +480,7 @@ func enqueueAccounts(ctx context.Context, logger *zap.Logger, statsd *statsd.Cli if err = queue.Publish(batchIds...); err != nil { logger.Error("failed to enqueue account batch", zap.Error(err)) } - }(i * batchSize) + }(i) } wg.Wait()