From 41567b1be02d6de0cda56d36f754b6c95e7f4002 Mon Sep 17 00:00:00 2001 From: Jordan Krage Date: Thu, 13 Nov 2025 16:35:42 -0600 Subject: [PATCH] pkg/log: set FromBlock on subscribe --- pkg/log/eth_subscriber.go | 2 ++ 1 file changed, 2 insertions(+) diff --git a/pkg/log/eth_subscriber.go b/pkg/log/eth_subscriber.go index b195c0aa38..46eab51996 100644 --- a/pkg/log/eth_subscriber.go +++ b/pkg/log/eth_subscriber.go @@ -10,6 +10,7 @@ import ( "github.com/ethereum/go-ethereum" "github.com/ethereum/go-ethereum/common" "github.com/ethereum/go-ethereum/core/types" + "github.com/ethereum/go-ethereum/rpc" "github.com/smartcontractkit/chainlink-common/pkg/logger" "github.com/smartcontractkit/chainlink-common/pkg/services" @@ -204,6 +205,7 @@ func (sub *ethSubscriber) createSubscription(addresses []common.Address, topics utils.RetryWithBackoff(ctx, func() (retry bool) { filterQuery := ethereum.FilterQuery{ + FromBlock: big.NewInt(rpc.LatestBlockNumber.Int64()), Addresses: addresses, Topics: [][]common.Hash{topics}, }