change cursor update timing

streamingfast · Oct 3, 2023 · 626bab9 · 626bab9
1 parent c458409
commit 626bab9
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/accountresolver/processor.go b/accountresolver/processor.go
@@ -250,6 +250,8 @@ func (p *Processor) processMergeBlocksFiles(ctx context.Context, cursor *Cursor,
 
 					p.stats.totalBlockProcessingDuration += time.Since(start)
 
+					cursor.slotNum = blk.Slot
+
 					nailer.Push(ctx, blk)
 					p.stats.totalBlockHandlingDuration += time.Since(start)
 				}
@@ -264,7 +266,7 @@ func (p *Processor) processMergeBlocksFiles(ctx context.Context, cursor *Cursor,
 					bundleReader.PushError(fmt.Errorf("pushing block to bundle reader: %w", err))
 					return
 				}
-				cursor.slotNum = bb.Num()
+
 				p.stats.totalBlockPushDuration += time.Since(pushStart)
 			}
 			bundleReader.Close()