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

Automatic style fix

Browse Source
This commit is contained in:
robot-clickhouse 2023-07-04 19:32:43 +00:00
parent 8551a38e73
commit 13cc329bfb
2 changed files with 9 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
tests/integration/test_quorum_inserts_parallel/test.py
View File

@ -27,7 +27,11 @@ def started_cluster():
def test_parallel_quorum_actually_parallel(started_cluster): def test_parallel_quorum_actually_parallel(started_cluster):
settings = {"insert_quorum": "3", "insert_quorum_parallel": "1", "function_sleep_max_microseconds_per_block": "0"} settings = {
"insert_quorum": "3",
"insert_quorum_parallel": "1",
"function_sleep_max_microseconds_per_block": "0",
}
for i, node in enumerate([node1, node2, node3]): for i, node in enumerate([node1, node2, node3]):
node.query( node.query(
"CREATE TABLE r (a UInt64, b String) ENGINE=ReplicatedMergeTree('/test/r', '{num}') ORDER BY tuple()".format( "CREATE TABLE r (a UInt64, b String) ENGINE=ReplicatedMergeTree('/test/r', '{num}') ORDER BY tuple()".format(

5
tests/integration/test_read_temporary_tables_on_failure/test.py
View File

@ -19,7 +19,10 @@ def start_cluster():
def test_different_versions(start_cluster): def test_different_versions(start_cluster):
with pytest.raises(QueryTimeoutExceedException): with pytest.raises(QueryTimeoutExceedException):
node.query("SELECT sleepEachRow(3) FROM numbers(10) SETTINGS function_sleep_max_microseconds_per_block = 0", timeout=5) node.query(
"SELECT sleepEachRow(3) FROM numbers(10) SETTINGS function_sleep_max_microseconds_per_block = 0",
timeout=5,
)
with pytest.raises(QueryRuntimeException): with pytest.raises(QueryRuntimeException):
node.query("SELECT 1", settings={"max_concurrent_queries_for_user": 1}) node.query("SELECT 1", settings={"max_concurrent_queries_for_user": 1})
assert node.contains_in_log("Too many simultaneous queries for user") assert node.contains_in_log("Too many simultaneous queries for user")