File tree Expand file tree Collapse file tree 1 file changed +3
-4
lines changed Expand file tree Collapse file tree 1 file changed +3
-4
lines changed Original file line number Diff line number Diff line change @@ -419,8 +419,7 @@ def __connect_to_stream(self):
419
419
self .__connected_stream = True
420
420
421
421
def fetchone (self ):
422
- should_continue = True
423
- while should_continue :
422
+ while True :
424
423
if not self .__connected_stream :
425
424
self .__connect_to_stream ()
426
425
@@ -474,9 +473,9 @@ def fetchone(self):
474
473
elif binlog_event .log_pos :
475
474
self .log_pos = binlog_event .log_pos
476
475
477
- if self .end_log_pos and self .log_pos >= self .end_log_pos :
476
+ if self .end_log_pos and self .log_pos > self .end_log_pos :
478
477
# We're currently at, or past, the specified end log position.
479
- should_continue = False
478
+ return None
480
479
481
480
# This check must not occur before clearing the ``table_map`` as a
482
481
# result of a RotateEvent.
You can’t perform that action at this time.
0 commit comments