@@ -25,9 +25,9 @@ def ignoredEvents(self):
25
25
return [GtidEvent ]
26
26
27
27
def test_allowed_event_list (self ):
28
- self .assertEqual (len (self .stream ._allowed_event_list (None , None , False )), 13 )
29
- self .assertEqual (len (self .stream ._allowed_event_list (None , None , True )), 12 )
30
- self .assertEqual (len (self .stream ._allowed_event_list (None , [RotateEvent ], False )), 12 )
28
+ self .assertEqual (len (self .stream ._allowed_event_list (None , None , False )), 14 )
29
+ self .assertEqual (len (self .stream ._allowed_event_list (None , None , True )), 13 )
30
+ self .assertEqual (len (self .stream ._allowed_event_list (None , [RotateEvent ], False )), 13 )
31
31
self .assertEqual (len (self .stream ._allowed_event_list ([RotateEvent ], None , False )), 1 )
32
32
33
33
def test_read_query_event (self ):
@@ -714,7 +714,8 @@ def test_read_query_event(self):
714
714
715
715
self .stream .close ()
716
716
self .stream = BinLogStreamReader (
717
- self .database , server_id = 1024 , blocking = True , auto_position = gtid )
717
+ self .database , server_id = 1024 , blocking = True , auto_position = gtid ,
718
+ ignored_events = [HeartbeatLogEvent ])
718
719
719
720
self .assertIsInstance (self .stream .fetchone (), RotateEvent )
720
721
self .assertIsInstance (self .stream .fetchone (), FormatDescriptionEvent )
@@ -770,7 +771,8 @@ def test_position_gtid(self):
770
771
771
772
self .stream .close ()
772
773
self .stream = BinLogStreamReader (
773
- self .database , server_id = 1024 , blocking = True , auto_position = gtid )
774
+ self .database , server_id = 1024 , blocking = True , auto_position = gtid ,
775
+ ignored_events = [HeartbeatLogEvent ])
774
776
775
777
self .assertIsInstance (self .stream .fetchone (), RotateEvent )
776
778
self .assertIsInstance (self .stream .fetchone (), FormatDescriptionEvent )
0 commit comments