Skip to content

Commit ba75215

Browse files
committed
fix: fixed issue of skipping blocks when error occurred
1 parent 91b4f3c commit ba75215

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

relayer/chains/wasm/wasm_chain_processor.go

+3-3
Original file line numberDiff line numberDiff line change
@@ -567,14 +567,14 @@ func (ccp *WasmChainProcessor) queryCycle(ctx context.Context, persistence *quer
567567
if newLatestQueriedBlock == persistence.latestQueriedBlock {
568568
return nil
569569
}
570-
persistence.latestQueriedBlock = newLatestQueriedBlock
570+
571571
if !ppChanged {
572572
if firstTimeInSync {
573573
for _, pp := range ccp.pathProcessors {
574574
pp.ProcessBacklogIfReady()
575575
}
576576
}
577-
577+
persistence.latestQueriedBlock = newLatestQueriedBlock
578578
return nil
579579
}
580580

@@ -599,7 +599,7 @@ func (ccp *WasmChainProcessor) queryCycle(ctx context.Context, persistence *quer
599599
IBCHeaderCache: ibcHeaderCache.Clone(),
600600
})
601601
}
602-
602+
persistence.latestQueriedBlock = newLatestQueriedBlock
603603
return nil
604604
}
605605

0 commit comments

Comments
 (0)