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

Update tests/integration/test_failed_async_inserts/test.py

Browse Source 
Co-authored-by: Kruglov Pavel <48961922+Avogar@users.noreply.github.com>
This commit is contained in:
Krzysztof Góralski 2022-11-01 13:55:25 +01:00 committed by Krzysztof Góralski
parent 14e922aca1
commit f526ddba68
1 changed files with 16 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -28,17 +28,22 @@ def test_failed_async_inserts(started_cluster):
node.query( 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"
) )
node.query(
try: "INSERT INTO async_insert_30_10_2022 SETTINGS async_insert = 1 VALUES ()",
node.query("SET async_insert = 1") ignore_error=True,
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(
node.query( "INSERT INTO async_insert_30_10_2022 SETTINGS async_insert = 1 VALUES ([1,2,3], 1)",
'INSERT INTO async_insert_30_10_2022 format JSONEachRow {"id" : 1} {"x"}' ignore_error=True,
) )
node.query("INSERT INTO async_insert_30_10_2022 Values (throwIf(4),'')") node.query(
except Exception: 'INSERT INTO async_insert_30_10_2022 SETTINGS async_insert = 1 FORMAT JSONEachRow {"id" : 1} {"x"}',
return None ignore_error=True,
)
node.query(
"INSERT INTO async_insert_30_10_2022 SETTINGS async_insert = 1 VALUES (throwIf(4),'')",
ignore_error=True,
)
select_query = ( select_query = (
"SELECT value FROM system.events WHERE event == 'FailedAsyncInsertQuery'" "SELECT value FROM system.events WHERE event == 'FailedAsyncInsertQuery'"