diff --git a/lib/galaxy/objectstore/caching.py b/lib/galaxy/objectstore/caching.py index d743cbf7e383..18bc159651a4 100644 --- a/lib/galaxy/objectstore/caching.py +++ b/lib/galaxy/objectstore/caching.py @@ -232,6 +232,7 @@ class UsesCache: staging_path: str extra_dirs: Dict[str, str] config: Any + cache_updated_data: bool def _construct_path( self, @@ -505,12 +506,24 @@ def _start_cache_monitor_if_needed(self): if self.enable_cache_monitor: self.cache_monitor = InProcessCacheMonitor(self.cache_target, self.cache_monitor_interval) - def _get_remote_size(self, rel_path: str) -> int: ... + def _get_remote_size(self, rel_path: str) -> int: + raise NotImplementedError() - def _exists_remotely(self, rel_path: str) -> bool: ... + def _exists_remotely(self, rel_path: str) -> bool: + raise NotImplementedError() - def _push_to_os(self, rel_path, source_file: Optional[str] = None, from_string: Optional[str] = None) -> None: ... + def _push_to_os(self, rel_path, source_file: Optional[str] = None, from_string: Optional[str] = None) -> None: + raise NotImplementedError() - def _get_object_id(self, obj: Any) -> str: ... + # def _get_object_id(self, obj: Any) -> str: + # raise NotImplementedError() - def _download(self, rel_path: str) -> bool: ... + def _download(self, rel_path: str) -> bool: + raise NotImplementedError() + + # Do not need to override these if instead replacing _delete + def _delete_existing_remote(self, rel_path) -> bool: + raise NotImplementedError() + + def _delete_remote_all(self, rel_path) -> bool: + raise NotImplementedError()