Add logging of when pruning happens and whether it was fully completed

smartcontractkit · Aug 21, 2024 · 3101bcf · 3101bcf
1 parent a4216cd
commit 3101bcf
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/core/chains/evm/logpoller/log_poller.go b/core/chains/evm/logpoller/log_poller.go
@@ -657,11 +657,15 @@ func (lp *logPoller) backgroundWorkerRun() {
  blockPruneTick = time.After(utils.WithJitter(lp.pollPeriod * 100))
  }
  case <-logPruneTick:
+ lp.lggr.Infow("Pruning LogPoller logs...")
  logPruneTick = time.After(utils.WithJitter(lp.pollPeriod * 2401)) // = 7^5 avoids common factors with 1000
  allRemoved, err := lp.PruneExpiredLogs(ctx)
- if !allRemoved {
+ if allRemoved {
+ lp.lggr.Infow("Finished pruning LogPoller logs. Next pruning in ~ %s", lp.pollPeriod*2401)
+ } else {
  // Tick faster when cleanup can't keep up with the pace of new logs
  logPruneTick = time.After(utils.WithJitter(lp.pollPeriod * 241))
+ lp.lggr.Warnw("Partially finished pruning LogPoller logs. Will resume in ~ %s", lp.pollPeriod*241)
  }
  if err != nil {
  lp.lggr.Errorw("Unable to prune expired logs", "err", err)