thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-11-26 17:41:59 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fix black check

Browse Source
This commit is contained in:
kssenii 2023-10-12 19:47:39 +02:00
parent 1917a882b7
commit 34915a8a5e
1 changed files with 5 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
tests/integration/test_postgresql_replica_database_engine_2/test.py
View File

@ -728,7 +728,7 @@ def test_replica_consumer(started_cluster):
cluster.postgres_ip,
cluster.postgres_port,
default_database="postgres_database",
postgres_db_exists=True
postgres_db_exists=True,
)
for pm in [pg_manager, pg_manager_replica]:
@ -740,14 +740,16 @@ def test_replica_consumer(started_cluster):
f"materialized_postgresql_tables_list = '{table}'",
"materialized_postgresql_backoff_min_ms = 100",
"materialized_postgresql_backoff_max_ms = 100",
"materialized_postgresql_use_unique_replication_consumer_identifier = 1"
"materialized_postgresql_use_unique_replication_consumer_identifier = 1",
],
)
assert 50 == int(instance.query(f"SELECT count() FROM test_database.{table}"))
assert 50 == int(instance2.query(f"SELECT count() FROM test_database.{table}"))
instance.query(f"INSERT INTO postgres_database.{table} SELECT number, number from numbers(1000, 1000)")
instance.query(
f"INSERT INTO postgres_database.{table} SELECT number, number from numbers(1000, 1000)"
)
check_tables_are_synchronized(
instance, table, postgres_database=pg_manager.get_default_database()