diff --git a/lib/chainsync/bin/acquire_data.py b/lib/chainsync/bin/acquire_data.py
index b4d39e8ffe..f3248e25f7 100644
--- a/lib/chainsync/bin/acquire_data.py
+++ b/lib/chainsync/bin/acquire_data.py
@@ -119,7 +119,9 @@ def main(
 
         # Query and add block transactions
         transactions = fetch_contract_transactions_for_block(web3, hyperdrive_contract, block_number)
-        block_transactions, wallet_deltas = convert_hyperdrive_transactions_for_block(hyperdrive_contract, transactions)
+        block_transactions, wallet_deltas = convert_hyperdrive_transactions_for_block(
+            web3, hyperdrive_contract, transactions
+        )
         add_transactions(block_transactions, session)
         add_wallet_deltas(wallet_deltas, session)
 
@@ -183,7 +185,7 @@ def main(
                         (
                             block_transactions,
                             wallet_deltas,
-                        ) = convert_hyperdrive_transactions_for_block(hyperdrive_contract, transactions)
+                        ) = convert_hyperdrive_transactions_for_block(web3, hyperdrive_contract, transactions)
                         break
                     except ValueError:
                         logging.warning("Error in fetch_contract_transactions_for_block, retrying")
diff --git a/lib/chainsync/chainsync/hyperdrive/convert_data.py b/lib/chainsync/chainsync/hyperdrive/convert_data.py
index d2e3086ee4..454d641883 100644
--- a/lib/chainsync/chainsync/hyperdrive/convert_data.py
+++ b/lib/chainsync/chainsync/hyperdrive/convert_data.py
@@ -18,12 +18,16 @@
 
 
 def convert_hyperdrive_transactions_for_block(
-    hyperdrive_contract: Contract, transactions: list[TxData]
+    web3: Web3, hyperdrive_contract: Contract, transactions: list[TxData]
 ) -> tuple[list[Transaction], list[WalletDelta]]:
     """Fetch transactions related to the contract.
 
     Arguments
     ---------
+    web3: Web3
+        web3 provider object
+    hyperdrive_contract: Contract
+        The contract to query the transactions from
     transactions: TxData
         A list of hyperdrive transactions for a given block.
 
@@ -47,7 +51,7 @@ def convert_hyperdrive_transactions_for_block(
             transaction_dict["input"] = {"method": method.fn_name, "params": params}
         except ValueError:  # if the input is not meant for the contract, ignore it
             continue
-        tx_receipt = Web3.eth.get_transaction_receipt(tx_hash)
+        tx_receipt = web3.eth.get_transaction_receipt(tx_hash)
         logs = get_transaction_logs(hyperdrive_contract, tx_receipt)
         receipt: dict[str, Any] = _convert_object_hexbytes_to_strings(tx_receipt)  # type: ignore
         out_transactions.append(_build_hyperdrive_transaction_object(transaction_dict, logs, receipt))