From b33b2c094507afedc96ec18794fb0850503e9eb9 Mon Sep 17 00:00:00 2001 From: SomberNight Date: Sat, 8 Sep 2018 18:38:58 +0200 Subject: [PATCH] synchronizer: more batching --- electrum/synchronizer.py | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) diff --git a/electrum/synchronizer.py b/electrum/synchronizer.py index d8a887607..ff17a34c4 100644 --- a/electrum/synchronizer.py +++ b/electrum/synchronizer.py @@ -118,11 +118,12 @@ class Synchronizer(PrintError): transaction_hashes.append(tx_hash) self.requested_tx[tx_hash] = tx_height - for tx_hash in transaction_hashes: - await self.get_transaction(tx_hash) + async with TaskGroup() as group: + for tx_hash in transaction_hashes: + await group.spawn(self.get_transaction, tx_hash) async def get_transaction(self, tx_hash): - result = await self.session.send_request('blockchain.transaction.get', [tx_hash]) + result = await asyncio.wait_for(self.session.send_request('blockchain.transaction.get', [tx_hash]), 20) tx = Transaction(result) try: tx.deserialize()