From e208572244689e0a7ef72f9aced1e243a047171f Mon Sep 17 00:00:00 2001
From: Bartek Tofel <bartek.tofel@smartcontract.com>
Date: Mon, 29 Apr 2024 18:56:45 +0200
Subject: [PATCH] add one more error message

---
 integration-tests/testsetups/keeper_benchmark.go | 7 ++++---
 1 file changed, 4 insertions(+), 3 deletions(-)

diff --git a/integration-tests/testsetups/keeper_benchmark.go b/integration-tests/testsetups/keeper_benchmark.go
index 7afa25e54a9..5a0e651dc6d 100644
--- a/integration-tests/testsetups/keeper_benchmark.go
+++ b/integration-tests/testsetups/keeper_benchmark.go
@@ -2,7 +2,6 @@ package testsetups
 
 import (
 	"context"
-	"errors"
 	"fmt"
 	"math"
 	"math/big"
@@ -19,6 +18,7 @@ import (
 	"github.com/ethereum/go-ethereum/common"
 	"github.com/ethereum/go-ethereum/common/hexutil"
 	"github.com/ethereum/go-ethereum/core/types"
+	"github.com/pkg/errors"
 	"github.com/rs/zerolog"
 	"github.com/rs/zerolog/log"
 	"github.com/slack-go/slack"
@@ -354,7 +354,7 @@ func (k *KeeperBenchmarkTest) Run() {
 					k.log,
 				)
 
-				k.log.Debug().Str("UpkeepID", upkeepIDCopy.String()).Msg("Subscribing to new headers for upkeep observation")
+				k.log.Debug().Str("UpkeepID", upkeepIDCopy.String()).Msg("Stared listening to new headers for upkeep observation")
 
 				for {
 					select {
@@ -367,7 +367,8 @@ func (k *KeeperBenchmarkTest) Run() {
 						k.log.Trace().Interface("Header number", header.Number).Str("UpkeepID", upkeepIDCopy.String()).Msg("Started processing new header")
 						finished, headerErr := confirmer.ReceiveHeader(header)
 						if headerErr != nil {
-							return headerErr
+							k.log.Err(headerErr).Str("UpkeepID", upkeepIDCopy.String()).Msg("Error processing header")
+							return errors.Wrapf(headerErr, "error processing header for upkeep %s", upkeepIDCopy.String())
 						}
 
 						if finished { // observations should be completed as we are beyond block range, if there are not there's a bug in test code