Skip to content

Commit 49cdce0

Browse files
committed
style fixes
1 parent 825c462 commit 49cdce0

File tree

2 files changed

+5
-2
lines changed

2 files changed

+5
-2
lines changed

ydb/query/pool.py

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -116,9 +116,12 @@ def wrapped_callee():
116116
else:
117117
return next_opt.result
118118

119-
def execute_with_retries(self, query: str, ddl: bool = False, retry_settings: RetrySettings = None, *args, **kwargs):
119+
def execute_with_retries(
120+
self, query: str, ddl: bool = False, retry_settings: RetrySettings = None, *args, **kwargs
121+
):
120122
retry_settings = RetrySettings() if retry_settings is None else retry_settings
121123
with self.checkout() as session:
124+
122125
def wrapped_callee():
123126
it = session.execute(query, empty_tx_control=ddl)
124127
return [result_set for result_set in it]

ydb/query/session.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -249,7 +249,7 @@ def execute(
249249
exec_mode: base.QueryExecMode = None,
250250
parameters: dict = None,
251251
concurrent_result_sets: bool = False,
252-
empty_tx_control: bool = False
252+
empty_tx_control: bool = False,
253253
):
254254
self._state._check_session_ready_to_use()
255255

0 commit comments

Comments
 (0)