Refactor logic to update flag value based on the "annotate event rows…

…" parameter
chungeun-choi · Jul 28, 2023 · f23eba2 · f23eba2
1 parent 7e1084d
commit f23eba2
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/pymysqlreplication/binlogstream.py b/pymysqlreplication/binlogstream.py
@@ -389,7 +389,7 @@ def __connect_to_stream(self):
 
                 # Enable annotate rows event 
                 if self.__annotate_rows_event:
-                    flags = 2
+                    flags |= 0x02
 
                 if not self.__blocking:
                     flags |= 0x01  # BINLOG_DUMP_NON_BLOCK