Skip to content

Commit aaf30e3

Browse files
committed
Try fix tests 3
1 parent 586f122 commit aaf30e3

File tree

1 file changed

+6
-3
lines changed

1 file changed

+6
-3
lines changed

test_mysql_ch_replicator.py

Lines changed: 6 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -345,18 +345,21 @@ def test_runner():
345345
mysql.execute(f"INSERT INTO {TEST_TABLE_NAME} (name, age, coordinate) VALUES ('Ivan', 42, POINT(10.0, 20.0));", commit=True)
346346
mysql.execute(f"INSERT INTO {TEST_TABLE_NAME} (name, age, coordinate) VALUES ('Peter', 33, POINT(10.0, 20.0));", commit=True)
347347

348+
mysql.execute(f"INSERT INTO `group` (name, age, rate) VALUES ('Peter', 33, 10.2);", commit=True)
349+
348350
run_all_runner = RunAllRunner()
349351
run_all_runner.run()
350352

351353
assert_wait(lambda: TEST_DB_NAME in ch.get_databases())
352-
assert_wait(lambda: 'group' in ch.get_databases())
354+
355+
ch.execute_command(f'USE {TEST_DB_NAME};')
356+
357+
assert_wait(lambda: 'group' in ch.get_tables())
353358

354359
mysql.drop_table('group')
355360

356361
assert_wait(lambda: 'group' not in ch.get_databases())
357362

358-
ch.execute_command(f'USE {TEST_DB_NAME}')
359-
360363
assert_wait(lambda: TEST_TABLE_NAME in ch.get_tables())
361364
assert_wait(lambda: len(ch.select(TEST_TABLE_NAME)) == 2)
362365

0 commit comments

Comments
 (0)