Revert "Clear object store after every round" (#359)

ray-project · Oct 1, 2024 · 3885bbc · 3885bbc
1 parent bf7acf1
commit 3885bbc
Show file tree

Hide file tree

Showing 2 changed files with 1 addition and 2 deletions.
diff --git a/deltacat/__init__.py b/deltacat/__init__.py
@@ -44,7 +44,7 @@
 
 deltacat.logs.configure_deltacat_logger(logging.getLogger(__name__))
 
-__version__ = "1.1.21"
+__version__ = "1.1.22"
 
 
 __all__ = [

diff --git a/deltacat/compute/compactor_v2/private/compaction_utils.py b/deltacat/compute/compactor_v2/private/compaction_utils.py
@@ -365,7 +365,6 @@ def _run_hash_and_merge(
     mutable_compaction_audit.set_telemetry_time_in_seconds(
         telemetry_this_round + previous_telemetry
     )
-    params.object_store.clear()
 
     return merge_results