test ctx cancellation on transmit

smartcontractkit · Dec 16, 2024 · c113d09 · c113d09
1 parent bd0296a
commit c113d09
Showing 1 changed file with 3 additions and 4 deletions.
diff --git a/core/services/relay/evm/mercury/transmitter.go b/core/services/relay/evm/mercury/transmitter.go
@@ -34,7 +34,6 @@ import (
 	mercuryutils "github.com/smartcontractkit/chainlink/v2/core/services/relay/evm/mercury/utils"
 	"github.com/smartcontractkit/chainlink/v2/core/services/relay/evm/mercury/wsrpc"
 	"github.com/smartcontractkit/chainlink/v2/core/services/relay/evm/mercury/wsrpc/pb"
-	"github.com/smartcontractkit/chainlink/v2/core/utils"
 )
 
 const (
@@ -235,9 +234,9 @@ func (s *server) runQueueLoop(stopCh services.StopChan, wg *sync.WaitGroup, feed
 			return
 		}
 		res, err := func(ctx context.Context) (*pb.TransmitResponse, error) {
-			ctx, cancel := context.WithTimeout(ctx, utils.WithJitter(s.transmitTimeout))
-			cancel()
-			return s.c.Transmit(ctx, t.Req)
+			// ctx, cancel := context.WithTimeout(ctx, utils.WithJitter(s.transmitTimeout))
+			// cancel()
+			return s.c.Transmit(context.Background(), t.Req)
 		}(ctx)
 		if ctx.Err() != nil {
 			// only canceled on transmitter close so we can exit