fix: fixed query to adjust last saved height

icon-project · Aug 12, 2024 · b13b1e0 · b13b1e0
1 parent 5ab7b29
commit b13b1e0
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/relayer/chains/wasm/wasm_chain_processor.go b/relayer/chains/wasm/wasm_chain_processor.go
@@ -371,7 +371,7 @@ func (ccp *WasmChainProcessor) initializeChannelState(ctx context.Context) error
 
 func (ccp *WasmChainProcessor) getBlocksToProcess(ctx context.Context, blockToRequest int64) ([]int64, error) {
 	ibcHandlerAddr := ccp.chainProvider.PCfg.IbcHandlerAddress
-	queryFilter := fmt.Sprintf("tx.height>%d AND execute._contract_address='%s'",
+	queryFilter := fmt.Sprintf("tx.height>=%d AND execute._contract_address='%s'",
 		blockToRequest, ibcHandlerAddr)
 	queryCtx, cancelQueryCtx := context.WithTimeout(ctx, blockResultsQueryTimeout)
 	defer cancelQueryCtx()