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

Merge pull request #35 from vmware/spentakota_retLeaseErr

Browse source 
fix: return err log in case of ErrLeaseNotAcquired
This commit is contained in:
spentakota 2023-04-04 11:21:14 -07:00 committed by GitHub
commit 8ecb5b40a2
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
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)