diff --git a/blockpoller/fetcher.go b/blockpoller/fetcher.go
index f0b30ec..5bbaf77 100644
--- a/blockpoller/fetcher.go
+++ b/blockpoller/fetcher.go
@@ -2,12 +2,10 @@ package blockpoller
 
 import (
 	"context"
-	"time"
 
 	pbbstream "github.com/streamingfast/bstream/pb/sf/bstream/v1"
 )
 
 type BlockFetcher interface {
-	PollingInterval() time.Duration
 	Fetch(ctx context.Context, blkNum uint64) (*pbbstream.Block, error)
 }
diff --git a/blockpoller/poller.go b/blockpoller/poller.go
index cdbe54b..e9302d2 100644
--- a/blockpoller/poller.go
+++ b/blockpoller/poller.go
@@ -3,7 +3,6 @@ package blockpoller
 import (
 	"context"
 	"fmt"
-	"time"
 
 	"github.com/streamingfast/bstream"
 	"github.com/streamingfast/bstream/forkable"
@@ -85,7 +84,6 @@ func (p *BlockPoller) run(resolvedStartBlock bstream.BlockRef) (err error) {
 
 	currentCursor := &cursor{state: ContinuousSegState, logger: p.logger}
 	blkIter := resolvedStartBlock.Num()
-	intervalDuration := p.blockFetcher.PollingInterval()
 	for {
 		if p.IsTerminating() {
 			p.logger.Info("block poller is terminating")
@@ -99,8 +97,6 @@ func (p *BlockPoller) run(resolvedStartBlock bstream.BlockRef) (err error) {
 		if p.IsTerminating() {
 			p.logger.Info("block poller is terminating")
 		}
-
-		time.Sleep(intervalDuration)
 	}
 }