Skip to content

Commit 6c58895

Browse files
Set mode for call request
1 parent 1198151 commit 6c58895

File tree

2 files changed

+17
-10
lines changed

2 files changed

+17
-10
lines changed

tarantool/connection.py

Lines changed: 12 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -392,7 +392,16 @@ def flush_schema(self):
392392
self.schema.flush()
393393
self.load_schema()
394394

395-
def call(self, func_name, *args):
395+
def _build_call_request(self, func_name, args, kwargs):
396+
assert isinstance(func_name, str)
397+
398+
# This allows to use a tuple or list as an argument
399+
if len(args) == 1 and isinstance(args[0], (list, tuple)):
400+
args = args[0]
401+
402+
return RequestCall(self, func_name, args, self.call_16)
403+
404+
def call(self, func_name, *args, **kwargs):
396405
'''
397406
Execute CALL request. Call stored Lua function.
398407
@@ -403,15 +412,8 @@ def call(self, func_name, *args):
403412
404413
:rtype: `Response` instance
405414
'''
406-
assert isinstance(func_name, str)
407-
408-
# This allows to use a tuple or list as an argument
409-
if len(args) == 1 and isinstance(args[0], (list, tuple)):
410-
args = args[0]
411-
412-
request = RequestCall(self, func_name, args, self.call_16)
413-
response = self._send_request(request)
414-
return response
415+
request = self._build_call_request(func_name, args, kwargs)
416+
return self._send_request(request)
415417

416418
def eval(self, expr, *args):
417419
'''

tarantool/mesh_connection.py

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -373,3 +373,8 @@ def _build_insert_request(self, space_name, values):
373373
request = super(MeshConnection, self)._build_insert_request(space_name, values)
374374
request.mode = Mode.RW
375375
return request
376+
377+
def _build_call_request(self, func_name, args, kwargs):
378+
request = super(MeshConnection, self)._build_call_request(func_name, args, kwargs)
379+
request.mode = kwargs.get("mode", Mode.PREFER_RW)
380+
return request

0 commit comments

Comments
 (0)