@@ -94,7 +94,7 @@ def transaction(session):
94
94
def run_reads (driver , query , max_id , metrics , limiter , runtime , timeout ):
95
95
start_time = time .time ()
96
96
97
- logger .info ("Start read workload" )
97
+ logger .info ("Start read workload over table service " )
98
98
99
99
request_settings = ydb .BaseRequestSettings ().with_timeout (timeout )
100
100
retry_setting = ydb .RetrySettings (
@@ -128,7 +128,7 @@ def check_result(result):
128
128
129
129
130
130
def run_read_jobs (args , driver , tb_name , max_id , metrics ):
131
- logger .info ("Start read jobs" )
131
+ logger .info ("Start read jobs over table service " )
132
132
133
133
session = ydb .retry_operation_sync (lambda : driver .table_client .session ().create ())
134
134
read_q = session .prepare (READ_QUERY_TEMPLATE .format (tb_name ))
@@ -150,7 +150,7 @@ def run_read_jobs(args, driver, tb_name, max_id, metrics):
150
150
def run_reads_query (driver , query , max_id , metrics , limiter , runtime , timeout ):
151
151
start_time = time .time ()
152
152
153
- logger .info ("Start read workload" )
153
+ logger .info ("Start read workload over query service " )
154
154
155
155
request_settings = ydb .BaseRequestSettings ().with_timeout (timeout )
156
156
retry_setting = ydb .RetrySettings (
@@ -185,7 +185,7 @@ def check_result(result):
185
185
186
186
187
187
def run_read_jobs_query (args , driver , tb_name , max_id , metrics ):
188
- logger .info ("Start read jobs for query service" )
188
+ logger .info ("Start read jobs over query service" )
189
189
190
190
read_q = QUERY_READ_QUERY_TEMPLATE .format (tb_name )
191
191
@@ -205,7 +205,7 @@ def run_read_jobs_query(args, driver, tb_name, max_id, metrics):
205
205
def run_writes (driver , query , row_generator , metrics , limiter , runtime , timeout ):
206
206
start_time = time .time ()
207
207
208
- logger .info ("Start write workload" )
208
+ logger .info ("Start write workload over table service " )
209
209
210
210
request_settings = ydb .BaseRequestSettings ().with_timeout (timeout )
211
211
retry_setting = ydb .RetrySettings (
@@ -241,7 +241,7 @@ def run_writes(driver, query, row_generator, metrics, limiter, runtime, timeout)
241
241
242
242
243
243
def run_write_jobs (args , driver , tb_name , max_id , metrics ):
244
- logger .info ("Start write jobs" )
244
+ logger .info ("Start write jobs over table service " )
245
245
246
246
session = ydb .retry_operation_sync (lambda : driver .table_client .session ().create ())
247
247
write_q = session .prepare (WRITE_QUERY_TEMPLATE .format (tb_name ))
@@ -265,7 +265,7 @@ def run_write_jobs(args, driver, tb_name, max_id, metrics):
265
265
def run_writes_query (driver , query , row_generator , metrics , limiter , runtime , timeout ):
266
266
start_time = time .time ()
267
267
268
- logger .info ("Start write workload" )
268
+ logger .info ("Start write workload over query service " )
269
269
270
270
request_settings = ydb .BaseRequestSettings ().with_timeout (timeout )
271
271
retry_setting = ydb .RetrySettings (
0 commit comments