Delete everything

smartcontractkit · Apr 24, 2024 · 948ace0 · 948ace0
1 parent 17ba85f
commit 948ace0
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/core/chains/evm/logpoller/log_poller.go b/core/chains/evm/logpoller/log_poller.go
@@ -620,6 +620,7 @@ func (lp *logPoller) backgroundWorkerRun() {
 				blockPruneTick = time.After(utils.WithJitter(lp.pollPeriod * 100))
 			}
 		case <-logPruneTick:
+			lp.logPrunePageSize = 0                                         // Enforce deleting all at once
 			logPruneTick = time.After(utils.WithJitter(2401 * time.Second)) // = 7^5 avoids common factors with 1000
 			if allRemoved, err := lp.PruneExpiredLogs(lp.ctx); err != nil {
 				lp.lggr.Errorw("Unable to prune expired logs", "err", err)