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

fix flacky test test_profile_events_s3

Browse Source
This commit is contained in:
Sema Checherinda 2023-06-26 14:46:51 +02:00
parent 4b02d83999
commit c4d190617c
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -139,7 +139,7 @@ def test_profile_events(cluster):
) )
stat1 = get_query_stat(instance, query1) stat1 = get_query_stat(instance, query1)
for metric in stat1: for metric in stat1:
assert stat1[metric] == metrics1[metric] - metrics0[metric] assert stat1[metric] == metrics1.get(metric, 0) - metrics0.get(metric, 0)
assert ( assert (
metrics1["WriteBufferFromS3Bytes"] - metrics0["WriteBufferFromS3Bytes"] == size1 metrics1["WriteBufferFromS3Bytes"] - metrics0["WriteBufferFromS3Bytes"] == size1
) )
@ -163,7 +163,7 @@ def test_profile_events(cluster):
stat2 = get_query_stat(instance, query2) stat2 = get_query_stat(instance, query2)
for metric in stat2: for metric in stat2:
assert stat2[metric] == metrics2[metric] - metrics1[metric] assert stat2[metric] == metrics2.get(metric, 0)- metrics1.get(metric, 0)
assert ( assert (
metrics2["WriteBufferFromS3Bytes"] - metrics1["WriteBufferFromS3Bytes"] metrics2["WriteBufferFromS3Bytes"] - metrics1["WriteBufferFromS3Bytes"]
@ -189,4 +189,4 @@ def test_profile_events(cluster):
# With async reads profile events are not updated fully because reads are done in a separate thread. # With async reads profile events are not updated fully because reads are done in a separate thread.
# for metric in stat3: # for metric in stat3:
# print(metric) # print(metric)
# assert stat3[metric] == metrics3[metric] - metrics2[metric] # assert stat3[metric] == metrics3.get(metric, 0) - metrics2.get(metric, 0)