thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-09-20 00:30:49 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix style

Browse Source
This commit is contained in:
Sema Checherinda 2023-11-30 18:35:39 +01:00
parent 42f648f0d2
commit 60bf17ce8a
2 changed files with 15 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -112,9 +112,14 @@ def test_parallel_quorum_actually_quorum(started_cluster):
def insert_fail_quorum_timeout(node, settings):
if "insert_quorum_timeout" not in settings:
settings["insert_quorum_timeout"] = "1000"
error = node.query_and_get_error("INSERT INTO q VALUES(3, 'Hi')", settings=settings)
error = node.query_and_get_error(
"INSERT INTO q VALUES(3, 'Hi')", settings=settings
)
assert "DB::Exception: Unknown status, client must retry." in error, error
assert "DB::Exception: Timeout while waiting for quorum. (TIMEOUT_EXCEEDED)" in error, error
assert (
"DB::Exception: Timeout while waiting for quorum. (TIMEOUT_EXCEEDED)"
in error
), error
p = Pool(2)
res = p.apply_async(
@ -147,7 +152,12 @@ def test_parallel_quorum_actually_quorum(started_cluster):
# Insert to the second to satisfy quorum
insert_fail_quorum_timeout(
node2, {"insert_quorum": "3", "insert_quorum_parallel": "1", "insert_quorum_timeout": "1000"}
node2,
{
"insert_quorum": "3",
"insert_quorum_parallel": "1",
"insert_quorum_timeout": "1000",
},
)
res.get()

4
tests/queries/0_stateless/02922_deduplication_with_zero_copy.sh
View File

@ -56,9 +56,9 @@ function filter_temporary_locks()
function insert_duplicates() {
query_with_retry "insert into r1 values(1);" --send_logs_level="error" &
$CLICKHOUSE_CLIENT -q "insert into r1 values(1);" --send_logs_level="error" &
query_with_retry "insert into r2 values(1);" --send_logs_level="error"
$CLICKHOUSE_CLIENT -q "insert into r2 values(1);" --send_logs_level="error"
wait