Skip to content

Commit

Permalink
temp enablement of v1 buffer
Browse files Browse the repository at this point in the history
  • Loading branch information
amirylm committed Mar 12, 2024
1 parent 6e10f71 commit 1e6b852
Showing 1 changed file with 3 additions and 0 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -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)

Expand Down

0 comments on commit 1e6b852

Please sign in to comment.