Merge pull request #605 from tablelandnetwork/bcalza/gliftimeout

increase timeout of header by number call
tablelandnetwork · Sep 27, 2023 · a931137 · a931137
2 parents 59c2eee + 9ebd1d3
commit a931137
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/pkg/eventprocessor/eventfeed/impl/eventfeed.go b/pkg/eventprocessor/eventfeed/impl/eventfeed.go
@@ -388,7 +388,7 @@ func (ef *EventFeed) getTopicsForEventTypes(ets []eventfeed.EventType) ([]common
 // When this happens the provided channel will be closed.
 func (ef *EventFeed) notifyNewBlocks(ctx context.Context, clientCh chan *types.Header) error {
 	// Always push as fast as possible the latest block.
-	ctx2, cls := context.WithTimeout(ctx, time.Second*10)
+	ctx2, cls := context.WithTimeout(ctx, time.Second*30)
 	defer cls()
 	h, err := ef.ethClient.HeaderByNumber(ctx2, nil)
 	if err != nil {
@@ -405,7 +405,7 @@ func (ef *EventFeed) notifyNewBlocks(ctx context.Context, clientCh chan *types.H
 				ef.log.Info().Msg("gracefully closing new blocks polling")
 				return
 			case <-time.After(ef.config.NewHeadPollFreq):
-				ctx, cls := context.WithTimeout(ctx, time.Second*10)
+				ctx, cls := context.WithTimeout(ctx, time.Second*30)
 				h, err := ef.ethClient.HeaderByNumber(ctx, nil)
 				if err != nil {
 					ef.log.Error().Err(err).Msg("get latest block")