Temporarily remove one task group from peers.py

Fixes #538
This commit is contained in:
Neil Booth 2018-07-29 23:46:58 +08:00
parent 7b9cd944be
commit 2c07939120

View File

@ -299,13 +299,9 @@ class PeerManager(object):
peer.features['server_version'] = server_version
ptuple = protocol_tuple(protocol_version)
async with TaskGroup() as group:
await group.spawn(self._send_headers_subscribe(session, peer,
timeout, ptuple))
await group.spawn(self._send_server_features(session, peer,
timeout))
await group.spawn(self._send_peers_subscribe(session, peer,
timeout))
await self._send_headers_subscribe(session, peer, timeout, ptuple)
await self._send_server_features(session, peer, timeout)
await self._send_peers_subscribe(session, peer, timeout)
async def _send_headers_subscribe(self, session, peer, timeout, ptuple):
message = 'blockchain.headers.subscribe'