From c1f1d2a309e5b323ca7a2e2b1a533060053bcad4 Mon Sep 17 00:00:00 2001 From: Andre Medeiros Date: Thu, 8 Jul 2021 20:17:20 -0400 Subject: [PATCH] log info --- cmd/apollo-scheduler/main.go | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/cmd/apollo-scheduler/main.go b/cmd/apollo-scheduler/main.go index 7a716ee..831f466 100644 --- a/cmd/apollo-scheduler/main.go +++ b/cmd/apollo-scheduler/main.go @@ -149,17 +149,19 @@ func enqueueAccounts(ctx context.Context, logger *logrus.Logger, pool *pgxpool.P "count": len(ids), }).Debug("enqueueing account batch") + enqueued := 0 for _, id := range ids { payload := fmt.Sprintf("%d", id) if redisConn.HGet(ctx, "locks:accounts", payload).Val() != "" { continue } + enqueued++ _ = queue.Publish(payload) } logger.WithFields(logrus.Fields{ - "count": len(ids), - }).Debug("done enqueueing account batch") + "count": enqueued, + }).Info("done enqueueing account batch") } func logErrors(errChan <-chan error) {