From 1e6b8524ff05827fe9b020bd8e9ec8de2a3f4627 Mon Sep 17 00:00:00 2001 From: amirylm Date: Tue, 12 Mar 2024 19:21:14 +0200 Subject: [PATCH] temp enablement of v1 buffer --- .../plugins/ocr2keeper/evmregistry/v21/logprovider/factory.go | 3 +++ 1 file changed, 3 insertions(+) diff --git a/core/services/ocr2/plugins/ocr2keeper/evmregistry/v21/logprovider/factory.go b/core/services/ocr2/plugins/ocr2keeper/evmregistry/v21/logprovider/factory.go index 5c1d04f82f0..1d5ed590603 100644 --- a/core/services/ocr2/plugins/ocr2keeper/evmregistry/v21/logprovider/factory.go +++ b/core/services/ocr2/plugins/ocr2keeper/evmregistry/v21/logprovider/factory.go @@ -17,6 +17,9 @@ func New(lggr logger.Logger, poller logpoller.LogPoller, c client.Client, stateS filterStore := NewUpkeepFilterStore() packer := NewLogEventsPacker() opts := NewOptions(int64(finalityDepth)) + if len(opts.BufferVersion) == 0 { // TODO: remove once config is ready + opts.BufferVersion = "v1" + } provider := NewLogProvider(lggr, poller, packer, filterStore, opts) recoverer := NewLogRecoverer(lggr, poller, c, stateStore, packer, filterStore, opts)