We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 89846fd commit 199e8d7Copy full SHA for 199e8d7
ydb/query/pool.py
@@ -123,10 +123,10 @@ def execute_with_retries(
123
with self.checkout() as session:
124
125
def wrapped_callee():
126
- it = session.execute(query, empty_tx_control=True)
+ it = session.execute(query, empty_tx_control=True, *args, **kwargs)
127
return [result_set for result_set in it]
128
129
- opt_generator = retry_operation_impl(wrapped_callee, retry_settings, *args, **kwargs)
+ opt_generator = retry_operation_impl(wrapped_callee, retry_settings)
130
for next_opt in opt_generator:
131
if isinstance(next_opt, YdbRetryOperationSleepOpt):
132
time.sleep(next_opt.timeout)
0 commit comments