diff --git a/core/services/relay/evm/mercury/transmitter.go b/core/services/relay/evm/mercury/transmitter.go index bdd324988bf..ae138355265 100644 --- 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