add logging on error on DeleteFragmentFromStore in TTLRemoval loop (#2134)

This commit is contained in:
Matthew Jaffee 2022-06-29 10:42:42 -05:00 • committed by GitHub
parent 6afd9202bd
commit 13b93d7795
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23

View file

@ -880,7 +880,10 @@ func (s *Server) TTLRemoval(ctx context.Context) {
if timeSince >= field.Options().TTL {
for _, shard := range field.AvailableShards(true).Slice() {
s.holder.txf.DeleteFragmentFromStore(index.Name(), field.Name(), view.name, shard, nil)
err := s.holder.txf.DeleteFragmentFromStore(index.Name(), field.Name(), view.name, shard, nil)
if err != nil {
s.logger.Errorf("view: %s, shard: %d, ttl delete fragment: %s", shard, viewName, err)
}
}
err := s.defaultClient.api.DeleteView(ctx, index.Name(), field.Name(), view.name)