Add fetch_schema to rpc.get_connection

tarantool · Jan 15, 2025 · 829ddcf · 829ddcf
1 parent 033ec75
commit 829ddcf
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 2 deletions.
diff --git a/CHANGELOG.rst b/CHANGELOG.rst
@@ -24,6 +24,12 @@ Changed
 
 - Update ``membership`` dependency to `2.4.6 <https://github.com/tarantool/membership/releases/tag/2.4.6>`_.
 
+~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
+Added
+~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
+
+- ``fetch_schema`` option to ``rpc.get_connection``.
+
 -------------------------------------------------------------------------------
 [2.13.0] - 2024-11-28
 -------------------------------------------------------------------------------

diff --git a/cartridge/rpc.lua b/cartridge/rpc.lua
@@ -146,8 +146,8 @@ local function get_connection(role_name, opts)
         prefer_local = '?boolean',
         leader_only = '?boolean',
         labels = '?table',
+        fetch_schema = '?boolean',
     })
-
     local candidates = get_candidates(role_name, {leader_only = opts.leader_only, labels = opts.labels})
     if next(candidates) == nil then
         if opts.labels then
@@ -174,7 +174,7 @@ local function get_connection(role_name, opts)
         num_candidates = num_candidates - 1
 
         uri = table.remove(candidates, n)
-        conn = pool.connect(uri, {wait_connected = false})
+        conn = pool.connect(uri, {wait_connected = false, fetch_schema = opts.fetch_schema})
     until conn:wait_connected() or num_candidates == 0
 
     if not conn:is_connected() then