We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 640c592 commit 2dc672cCopy full SHA for 2dc672c
pyiceberg/catalog/rest/__init__.py
@@ -274,6 +274,14 @@ def _create_session(self) -> Session:
274
if property_as_bool(self.properties, SIGV4, False):
275
self._init_sigv4(session)
276
277
+ # Mount custom adapters
278
+ if session_adapters := self.properties.get("session_adapters"):
279
+ for prefix, adapter in session_adapters.items(): # type: ignore
280
+ session.mount(prefix, adapter)
281
+ # Add custom auth
282
+ if session_auth := self.properties.get("session_auth"):
283
+ session.auth = session_auth # type: ignore
284
+
285
return session
286
287
def _create_legacy_oauth2_auth_manager(self, session: Session) -> AuthManager:
0 commit comments