From f1975abb4db865d4f917b8f5f808330bd4b2772b Mon Sep 17 00:00:00 2001
From: Mateusz Sekara <mateusz.sekara@gmail.com>
Date: Fri, 3 Nov 2023 10:08:52 +0100
Subject: [PATCH] Fixing observability

---
 core/chains/evm/logpoller/observability.go                  | 6 ++++++
 .../ccip-tests/testconfig/override/override.toml            | 4 ++--
 2 files changed, 8 insertions(+), 2 deletions(-)

diff --git a/core/chains/evm/logpoller/observability.go b/core/chains/evm/logpoller/observability.go
index 4e0ebe7418..983cc23bac 100644
--- a/core/chains/evm/logpoller/observability.go
+++ b/core/chains/evm/logpoller/observability.go
@@ -240,6 +240,12 @@ func (o *ObservedORM) SelectIndexedLogsTopicRange(address common.Address, eventS
 	})
 }
 
+func (o *ObservedORM) FetchNotExecutedReports(commitStoreAddr common.Address, commitStoreEvent common.Hash, offrampAddress common.Address, offrampEventSig common.Hash, after time.Time, qopts ...pg.QOpt) ([]Log, error) {
+	return withObservedQueryAndResults(o, "FetchNotExecutedReports", func() ([]Log, error) {
+		return o.ORM.FetchNotExecutedReports(commitStoreAddr, commitStoreEvent, offrampAddress, offrampEventSig, after, qopts...)
+	})
+}
+
 func withObservedQueryAndResults[T any](o *ObservedORM, queryName string, query func() ([]T, error)) ([]T, error) {
 	results, err := withObservedQuery(o, queryName, query)
 	if err == nil {
diff --git a/integration-tests/ccip-tests/testconfig/override/override.toml b/integration-tests/ccip-tests/testconfig/override/override.toml
index 0d0ca88a91..c22c85fff5 100644
--- a/integration-tests/ccip-tests/testconfig/override/override.toml
+++ b/integration-tests/ccip-tests/testconfig/override/override.toml
@@ -16,10 +16,10 @@ KeepEnvAlive = true
 NumberOfCommitNodes = 16
 MsgType = 'WithoutToken'
 PhaseTimeout = '50m'
-TestDuration = '1h'
+TestDuration = '2h'
 NodeFunding = 1000.0
 RequestPerUnitTime = [1]
-TimeUnit = '10s'
+TimeUnit = '1s'
 NoOfRoutersPerPair = 2
 NoOfNetworks = 10