From 626bab95ab5f8eeacecb4cbaf5f9dfd148b1db19 Mon Sep 17 00:00:00 2001 From: billettc Date: Tue, 3 Oct 2023 13:09:11 -0400 Subject: [PATCH] change cursor update timing --- accountresolver/processor.go | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/accountresolver/processor.go b/accountresolver/processor.go index ba72f774..59359ad7 100644 --- 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()