From 7267db8c8c5391f8cb83e285761ed7443f2d2edc Mon Sep 17 00:00:00 2001 From: Gabriel Fior Date: Tue, 10 Dec 2024 11:44:42 -0300 Subject: [PATCH] Update prediction_market_agent/db/blockchain_transaction_fetcher.py Co-authored-by: Peter Jung --- prediction_market_agent/db/blockchain_transaction_fetcher.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/prediction_market_agent/db/blockchain_transaction_fetcher.py b/prediction_market_agent/db/blockchain_transaction_fetcher.py index d17c14eb..01ae0f42 100644 --- a/prediction_market_agent/db/blockchain_transaction_fetcher.py +++ b/prediction_market_agent/db/blockchain_transaction_fetcher.py @@ -40,7 +40,7 @@ def fetch_unseen_transactions_df( # We order by block_time because it's used as partition on Dune. # We use >= for block because we might have lost transactions from the same block. # Additionally, processed tx_hashes are filtered out anyways. - query = f'select * from gnosis.transactions where "to" = {Web3.to_checksum_address(consumer_address)} AND block_number >= {min_block_number} and value > {xdai_to_wei(TRANSACTION_MESSAGE_FEE)} order by block_time asc' + query = f'select * from gnosis.transactions where "to" = {Web3.to_checksum_address(consumer_address)} AND block_number >= {min_block_number} and value >= {xdai_to_wei(TRANSACTION_MESSAGE_FEE)} order by block_time asc' df = spice.query(query, api_key=keys.dune_api_key.get_secret_value()) existing_hashes = self.blockchain_table_handler.fetch_all_transaction_hashes(