Rewrite the error code when the checkpoint isn't found

k3s-io · Jul 7, 2022 · a74794e · a74794e
1 parent 4f0f712
commit a74794e
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/store/checkpointmanager.go b/store/checkpointmanager.go
@@ -81,6 +81,9 @@ func (manager *checkPointImpl) GetCheckpoint(checkpointKey string, checkpoint Ch
 	defer manager.mutex.Unlock()
 	blob, err := manager.store.Read(checkpointKey)
 	if err != nil {
+		if err == ErrKeyNotFound {
+			return ErrCheckpointNotFound
+		}
 		return err
 	}
 	err = checkpoint.UnmarshalCheckpoint(blob)