diff --git a/python/python/lancedb/__init__.py b/python/python/lancedb/__init__.py index fb266a01..49149bf1 100644 --- a/python/python/lancedb/__init__.py +++ b/python/python/lancedb/__init__.py @@ -110,6 +110,7 @@ def connect( # TODO: remove this (deprecation warning downstream) request_thread_pool=request_thread_pool, client_config=client_config, + storage_options=storage_options, **kwargs, ) diff --git a/python/python/lancedb/remote/db.py b/python/python/lancedb/remote/db.py index d79aacd9..1dfa1c9a 100644 --- a/python/python/lancedb/remote/db.py +++ b/python/python/lancedb/remote/db.py @@ -44,9 +44,9 @@ class RemoteDBConnection(DBConnection): client_config: Union[ClientConfig, Dict[str, Any], None] = None, connection_timeout: Optional[float] = None, read_timeout: Optional[float] = None, + storage_options: Optional[Dict[str, str]] = None, ): """Connect to a remote LanceDB database.""" - if isinstance(client_config, dict): client_config = ClientConfig(**client_config) elif client_config is None: @@ -94,6 +94,7 @@ class RemoteDBConnection(DBConnection): region=region, host_override=host_override, client_config=client_config, + storage_options=storage_options, ) )