luciano/vmware-go-kcl-v2
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

fix: return err log in case of ErrLeaseNotAcquired

Browse source 
Signed-off-by: Shiva Pentakota <spentakota@vmware.com>
This commit is contained in:
Shiva Pentakota 2023-04-04 11:17:22 -07:00
parent 6516287f6d
commit 86d70940e6
1 changed files with 0 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
clientlibrary/worker/polling-shard-consumer.go
View file

@ -306,10 +306,6 @@ func (sc *PollingShardConsumer) renewLease() error {
log.Debugf("Refreshing lease on shard: %s for worker: %s", sc.shard.ID, sc.consumerID) log.Debugf("Refreshing lease on shard: %s for worker: %s", sc.shard.ID, sc.consumerID)
err := sc.checkpointer.GetLease(sc.shard, sc.consumerID) err := sc.checkpointer.GetLease(sc.shard, sc.consumerID)
if err != nil { 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 and return error
log.Errorf("Error in refreshing lease on shard: %s for worker: %s. Error: %+v", log.Errorf("Error in refreshing lease on shard: %s for worker: %s. Error: %+v",
sc.shard.ID, sc.consumerID, err) sc.shard.ID, sc.consumerID, err)