Fix #454

aio-libs · Apr 24, 2020 · 95d3457 · 95d3457
1 parent b16e5bd
commit 95d3457
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/aiomysql/connection.py b/aiomysql/connection.py
@@ -596,7 +596,7 @@ async def _read_packet(self, packet_type=MysqlPacket):
     async def _read_bytes(self, num_bytes):
         try:
             data = await self._reader.readexactly(num_bytes)
-        except asyncio.streams.IncompleteReadError as e:
+        except asyncio.IncompleteReadError as e:
             msg = "Lost connection to MySQL server during query"
             raise OperationalError(2013, msg) from e
         except (IOError, OSError) as e: