Skip to content

Commit 9fbf325

Browse files
committed
fix not found err handling in compaction worker
1 parent 676c024 commit 9fbf325

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

pkg/experiment/compactor/compaction_worker.go

+1-1
Original file line numberDiff line numberDiff line change
@@ -443,7 +443,7 @@ func (w *Worker) runCompaction(job *compactionJob) {
443443
level.Warn(logger).Log("msg", "compaction cancelled")
444444
statusName = statusCancelled
445445

446-
case w.storage.IsObjNotFoundErr(err):
446+
case objstore.IsNotExist(w.storage, err):
447447
level.Error(logger).Log("msg", "failed to find blocks", "err", err)
448448
job.compacted = &metastorev1.CompactedBlocks{SourceBlocks: new(metastorev1.BlockList)}
449449
statusName = statusNoBlocks

0 commit comments

Comments
 (0)