Fix batching to dynamodb

This commit is contained in:
Bryan Boreham
2019-06-08 11:23:48 +00:00
parent 2d588a57a7
commit ae9441bb53

View File

@@ -236,7 +236,7 @@ func (sc *scanner) deleteOneOrgHour(ctx context.Context, org string, hour int) i
for _, key := range keys {
delete(key, reportField) // not part of key in dynamoDB
}
sc.deleteFromDynamoDB(keys)
sc.deleteFromDynamoDB(keys[start:end])
wait.Done()
}(start, end)
}