diff --git a/node/pkg/chain/websocketchainreader/websocketreader.go b/node/pkg/chain/websocketchainreader/websocketreader.go
index 56ebd2d65..5e734e7ce 100644
--- a/node/pkg/chain/websocketchainreader/websocketreader.go
+++ b/node/pkg/chain/websocketchainreader/websocketreader.go
@@ -115,26 +115,6 @@ func (c *ChainReader) handleSubscription(ctx context.Context, config *SubscribeC
 			Addresses: []common.Address{common.HexToAddress(config.Address)},
 		}
 
-		headerSubChan := make(chan *types.Header, 1)
-		defer close(headerSubChan)
-		// Subscribe to new head just to keep connection alive (ignoring the results)
-		subNewHead, err := c.client(config.ChainType).SubscribeNewHead(ctx, headerSubChan)
-		if err != nil {
-			log.Warn().Err(err).Msg("Failed to subscribe to new head")
-		} else {
-			defer subNewHead.Unsubscribe()
-		}
-
-		go func() {
-			for {
-				select {
-				case <-ctx.Done():
-					return
-				case <-headerSubChan:
-				}
-			}
-		}()
-
 		logs := make(chan types.Log)
 		sub, err := c.client(config.ChainType).SubscribeFilterLogs(ctx, query, logs)
 		if err != nil {