From fa84b0f54bbd92a85dae2e8b598b02ba0b37f15b Mon Sep 17 00:00:00 2001 From: Neil Booth Date: Wed, 25 Jul 2018 10:14:05 +0800 Subject: [PATCH] Use asyncio.gather to propogate exceptions --- electrumx/server/mempool.py | 2 +- electrumx/server/peers.py | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/electrumx/server/mempool.py b/electrumx/server/mempool.py index 88dfad2..5153742 100644 --- a/electrumx/server/mempool.py +++ b/electrumx/server/mempool.py @@ -168,7 +168,7 @@ class MemPool(object): (hashes, all_hashes, touched)) for hashes in chunks(new_hashes, 2000)] if jobs: - await asyncio.wait(jobs) + await asyncio.gather(*jobs) tx_map = {} utxo_map = {} for job in jobs: diff --git a/electrumx/server/peers.py b/electrumx/server/peers.py index 02bcd17..59b92e2 100644 --- a/electrumx/server/peers.py +++ b/electrumx/server/peers.py @@ -281,7 +281,7 @@ class PeerManager(object): self._send_server_features(session, peer, timeout), self._send_peers_subscribe(session, peer, timeout) )] - await asyncio.wait(jobs) + await asyncio.gather(*jobs) async def _send_headers_subscribe(self, session, peer, timeout, ptuple): request = session.send_request('blockchain.headers.subscribe',