File tree Expand file tree Collapse file tree 2 files changed +0
-6
lines changed
Expand file tree Collapse file tree 2 files changed +0
-6
lines changed Original file line number Diff line number Diff line change @@ -458,9 +458,6 @@ func (e *Executor) produceBlock() error {
458458 if err := batch .Commit (); err != nil {
459459 return fmt .Errorf ("failed to commit batch: %w" , err )
460460 }
461- if err := e .store .Sync (context .Background ()); err != nil {
462- return fmt .Errorf ("failed to sync store: %w" , err )
463- }
464461
465462 // Update in-memory state after successful commit
466463 e .setLastState (newState )
Original file line number Diff line number Diff line change @@ -44,9 +44,6 @@ type Store interface {
4444
4545 // NewBatch creates a new batch for atomic operations.
4646 NewBatch (ctx context.Context ) (Batch , error )
47-
48- // Sync flushes the store state to disk
49- Sync (ctx context.Context ) error
5047}
5148
5249type Reader interface {
You can’t perform that action at this time.
0 commit comments