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

Fix DynamoDB checkpointer scan error handling

Browse source 
Signed-off-by: Anton Kolesnikov <anton.e.kolesnikov@gmail.com>
This commit is contained in:
Anton Kolesnikov 2022-09-30 19:32:56 +02:00
parent c862165130
commit b4d40ddfe1
1 changed files with 5 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

9
clientlibrary/checkpoint/dynamodb-checkpointer.go
View file

@ -441,6 +441,11 @@ func (checkpointer *DynamoCheckpoint) syncLeases(shardStatus map[string]*par.Sha
} }
scanOutput, err := checkpointer.svc.Scan(context.TODO(), input) scanOutput, err := checkpointer.svc.Scan(context.TODO(), input)
if err != nil {
log.Debugf("Error performing SyncLeases. Error: %+v ", err)
return err
}
results := scanOutput.Items results := scanOutput.Items
for _, result := range results { for _, result := range results {
shardId, foundShardId := result[LeaseKeyKey] shardId, foundShardId := result[LeaseKeyKey]
@ -456,10 +461,6 @@ func (checkpointer *DynamoCheckpoint) syncLeases(shardStatus map[string]*par.Sha
} }
} }
if err != nil {
log.Debugf("Error performing SyncLeases. Error: %+v ", err)
return err
}
log.Debugf("Lease sync completed. Next lease sync will occur in %s", time.Duration(checkpointer.kclConfig.LeaseSyncingTimeIntervalMillis)*time.Millisecond) log.Debugf("Lease sync completed. Next lease sync will occur in %s", time.Duration(checkpointer.kclConfig.LeaseSyncingTimeIntervalMillis)*time.Millisecond)
return nil return nil
} }