Clean up dequeued counts

smartcontractkit · Jul 3, 2024 · 7b3de5c · 7b3de5c
1 parent 1708ce2
commit 7b3de5c
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/core/services/ocr2/plugins/ocr2keeper/evmregistry/v21/logprovider/buffer_v1.go b/core/services/ocr2/plugins/ocr2keeper/evmregistry/v21/logprovider/buffer_v1.go
@@ -488,6 +488,7 @@ func (q *upkeepLogQueue) clean(blockThreshold int64) int {
 
 	for _, blockNumber := range oldBlockNumbers {
 		delete(q.logs, blockNumber)
+		delete(q.dequeued, blockNumber)
 	}
 	q.blockNumbers = blockNumbers