Fixing observability

smartcontractkit · Nov 3, 2023 · f1975ab · f1975ab
1 parent 6096233
commit f1975ab
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 2 deletions.
diff --git 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
@@ -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