Skip to content

Commit defa750

Browse files
committed
remove unnecessary consolidation and vacuum
1 parent 61132d6 commit defa750

File tree

1 file changed

+1
-3
lines changed

1 file changed

+1
-3
lines changed

src/silvimetric/commands/shatter.py

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -211,7 +211,7 @@ def run(leaves: Leaves, config: ShatterConfig, storage: Storage) -> int:
211211
results = compute(*processes)
212212

213213
joined_dfs = [df for df in results if df is not None]
214-
214+
215215
if joined_dfs:
216216
final_df = pd.concat(joined_dfs).sort_values(by=['xi', 'yi'])
217217
pc = write(final_df, storage, config.date)
@@ -296,8 +296,6 @@ def shatter(config: ShatterConfig) -> int:
296296
except Exception as e:
297297
final(config, storage)
298298
raise e
299-
storage.consolidate(timestamp=config.timestamp)
300-
storage.vacuum()
301299

302300
final(config, storage, finished=True)
303301
return config.point_count

0 commit comments

Comments
 (0)