fix log statement for fetchone

julien-duponchelle · Feb 7, 2024 · 317cdd3 · 317cdd3
1 parent 00364de
commit 317cdd3
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/pymysqlreplication/binlogstream.py b/pymysqlreplication/binlogstream.py
@@ -599,7 +599,8 @@ def fetchone(self):
                 if code in MYSQL_EXPECTED_ERROR_CODES:
                     self._stream_connection.close()
                     self.__connected_stream = False
-                    logging.WARN(
+                    logging.log(
+                        logging.WARN,
                         """
                           A pymysql.OperationalError error occurred, Re-request the connection.
                         """