From babbdd9202466f0007d85d780097ed74733fb01f Mon Sep 17 00:00:00 2001 From: kssenii Date: Wed, 18 Oct 2023 12:08:47 +0200 Subject: [PATCH 1/2] Fxi --- .../test_postgresql_replica_database_engine_2/test.py | 7 +++++-- 1 file changed, 5 insertions(+), 2 deletions(-) diff --git a/tests/integration/test_postgresql_replica_database_engine_2/test.py b/tests/integration/test_postgresql_replica_database_engine_2/test.py index 15625e6d8a4..7ae8c9b8713 100644 --- a/tests/integration/test_postgresql_replica_database_engine_2/test.py +++ b/tests/integration/test_postgresql_replica_database_engine_2/test.py @@ -759,13 +759,16 @@ VALUES (1, (SELECT array_to_string(ARRAY(SELECT chr((100 + round(random() * 25)) order_by="id", ) -@pytest.mark.skip(reason="flaky test, will fix soon") def test_replica_consumer(started_cluster): table = "test_replica_consumer" pg_manager_instance2.restart() + pg_manager.create_postgres_table(table) + instance.query( + f"INSERT INTO postgres_database.{table} SELECT number, number from numbers(0, 50)" + ) + for pm in [pg_manager, pg_manager_instance2]: - pm.create_and_fill_postgres_table(table) pm.create_materialized_db( ip=started_cluster.postgres_ip, port=started_cluster.postgres_port, From 33118442ddf248656bf2738405d6b82e85dd87c7 Mon Sep 17 00:00:00 2001 From: kssenii Date: Wed, 18 Oct 2023 13:01:35 +0200 Subject: [PATCH 2/2] Fix black check --- .../test_postgresql_replica_database_engine_2/test.py | 1 + 1 file changed, 1 insertion(+) diff --git a/tests/integration/test_postgresql_replica_database_engine_2/test.py b/tests/integration/test_postgresql_replica_database_engine_2/test.py index 7ae8c9b8713..e8053730c44 100644 --- a/tests/integration/test_postgresql_replica_database_engine_2/test.py +++ b/tests/integration/test_postgresql_replica_database_engine_2/test.py @@ -759,6 +759,7 @@ VALUES (1, (SELECT array_to_string(ARRAY(SELECT chr((100 + round(random() * 25)) order_by="id", ) + def test_replica_consumer(started_cluster): table = "test_replica_consumer" pg_manager_instance2.restart()