File tree 5 files changed +9
-4
lines changed
ydb/library/yql/providers/generic/connector/tests
5 files changed +9
-4
lines changed Original file line number Diff line number Diff line change @@ -241,7 +241,7 @@ def _large_table(self) -> Sequence[TestCase]:
241
241
test_cases = []
242
242
for data_source_kind in data_source_kinds :
243
243
tc = TestCase (
244
- name = f 'large_table' ,
244
+ name = 'large_table' ,
245
245
data_source_kind = data_source_kind ,
246
246
data_in = data_in ,
247
247
data_out_ = data_in ,
Original file line number Diff line number Diff line change 1
1
from pathlib import Path
2
2
import subprocess
3
3
from typing import Final
4
- import json
5
4
6
5
import jinja2
7
6
Original file line number Diff line number Diff line change 1
- from os import environ
2
1
from dataclasses import dataclass
3
2
from typing import Optional , Sequence
4
3
@@ -46,7 +45,7 @@ def from_env(cls) -> 'Settings':
46
45
connector = cls .Connector (
47
46
grpc_host = 'localhost' ,
48
47
grpc_port = 50051 ,
49
- paging_bytes_per_page = 4 * 1024 * 1024 ,
48
+ paging_bytes_per_page = 4 * 1024 * 1024 ,
50
49
paging_prefetch_queue_capacity = 2 ,
51
50
),
52
51
clickhouse = cls .ClickHouse (
Original file line number Diff line number Diff line change 1
1
import datetime
2
2
from typing import Sequence
3
3
4
+
4
5
def format_values_for_sql_insert (row : Sequence ) -> str :
5
6
row_values_dump = []
6
7
for val in row :
@@ -17,6 +18,7 @@ def format_values_for_sql_insert(row: Sequence) -> str:
17
18
values = "(" + ", " .join (row_values_dump ) + ")"
18
19
return values
19
20
21
+
20
22
def format_values_for_bulk_sql_insert (data_in : Sequence ) -> str :
21
23
"""
22
24
This function helps to build multiline INSERTs, like this:
Original file line number Diff line number Diff line change @@ -57,3 +57,8 @@ DEPENDS(
57
57
)
58
58
59
59
END()
60
+
61
+ RECURSE_FOR_TESTS(
62
+ test_cases
63
+ utils
64
+ )
You can’t perform that action at this time.
0 commit comments