From 3e5381ee0355f05a8a26a325dcea5d5a46713c55 Mon Sep 17 00:00:00 2001
From: Seth Sims <xzy3@cdc.gov>
Date: Thu, 22 Mar 2018 09:15:10 -0400
Subject: [PATCH] aiohttp 3 dropped the tp alias for type in WSMessage,
changing to its full name
---
aiogremlin/driver/aiohttp/transport.py | 8 ++++----
1 file changed, 4 insertions(+), 4 deletions(-)
diff --git a/aiogremlin/driver/aiohttp/transport.py b/aiogremlin/driver/aiohttp/transport.py
index 01e80d7..3fe33ed 100644
--- a/aiogremlin/driver/aiohttp/transport.py
+++ b/aiogremlin/driver/aiohttp/transport.py
@@ -26,16 +26,16 @@ class AiohttpTransport(transport.AbstractBaseTransport):
async def read(self):
data = await self._ws.receive()
- if data.tp == aiohttp.WSMsgType.close:
+ if data.type == aiohttp.WSMsgType.close:
await self._transport.close()
raise RuntimeError("Connection closed by server")
- elif data.tp == aiohttp.WSMsgType.error:
+ elif data.type == aiohttp.WSMsgType.error:
# This won't raise properly, fix
raise data.data
- elif data.tp == aiohttp.WSMsgType.closed:
+ elif data.type == aiohttp.WSMsgType.closed:
# Hmm
raise RuntimeError("Connection closed by server")
- elif data.tp == aiohttp.WSMsgType.text:
+ elif data.type == aiohttp.WSMsgType.text:
# Should return bytes
data = data.data.strip().encode('utf-8')
else:
--
GitLab