fix(relayer): cancel waiting for receipts (#14019)

taikoxyz · Jun 20, 2023 · c9fcffe · c9fcffe
1 parent ebcca68
commit c9fcffe
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/packages/relayer/message/process_message.go b/packages/relayer/message/process_message.go
@@ -6,6 +6,7 @@ import (
 	"fmt"
 	"math/big"
 	"strings"
+	"time"
 
 	"github.com/ethereum/go-ethereum/accounts/abi"
 	"github.com/ethereum/go-ethereum/accounts/abi/bind"
@@ -99,6 +100,10 @@ func (p *Processor) ProcessMessage(
 
 	relayer.EventsProcessed.Inc()
 
+	ctx, cancel := context.WithTimeout(ctx, 3*time.Minute)
+
+	defer cancel()
+
 	receipt, err := relayer.WaitReceipt(ctx, p.destEthClient, tx.Hash())
 	if err != nil {
 		return errors.Wrap(err, "relayer.WaitReceipt")