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

Automatic style fix

Browse Source
This commit is contained in:
robot-clickhouse 2023-04-14 20:38:11 +00:00
parent 60dbb7b406
commit 6c03b2ef0c
1 changed files with 6 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -524,7 +524,9 @@ def test_settings_connection_wait_timeout(started_cluster):
def worker():
worker_started_event.set()
node1.query(
"SELECT 1, sleepEachRow(1) FROM {} SETTINGS max_threads=1".format(table_name)
"SELECT 1, sleepEachRow(1) FROM {} SETTINGS max_threads=1".format(
table_name
)
)
worker_thread = threading.Thread(target=worker)
@ -540,7 +542,9 @@ def test_settings_connection_wait_timeout(started_cluster):
match=r"Exception: mysqlxx::Pool is full \(connection_wait_timeout is exceeded\)",
):
node1.query(
"SELECT 2, sleepEachRow(1) FROM {} SETTINGS max_threads=1".format(table_name)
"SELECT 2, sleepEachRow(1) FROM {} SETTINGS max_threads=1".format(
table_name
)
)
ended = time.time()
assert (ended - started) >= wait_timeout