Skip to content

Commit 6a35578

Browse files
committed
Pass endpoint_id and path_parts to BaseClient
1 parent a2b6c8a commit 6a35578

File tree

2 files changed

+22
-2
lines changed

2 files changed

+22
-2
lines changed

elasticsearch_serverless/_async/client/_base.py

Lines changed: 11 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -138,6 +138,8 @@ async def perform_request(
138138
params: Optional[Mapping[str, Any]] = None,
139139
headers: Optional[Mapping[str, str]] = None,
140140
body: Optional[Any] = None,
141+
endpoint_id: Optional[str] = None,
142+
path_parts: Optional[Mapping[str, Any]] = None,
141143
) -> ApiResponse[Any]:
142144
if headers:
143145
request_headers = self._headers.copy()
@@ -251,9 +253,17 @@ async def perform_request(
251253
params: Optional[Mapping[str, Any]] = None,
252254
headers: Optional[Mapping[str, str]] = None,
253255
body: Optional[Any] = None,
256+
endpoint_id: Optional[str] = None,
257+
path_parts: Optional[Mapping[str, Any]] = None,
254258
) -> ApiResponse[Any]:
255259
# Use the internal clients .perform_request() implementation
256260
# so we take advantage of their transport options.
257261
return await self._client.perform_request(
258-
method, path, params=params, headers=headers, body=body
262+
method,
263+
path,
264+
params=params,
265+
headers=headers,
266+
body=body,
267+
endpoint_id=endpoint_id,
268+
path_parts=path_parts,
259269
)

elasticsearch_serverless/_sync/client/_base.py

Lines changed: 11 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -138,6 +138,8 @@ def perform_request(
138138
params: Optional[Mapping[str, Any]] = None,
139139
headers: Optional[Mapping[str, str]] = None,
140140
body: Optional[Any] = None,
141+
endpoint_id: Optional[str] = None,
142+
path_parts: Optional[Mapping[str, Any]] = None,
141143
) -> ApiResponse[Any]:
142144
if headers:
143145
request_headers = self._headers.copy()
@@ -251,9 +253,17 @@ def perform_request(
251253
params: Optional[Mapping[str, Any]] = None,
252254
headers: Optional[Mapping[str, str]] = None,
253255
body: Optional[Any] = None,
256+
endpoint_id: Optional[str] = None,
257+
path_parts: Optional[Mapping[str, Any]] = None,
254258
) -> ApiResponse[Any]:
255259
# Use the internal clients .perform_request() implementation
256260
# so we take advantage of their transport options.
257261
return self._client.perform_request(
258-
method, path, params=params, headers=headers, body=body
262+
method,
263+
path,
264+
params=params,
265+
headers=headers,
266+
body=body,
267+
endpoint_id=endpoint_id,
268+
path_parts=path_parts,
259269
)

0 commit comments

Comments
 (0)