@@ -1737,7 +1737,7 @@ def tearDown(self):
1737
1737
super (TestOptionalMetaData , self ).tearDown ()
1738
1738
1739
1739
1740
- class TestColumnValueNoneSources (base .PyMySQLReplicationTestCase ):
1740
+ class TestColumnValueNoneSources (base .PyMySQLReplicationVersion8TestCase ):
1741
1741
def setUp (self ):
1742
1742
super (TestColumnValueNoneSources , self ).setUp ()
1743
1743
self .stream .close ()
@@ -1747,7 +1747,9 @@ def setUp(self):
1747
1747
only_events = (TableMapEvent ,),
1748
1748
)
1749
1749
if not self .isMySQL8014AndMore ():
1750
- self .skipTest ("Mysql version is under 8.0.14 - pass TestOptionalMetaData" )
1750
+ self .skipTest (
1751
+ "Mysql version is under 8.0.14 - pass TestColumnValueNoneSources"
1752
+ )
1751
1753
self .execute ("SET GLOBAL binlog_row_metadata='FULL';" )
1752
1754
1753
1755
def test_get_none (self ):
@@ -1788,6 +1790,8 @@ def test_get_none_invalid(self):
1788
1790
1789
1791
self .assertIsInstance (self .stream .fetchone (), RotateEvent )
1790
1792
self .assertIsInstance (self .stream .fetchone (), FormatDescriptionEvent )
1793
+ self .assertIsInstance (self .stream .fetchone (), PreviousGtidsEvent )
1794
+ self .assertIsInstance (self .stream .fetchone (), GtidEvent )
1791
1795
self .assertIsInstance (self .stream .fetchone (), QueryEvent )
1792
1796
self .assertIsInstance (self .stream .fetchone (), TableMapEvent )
1793
1797
0 commit comments