From fbaa6804c288e1e206de868451c66282ed45d5e3 Mon Sep 17 00:00:00 2001 From: Azat Khuzhin Date: Fri, 19 Nov 2021 21:13:37 +0300 Subject: [PATCH] Fix 02010_lc_native flakiness (Query with id = 123456 is already running) --- tests/queries/0_stateless/02010_lc_native.python | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/tests/queries/0_stateless/02010_lc_native.python b/tests/queries/0_stateless/02010_lc_native.python index db2a85e8b14..2667bba8432 100755 --- a/tests/queries/0_stateless/02010_lc_native.python +++ b/tests/queries/0_stateless/02010_lc_native.python @@ -3,10 +3,12 @@ import socket import os +import uuid CLICKHOUSE_HOST = os.environ.get('CLICKHOUSE_HOST', '127.0.0.1') CLICKHOUSE_PORT = int(os.environ.get('CLICKHOUSE_PORT_TCP', '900000')) CLICKHOUSE_DATABASE = os.environ.get('CLICKHOUSE_DATABASE', 'default') +CLICKHOUSE_QUERY_ID = uuid.uuid4().hex def writeVarUInt(x, ba): for _ in range(0, 9): @@ -111,7 +113,7 @@ def receiveHello(s): def serializeClientInfo(ba): writeStringBinary('default', ba) # initial_user - writeStringBinary('123456', ba) # initial_query_id + writeStringBinary(CLICKHOUSE_QUERY_ID, ba) # initial_query_id writeStringBinary('127.0.0.1:9000', ba) # initial_address ba.extend([0] * 8) # initial_query_start_time_microseconds ba.append(1) # TCP @@ -130,7 +132,7 @@ def serializeClientInfo(ba): def sendQuery(s, query): ba = bytearray() writeVarUInt(1, ba) # query - writeStringBinary('123456', ba) + writeStringBinary(CLICKHOUSE_QUERY_ID, ba) ba.append(1) # INITIAL_QUERY