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 typos

Browse Source
This commit is contained in:
János Benjamin Antal 2024-08-07 13:16:47 +00:00
parent 8b5c8e5361
commit 139fe624c2
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_storage_kafka/test.py
View File

@ -2242,16 +2242,16 @@ def test_kafka_virtual_columns_with_materialized_view(
)
def insert_with_retry(instance, values, table_name="kafka", max_try_couunt=5):
def insert_with_retry(instance, values, table_name="kafka", max_try_count=5):
try_count = 0
while True:
logging.debug(f"Inserting, try_count is {try_count}")
try:
try_count += 1
instance.query("INSERT INTO test.kafka VALUES {}".format(values))
instance.query(f"INSERT INTO test.{table_name} VALUES {values}")
break
except QueryRuntimeException as e:
if "Local: Timed out." in str(e) and try_count < max_try_couunt:
if "Local: Timed out." in str(e) and try_count < max_try_count:
continue
else:
raise