Skip to content

Commit

Permalink
deprecate disutils
Browse files Browse the repository at this point in the history
  • Loading branch information
sean-k1 committed Nov 4, 2023
1 parent eeade3f commit 90fed8f
Showing 1 changed file with 4 additions and 4 deletions.
8 changes: 4 additions & 4 deletions pymysqlreplication/binlogstream.py
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
import struct
import logging
from distutils.version import LooseVersion
from packaging.version import Version

import pymysql
from pymysql.constants.COMMAND import COM_BINLOG_DUMP, COM_REGISTER_SLAVE
Expand Down Expand Up @@ -329,7 +329,7 @@ def _register_slave(self):

packet = self.report_slave.encoded(self.__server_id)

if pymysql.__version__ < LooseVersion("0.6"):
if Version(pymysql.__version__) < Version("0.6"):
self._stream_connection.wfile.write(packet)
self._stream_connection.wfile.flush()
self._stream_connection.read_packet()
Expand Down Expand Up @@ -501,7 +501,7 @@ def __connect_to_stream(self):
# encoded_data
prelude += gtid_set.encoded()

if pymysql.__version__ < LooseVersion("0.6"):
if Version(pymysql.__version__) < Version("0.6"):
self._stream_connection.wfile.write(prelude)
self._stream_connection.wfile.flush()
else:
Expand Down Expand Up @@ -587,7 +587,7 @@ def fetchone(self):
self.__connect_to_ctl()

try:
if pymysql.__version__ < LooseVersion("0.6"):
if Version(pymysql.__version__) < Version("0.6"):
pkt = self._stream_connection.read_packet()
else:
pkt = self._stream_connection._read_packet()
Expand Down

0 comments on commit 90fed8f

Please sign in to comment.