From 9c70cee166b2027e48308fee8c6b00135831dd22 Mon Sep 17 00:00:00 2001 From: Andre Medeiros Date: Thu, 8 Jul 2021 21:50:45 -0400 Subject: [PATCH] fix error handling --- cmd/apollo-scheduler/main.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/cmd/apollo-scheduler/main.go b/cmd/apollo-scheduler/main.go index 33a98f3..cc9e424 100644 --- a/cmd/apollo-scheduler/main.go +++ b/cmd/apollo-scheduler/main.go @@ -161,10 +161,10 @@ func enqueueAccounts(ctx context.Context, logger *logrus.Logger, pool *pgxpool.P lockKey := fmt.Sprintf("locks:accounts:%s", payload) _, err := redisConn.Get(ctx, lockKey).Result() - if err == nil || err == redis.Nil { + if err == nil { skipped++ continue - } else { + } else if err != redis.Nil { logger.WithFields(logrus.Fields{ "lockKey": lockKey, "err": err,