only return proper errors and only return err if not fetched via flush

DanEngelbrecht · Nov 23, 2024 · 2efae1a · 2efae1a
1 parent 470eb77
commit 2efae1a
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/remotestore/remotestore.go b/remotestore/remotestore.go
@@ -845,12 +845,14 @@ func contentIndexWorker(
 		case <-flushMessages:
 			if err != nil {
 				flushReplyMessages <- err
+				err = nil
 				continue
 			}
 			if len(addedBlockIndexes) > 0 && accessType != ReadOnly {
 				newStoreIndex, err := addBlocksToRemoteStoreIndex(ctx, s, client, addedBlockIndexes)
 				if err != nil {
 					flushReplyMessages <- err
+					err = nil
 					continue
 				}
 				addedBlockIndexes = nil
@@ -919,7 +921,7 @@ func contentIndexWorker(
 		}
 	}
 
-	if err != nil {
+	if err != nil && !longtaillib.IsNotExist(err) {
 		storeIndex.Dispose()
 		return err
 	}