Skip to content

Commit 70ecaf4

Browse files
committed
fix: binlog stream
1 parent 8a4be19 commit 70ecaf4

File tree

1 file changed

+1
-0
lines changed

1 file changed

+1
-0
lines changed

asyncmy/replication/binlogstream.py

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -285,6 +285,7 @@ async def _read(self):
285285
if code in self.MYSQL_EXPECTED_ERROR_CODES:
286286
await self.close()
287287
return
288+
raise e
288289

289290
if pkt.is_eof_packet():
290291
await self.close()

0 commit comments

Comments
 (0)