Update prediction_market_agent/db/blockchain_transaction_fetcher.py

Co-authored-by: Peter Jung <[email protected]>

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(