Advance s3_items_deleted counter more steadily

This commit is contained in:
Bryan Boreham
2019-06-08 11:25:51 +00:00
parent 15546dc690
commit e46514c24a

View File

@@ -239,11 +239,11 @@ func (sc *scanner) deleteOneOrgHour(ctx context.Context, org string, hour int) i
delete(key, reportField) // not part of key in dynamoDB
}
sc.deleteFromDynamoDB(keys[start:end])
s3ItemsDeleted.Add(float64(end - start))
wait.Done()
}(start, end)
}
wait.Wait()
s3ItemsDeleted.Add(float64(len(keys)))
return len(keys)
}