rust/lancedb
1
0
Fork 0
mirror of https://github.com/lancedb/lancedb.git synced 2026-05-14 10:30:40 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix(python): use declared location for namespace table open

Browse Source
This commit is contained in:
Jack Ye
2026-04-17 09:58:00 -07:00
parent d715bbb588
commit 15fbcf61fc
1 changed files with 27 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

37
python/python/lancedb/namespace.py
View File

@@ -578,13 +578,18 @@ class LanceNamespaceDBConnection(DBConnection):
on_bad_vectors=on_bad_vectors,
fill_value=fill_value,
embedding_functions=embedding_functions,
namespace_path=namespace_path,
namespace_path=[],
storage_options=merged_storage_options,
location=location,
namespace_client=self._namespace_client,
pushdown_operations=self._namespace_client_pushdown_operations,
)
tbl._namespace_path = namespace_path
tbl._location = location
tbl._namespace_client = self._namespace_client
tbl._pushdown_operations = self._namespace_client_pushdown_operations
return tbl
def _create_table_server_side(
@@ -914,18 +919,24 @@ class LanceNamespaceDBConnection(DBConnection):
# storage options provider
# Pass managed_versioning to avoid redundant describe_table call
# Pass pushdown_operations if configured on this connection
return LanceTable.open(
table = LanceTable.open(
temp_conn,
name,
namespace_path=namespace_path,
namespace_path=[],
storage_options=storage_options,
index_cache_size=index_cache_size,
location=table_uri,
namespace_client=namespace_client,
managed_versioning=managed_versioning,
namespace_client=None,
managed_versioning=False,
pushdown_operations=self._namespace_client_pushdown_operations,
)
table._namespace_path = namespace_path
table._location = table_uri
table._namespace_client = namespace_client
table._pushdown_operations = self._namespace_client_pushdown_operations
return table
@override
def namespace_client(self) -> LanceNamespace:
"""Get the namespace client for this connection.
@@ -1120,7 +1131,7 @@ class AsyncLanceNamespaceDBConnection:
on_bad_vectors=on_bad_vectors,
fill_value=fill_value,
embedding_functions=embedding_functions,
namespace_path=namespace_path,
namespace_path=[],
storage_options=merged_storage_options,
location=location,
namespace_client=self._namespace_client,
@@ -1222,18 +1233,24 @@ class AsyncLanceNamespaceDBConnection:
session=self.session,
)
return LanceTable.open(
table = LanceTable.open(
temp_conn,
name,
namespace_path=namespace_path,
namespace_path=[],
storage_options=merged_storage_options,
index_cache_size=index_cache_size,
location=response.location,
namespace_client=self._namespace_client,
managed_versioning=managed_versioning,
namespace_client=None,
managed_versioning=False,
pushdown_operations=self._namespace_client_pushdown_operations,
)
table._namespace_path = namespace_path
table._location = response.location
table._namespace_client = self._namespace_client
table._pushdown_operations = self._namespace_client_pushdown_operations
return table
lance_table = await asyncio.to_thread(_open_table)
return lance_table._table