We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent ab1c5fb commit 6a506ebCopy full SHA for 6a506eb
pymysqlreplication/tests/test_basic.py
@@ -621,8 +621,9 @@ def test_get_none(self):
621
write_rows_event = self.stream.fetchone()
622
self.assertIsInstance(write_rows_event, WriteRowsEvent)
623
624
- if write_rows_event.rows[0].get("none_sources"):
625
- self.assertEqual(write_rows_event.rows[0]["none_sources"]["col1"], "null")
+ none_sources = write_rows_event.rows[0].get("none_sources")
+ if none_sources:
626
+ self.assertEqual(none_sources["col1"], "null")
627
628
def test_get_none_invalid(self):
629
self.execute("SET SESSION SQL_MODE='ALLOW_INVALID_DATES'")
0 commit comments