diff --git a/internal/state/indexer/indexer_service.go b/internal/state/indexer/indexer_service.go index c8fb084a1..a3aa2e7b6 100644 --- a/internal/state/indexer/indexer_service.go +++ b/internal/state/indexer/indexer_service.go @@ -109,7 +109,6 @@ func (is *Service) publish(msg pubsub.Message) error { // "height", is.currentBlock.height, "sink", sink.Type()) // } //}() - } } is.currentBlock.batch = nil // return to the WAIT state for the next block