Skip to content

Commit 7e582fb

Browse files
committed
Merge pull request #30 from lxyu/bypass_events_in_log_pos
ignore pos of some events this closes #29!
2 parents 8fcfea7 + 684b837 commit 7e582fb

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

pymysqlreplication/binlogstream.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -124,7 +124,7 @@ def fetchone(self):
124124
if binlog_event.event_type == ROTATE_EVENT:
125125
self.log_pos = binlog_event.event.position
126126
self.log_file = binlog_event.event.next_binlog
127-
else:
127+
elif binlog_event.log_pos:
128128
self.log_pos = binlog_event.log_pos
129129

130130
if self.__filter_event(binlog_event.event):

0 commit comments

Comments
 (0)