Skip to content

Commit 467f1de

Browse files
committed
Fix headers for http
1 parent 46161c1 commit 467f1de

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

weaviate/connect/v4.py

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -154,13 +154,13 @@ def __init__(
154154
self.__add_weaviate_embedding_service_header(connection_params.http.host)
155155
if additional_headers is not None:
156156
_validate_input(_ValidateArgument([dict], "additional_headers", additional_headers))
157-
self.__additional_headers = additional_headers
158157
for key, value in additional_headers.items():
159158
if value is None:
160159
raise WeaviateInvalidInputError(
161160
f"Value for key '{key}' in headers cannot be None."
162161
)
163-
self._headers[key.lower()] = value
162+
self.__additional_headers[key] = str(value)
163+
self._headers[key.lower()] = str(value)
164164

165165
self._proxies: Dict[str, str] = _get_proxies(proxies, trust_env)
166166

@@ -599,7 +599,7 @@ def __get_latest_headers(self) -> Dict[str, str]:
599599

600600
# bearer token can change over time (OIDC) so we need to get the current one for each request
601601
copied_headers = copy(self._headers)
602-
copied_headers.update({"authorization": self.get_current_bearer_token()})
602+
copied_headers.update({"authorization": str(self.get_current_bearer_token())})
603603
return copied_headers
604604

605605
def __get_timeout(

0 commit comments

Comments
 (0)