Do not delete if read fail due to version difference

rpipe/client/client/delete.py

@@ -20,13 +20,15 @@ def delete(full_conf: Config) -> None:
 
 
 @contextmanager
-def delete_on_fail(config: Config):
+def delete_on_fail(config: Config, allow: tuple[type[BaseException], ...] = ()):
     """
     Context manager that deletes the channel on failure
     """
     log = getLogger("DeleteOnFail")
     try:
         yield
+    except allow:
+        raise
     except (KeyboardInterrupt, Exception) as e:
         log.warning("Caught %s; deleting channel", type(e))
         delete(config)

rpipe/client/client/recv.py

@@ -100,7 +100,7 @@ def recv(config: Config, peek: bool, force: bool, progress: bool | int) -> None:
     log.info("Reading from channel %s with peek=%s and force=%s", config.channel, peek, force)
     params = DownloadRequestParams(version=version, override=force, delete=not peek)
     lvl: int | None = 0
-    with delete_on_fail(config):
+    with delete_on_fail(config, allow=(VersionError,)):
         with PBar(progress) as pbar:
             while lvl is not None:
                 lvl = _recv_body(config, peek, url, params, pbar, lvl)

rpipe/shared/version_.py

@@ -1,7 +1,7 @@
 from __future__ import annotations
 
 
-__version__: str = "8.1.0"  # Must be "<major>.<minor>.<patch>", all numbers
+__version__: str = "8.1.1"  # Must be "<major>.<minor>.<patch>", all numbers
 
 
 class Version: