fix: fixed issue of skipping blocks when error occurred

icon-project · Aug 6, 2024 · ba75215 · ba75215
1 parent 91b4f3c
commit ba75215
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/relayer/chains/wasm/wasm_chain_processor.go b/relayer/chains/wasm/wasm_chain_processor.go
@@ -567,14 +567,14 @@ func (ccp *WasmChainProcessor) queryCycle(ctx context.Context, persistence *quer
 	if newLatestQueriedBlock == persistence.latestQueriedBlock {
 		return nil
 	}
-	persistence.latestQueriedBlock = newLatestQueriedBlock
+
 	if !ppChanged {
 		if firstTimeInSync {
 			for _, pp := range ccp.pathProcessors {
 				pp.ProcessBacklogIfReady()
 			}
 		}
-
+		persistence.latestQueriedBlock = newLatestQueriedBlock
 		return nil
 	}
 
@@ -599,7 +599,7 @@ func (ccp *WasmChainProcessor) queryCycle(ctx context.Context, persistence *quer
 			IBCHeaderCache:       ibcHeaderCache.Clone(),
 		})
 	}
-
+	persistence.latestQueriedBlock = newLatestQueriedBlock
 	return nil
 }