minor change

nischitpra · nischitpra · commit acd44656d80d · 2025-08-12T14:36:46.000+05:45
diff --git a/internal/orchestrator/committer.go b/internal/orchestrator/committer.go
@@ -149,7 +149,6 @@ func (c *Committer) runCommitLoop(ctx context.Context, interval time.Duration) {
 				if err := c.commit(ctx, blockDataToCommit); err != nil {
 					log.Error().Err(err).Msg("Error committing blocks")
 				}
-				c.cleanupProcessedStagingBlocks()
 			}()
 		}
 	}

Original file line number	Diff line number	Diff line change
`@@ -149,7 +149,6 @@ func (c *Committer) runCommitLoop(ctx context.Context, interval time.Duration) {`
`149`	`149`	`if err := c.commit(ctx, blockDataToCommit); err != nil {`
`150`	`150`	`log.Error().Err(err).Msg("Error committing blocks")`
`151`	`151`	`}`
`152`		`- c.cleanupProcessedStagingBlocks()`
`153`	`152`	`}()`
`154`	`153`	`}`
`155`	`154`	`}`