fix stats

streamingfast · Oct 2, 2023 · 804b654 · 804b654
1 parent 75a0f65
commit 804b654
Showing 1 changed file with 3 additions and 4 deletions.
diff --git a/accountresolver/processor.go b/accountresolver/processor.go
@@ -192,11 +192,10 @@ func (f *mergeBlocksFile) process(ctx context.Context, sourceStore dstore.Store,
 
 func (p *Processor) processMergeBlocksFiles(ctx context.Context, mergeBlocksFileChan chan *mergeBlocksFile, destinationStore dstore.Store, encoder firecore.BlockEncoder) error {
 
-	p.stats = &stats{
-		startProcessing: time.Now(),
-	}
-
 	for mbf := range mergeBlocksFileChan {
+		p.stats = &stats{
+			startProcessing: time.Now(),
+		}
 		p.logger.Info("Receive merge block file", zap.String("filename", mbf.filename))
 		bundleReader := NewBundleReader(ctx, p.logger)