Update test.py

This commit is contained in:
Kseniia Sumarokova 2021-10-04 11:38:38 +03:00 committed by GitHub
parent a3ee621d5e
commit a8f872f63e
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23

View File

@ -979,7 +979,7 @@ def test_user_managed_slots(started_cluster):
drop_postgres_table(cursor, table_name) drop_postgres_table(cursor, table_name)
drop_materialized_db() drop_materialized_db()
drop_replication_slot(replication_connection, slot_name) drop_replication_slot(replication_connection, slot_name)
cursor.execute(f'DROP TABLE IF EXISTS test_table') cursor.execute('DROP TABLE IF EXISTS test_table')
def test_add_new_table_to_replication(started_cluster): def test_add_new_table_to_replication(started_cluster):
@ -1133,7 +1133,7 @@ def test_predefined_connection_configuration(started_cluster):
instance.query("CREATE DATABASE test_database ENGINE = MaterializedPostgreSQL(postgres1)") instance.query("CREATE DATABASE test_database ENGINE = MaterializedPostgreSQL(postgres1)")
check_tables_are_synchronized("test_table"); check_tables_are_synchronized("test_table");
drop_materialized_db() drop_materialized_db()
cursor.execute(f'DROP TABLE IF EXISTS test_table') cursor.execute('DROP TABLE IF EXISTS test_table')
if __name__ == '__main__': if __name__ == '__main__':