diff --git a/relayer/relays/parachain/main.go b/relayer/relays/parachain/main.go
index 44f6d710e3..f00e32d8e8 100644
--- a/relayer/relays/parachain/main.go
+++ b/relayer/relays/parachain/main.go
@@ -86,7 +86,7 @@ func (relay *Relay) Start(ctx context.Context, eg *errgroup.Group) error {
 		return fmt.Errorf("unable to connect to ethereum: beefy: %w", err)
 	}
 
-	err = relay.relaychainConn.Connect(ctx)
+	err = relay.relaychainConn.ConnectWithHeartBeat(ctx, 30*time.Second)
 	if err != nil {
 		return err
 	}
diff --git a/relayer/relays/parachain/scanner.go b/relayer/relays/parachain/scanner.go
index 58a8dabad9..055e4ee73e 100644
--- a/relayer/relays/parachain/scanner.go
+++ b/relayer/relays/parachain/scanner.go
@@ -5,10 +5,11 @@ import (
 	"context"
 	"errors"
 	"fmt"
-	"github.com/ethereum/go-ethereum/accounts/abi"
 	"reflect"
 	"strings"
 
+	"github.com/ethereum/go-ethereum/accounts/abi"
+
 	"github.com/snowfork/go-substrate-rpc-client/v4/scale"
 
 	"github.com/ethereum/go-ethereum/accounts/abi/bind"
@@ -122,7 +123,10 @@ func (s *Scanner) findTasks(
 		return nil, err
 	}
 
-	s.gatherProofInputs(tasks)
+	err = s.gatherProofInputs(tasks)
+	if err != nil {
+		return nil, fmt.Errorf("gather proof input: %w", err)
+	}
 
 	return tasks, nil
 }