|
1 | | -import io |
2 | | -import json |
3 | 1 | import logging |
4 | | -import random |
5 | | -import string |
6 | 2 | import time |
7 | 3 | import uuid |
8 | 4 | from multiprocessing.dummy import Pool |
9 | 5 |
|
10 | 6 | import pytest |
11 | | -from kazoo.exceptions import NoNodeError |
12 | 7 |
|
13 | | -from helpers.client import QueryRuntimeException |
14 | 8 | from helpers.cluster import ClickHouseCluster, ClickHouseInstance |
15 | 9 | from helpers.s3_queue_common import ( |
16 | 10 | run_query, |
@@ -140,7 +134,7 @@ def test_replicated(started_cluster): |
140 | 134 | f"SELECT * FROM system.zookeeper WHERE path = '{keeper_path}'" |
141 | 135 | ) |
142 | 136 |
|
143 | | - total_values = generate_random_files( |
| 137 | + generate_random_files( |
144 | 138 | started_cluster, files_path, files_to_generate, start_ind=0, row_num=1 |
145 | 139 | ) |
146 | 140 |
|
@@ -170,10 +164,8 @@ def test_bad_settings(started_cluster): |
170 | 164 | node = started_cluster.instances["node_cloud_mode"] |
171 | 165 |
|
172 | 166 | table_name = f"test_bad_settings_{uuid.uuid4().hex[:8]}" |
173 | | - dst_table_name = f"{table_name}_dst" |
174 | 167 | keeper_path = f"/clickhouse/test_{table_name}" |
175 | 168 | files_path = f"{table_name}_data" |
176 | | - files_to_generate = 10 |
177 | 169 |
|
178 | 170 | try: |
179 | 171 | create_table( |
@@ -225,7 +217,7 @@ def test_processing_threads(started_cluster): |
225 | 217 | ) |
226 | 218 | ) |
227 | 219 |
|
228 | | - total_values = generate_random_files( |
| 220 | + generate_random_files( |
229 | 221 | started_cluster, files_path, files_to_generate, start_ind=0, row_num=1 |
230 | 222 | ) |
231 | 223 |
|
@@ -296,7 +288,7 @@ def test_alter_settings(started_cluster): |
296 | 288 | f"SELECT * FROM system.zookeeper WHERE path = '{keeper_path}'" |
297 | 289 | ) |
298 | 290 |
|
299 | | - total_values = generate_random_files( |
| 291 | + generate_random_files( |
300 | 292 | started_cluster, files_path, files_to_generate, start_ind=0, row_num=1 |
301 | 293 | ) |
302 | 294 |
|
@@ -588,7 +580,7 @@ def test_registry(started_cluster): |
588 | 580 | for elem in expected: |
589 | 581 | assert elem in str(registry) |
590 | 582 |
|
591 | | - total_values = generate_random_files( |
| 583 | + generate_random_files( |
592 | 584 | started_cluster, files_path, files_to_generate, start_ind=0, row_num=1 |
593 | 585 | ) |
594 | 586 |
|
|
0 commit comments