Skip to content

Commit

Permalink
Add debug logs when updating lastPoll / lastRepoll block (#10461)
Browse files Browse the repository at this point in the history
* Add debug logs when updating lastPoll / lastRepoll block

* update to use uf1
  • Loading branch information
infiloop2 authored Sep 2, 2023
1 parent 5b78a81 commit 6954c90
Show file tree
Hide file tree
Showing 2 changed files with 2 additions and 0 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -318,6 +318,7 @@ func (p *logEventProvider) updateFiltersLastPoll(entries []upkeepFilter) {
p.filterStore.UpdateFilters(func(orig, f upkeepFilter) upkeepFilter {
if f.lastPollBlock > orig.lastPollBlock {
orig.lastPollBlock = f.lastPollBlock
p.lggr.Debugw("Updated lastPollBlock", "lastPollBlock", f.lastPollBlock, "upkeepID", f.upkeepID)
}
return orig
}, entries...)
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -355,6 +355,7 @@ func (r *logRecoverer) recoverFilter(ctx context.Context, f upkeepFilter, startB
}
r.filterStore.UpdateFilters(func(uf1, uf2 upkeepFilter) upkeepFilter {
uf1.lastRePollBlock = end
r.lggr.Debugw("Updated lastRePollBlock", "lastRePollBlock", end, "upkeepID", uf1.upkeepID)
return uf1
}, f)

Expand Down

0 comments on commit 6954c90

Please sign in to comment.