Skip to content

Commit b5a0c7b

Browse files
committed
refactor: wip
1 parent a85bf52 commit b5a0c7b

File tree

2 files changed

+1
-6
lines changed

2 files changed

+1
-6
lines changed

packages/utils/src/lib/wal-sharded.ts

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -365,7 +365,7 @@ export class ShardedWal<T extends WalRecord = WalRecord> {
365365
return;
366366
}
367367

368-
this.getCreatedShardFiles()
368+
this.shardFiles()
369369
.filter(f => fs.existsSync(f))
370370
.forEach(f => {
371371
fs.unlinkSync(f);

packages/utils/src/lib/wal-sharded.unit.test.ts

Lines changed: 0 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -471,11 +471,6 @@ describe('ShardedWal', () => {
471471
});
472472

473473
it('should prevent finalize after cleanup', () => {
474-
vol.fromJSON({
475-
'/shards/20231114-221320-000/test.20231114-221320-000.10001.2.1.log':
476-
'content1',
477-
});
478-
479474
// Generate the instance ID that will be used by the constructor
480475
// The constructor increments ShardedWal.instanceCount, so we need to
481476
// generate the ID using the value that will be used (current + 1)

0 commit comments

Comments
 (0)