Fix lint

Author: taehun.kim

pymysqlreplication/event.py

@@ -108,20 +108,34 @@ def __init__(self, from_packet, event_size, table_map, ctl_connection, **kwargs)
             self.last_committed = struct.unpack("<Q", self.packet.read(8))[0]
             self.sequence_number = struct.unpack("<Q", self.packet.read(8))[0]
 
-        format_string = '<Q'
+        format_string = "<Q"
         read_immediate_commit_timestamp = self.packet.read(7)
-        self.immediate_commit_timestamp = read_immediate_commit_timestamp.ljust(struct.calcsize(format_string), b'\x00')
-        self.immediate_commit_timestamp = struct.unpack(format_string, self.immediate_commit_timestamp)[0]
+        self.immediate_commit_timestamp = read_immediate_commit_timestamp.ljust(
+            struct.calcsize(format_string), b"\x00"
+        )
+        self.immediate_commit_timestamp = struct.unpack(
+            format_string, self.immediate_commit_timestamp
+        )[0]
         self.immediate_commit_timestamp = self.immediate_commit_timestamp & (
-                    (1 << (8 * struct.calcsize(format_string))) - 1)
-        self.immediate_commit_timestamp = struct.pack(format_string, self.immediate_commit_timestamp)
+            (1 << (8 * struct.calcsize(format_string))) - 1
+        )
+        self.immediate_commit_timestamp = struct.pack(
+            format_string, self.immediate_commit_timestamp
+        )
 
         read_original_commit_timestamp = self.packet.read(7)
-        self.original_commit_timestamp = read_original_commit_timestamp.ljust(struct.calcsize(format_string), b'\x00')
-        self.original_commit_timestamp = struct.unpack(format_string, self.original_commit_timestamp)[0]
+        self.original_commit_timestamp = read_original_commit_timestamp.ljust(
+            struct.calcsize(format_string), b"\x00"
+        )
+        self.original_commit_timestamp = struct.unpack(
+            format_string, self.original_commit_timestamp
+        )[0]
         self.original_commit_timestamp = self.original_commit_timestamp & (
-                    (1 << (8 * struct.calcsize(format_string))) - 1)
-        self.original_commit_timestamp = struct.pack(format_string, self.original_commit_timestamp)
+            (1 << (8 * struct.calcsize(format_string))) - 1
+        )
+        self.original_commit_timestamp = struct.pack(
+            format_string, self.original_commit_timestamp
+        )
 
         # todo(hun): We should implement the properties below,
         #            but due to the lack of documentation on the variable-length property,

pymysqlreplication/tests/test_basic.py

@@ -14,7 +14,6 @@
 from pymysql.protocol import MysqlPacket
 import pytest
 
-
 __all__ = [
     "TestBasicBinLogStreamReader",
     "TestMultipleRowBinLogStreamReader",
@@ -1472,6 +1471,7 @@ def test_rows_query_log_event(self):
         event = self.stream.fetchone()
         self.assertIsInstance(event, RowsQueryLogEvent)
 
+
 class TestGtidEvent(base.PyMySQLReplicationTestCase):
     def setUp(self):
         super(TestGtidEvent, self).setUp()
@@ -1504,6 +1504,7 @@ def test_gtid_event(self):
         self.assertIsInstance(gtid_event.immediate_commit_timestamp, bytes)
         self.assertIsInstance(gtid_event.original_commit_timestamp, bytes)
 
+
 class TestLatin1(base.PyMySQLReplicationTestCase):
     def setUp(self):
         super().setUp(charset="latin1")