Skip to content

Commit 89846fd

Browse files
committed
omit flag in client side
1 parent daea8a9 commit 89846fd

File tree

2 files changed

+4
-4
lines changed

2 files changed

+4
-4
lines changed

examples/query-service/basic_example.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -18,11 +18,11 @@ def main():
1818

1919
print("=" * 50)
2020
print("DELETE TABLE IF EXISTS")
21-
pool.execute_with_retries("drop table if exists example;", ddl=True)
21+
pool.execute_with_retries("drop table if exists example;")
2222

2323
print("=" * 50)
2424
print("CREATE TABLE")
25-
pool.execute_with_retries("CREATE TABLE example(key UInt64, value String, PRIMARY KEY (key));", ddl=True)
25+
pool.execute_with_retries("CREATE TABLE example(key UInt64, value String, PRIMARY KEY (key));")
2626

2727
pool.execute_with_retries("INSERT INTO example (key, value) VALUES (1, 'onepieceisreal');")
2828

ydb/query/pool.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -117,13 +117,13 @@ def wrapped_callee():
117117
return next_opt.result
118118

119119
def execute_with_retries(
120-
self, query: str, ddl: bool = False, retry_settings: RetrySettings = None, *args, **kwargs
120+
self, query: str, retry_settings: RetrySettings = None, *args, **kwargs
121121
):
122122
retry_settings = RetrySettings() if retry_settings is None else retry_settings
123123
with self.checkout() as session:
124124

125125
def wrapped_callee():
126-
it = session.execute(query, empty_tx_control=ddl)
126+
it = session.execute(query, empty_tx_control=True)
127127
return [result_set for result_set in it]
128128

129129
opt_generator = retry_operation_impl(wrapped_callee, retry_settings, *args, **kwargs)

0 commit comments

Comments
 (0)