Merge pull request #608 from bentsku/fix-log-statement

fix log statement for BinLogStreamReader.fetchone

Author: sean-k1

pymysqlreplication/binlogstream.py

@@ -599,10 +599,11 @@ 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.
-                        """
+                        """,
                     )
                     continue
                 raise
@@ -687,9 +688,9 @@ def fetchone(self):
                 binlog_event.event_type == TABLE_MAP_EVENT
                 and binlog_event.event is not None
             ):
-                self.table_map[
-                    binlog_event.event.table_id
-                ] = binlog_event.event.get_table()
+                self.table_map[binlog_event.event.table_id] = (
+                    binlog_event.event.get_table()
+                )
 
             # event is none if we have filter it on packet level
             # we filter also not allowed events

pymysqlreplication/tests/binlogfilereader.py

@@ -1,4 +1,5 @@
 """Read binlog files"""
+
 import struct
 
 from pymysqlreplication import constants

pymysqlreplication/tests/test_abnormal.py

@@ -1,5 +1,6 @@
 """Test abnormal conditions, such as caused by a MySQL crash
 """
+
 import os.path
 
 from pymysqlreplication.tests import base