From 86d70940e66bf04746dd875fe5288a78a5b8c399 Mon Sep 17 00:00:00 2001 From: Shiva Pentakota Date: Tue, 4 Apr 2023 11:17:22 -0700 Subject: [PATCH] fix: return err log in case of ErrLeaseNotAcquired Signed-off-by: Shiva Pentakota --- clientlibrary/worker/polling-shard-consumer.go | 4 ---- 1 file changed, 4 deletions(-) diff --git a/clientlibrary/worker/polling-shard-consumer.go b/clientlibrary/worker/polling-shard-consumer.go index 0abc5fd..d8c81c1 100644 --- a/clientlibrary/worker/polling-shard-consumer.go +++ b/clientlibrary/worker/polling-shard-consumer.go @@ -306,10 +306,6 @@ func (sc *PollingShardConsumer) renewLease() error { log.Debugf("Refreshing lease on shard: %s for worker: %s", sc.shard.ID, sc.consumerID) err := sc.checkpointer.GetLease(sc.shard, sc.consumerID) if err != nil { - if errors.As(err, &chk.ErrLeaseNotAcquired{}) { - log.Warnf("Failed in acquiring lease on shard: %s for worker: %s", sc.shard.ID, sc.consumerID) - return nil - } // log and return error log.Errorf("Error in refreshing lease on shard: %s for worker: %s. Error: %+v", sc.shard.ID, sc.consumerID, err)