thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-11-22 15:42:02 +00:00
Code Issues Packages Projects Releases Wiki Activity

style check fixes test.py

Browse Source
This commit is contained in:
Krzysztof Góralski 2022-11-01 09:01:33 +01:00 committed by Krzysztof Góralski
parent 69f56d8d68
commit 14e922aca1
1 changed files with 7 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
tests/integration/test_failed_async_inserts/test.py
View File

@ -26,19 +26,23 @@ def test_failed_async_inserts(started_cluster):
node = started_cluster.instances["node"]
node.query(
"CREATE TABLE async_insert_30_10_2022 (id UInt32, s String) ENGINE = Memory")
"CREATE TABLE async_insert_30_10_2022 (id UInt32, s String) ENGINE = Memory"
)
try:
node.query("SET async_insert = 1")
node.query("INSERT INTO async_insert_30_10_2022 VALUES ()")
node.query("INSERT INTO async_insert_30_10_2022 VALUES ([1,2,3], 1)")
node.query(
'INSERT INTO async_insert_30_10_2022 format JSONEachRow {"id" : 1} {"x"}')
'INSERT INTO async_insert_30_10_2022 format JSONEachRow {"id" : 1} {"x"}'
)
node.query("INSERT INTO async_insert_30_10_2022 Values (throwIf(4),'')")
except Exception:
return None
select_query = "SELECT value FROM system.events WHERE event == 'FailedAsyncInsertQuery'"
select_query = (
"SELECT value FROM system.events WHERE event == 'FailedAsyncInsertQuery'"
)
assert node.query(select_query) == "4\n"