Auto-generated API code

Author: elasticmachine

elasticsearch/_async/client/__init__.py

@@ -45,9 +45,7 @@ async def delete(
         """
         if id in SKIP_IN_PATH:
             raise ValueError("Empty value passed for parameter 'id'")
-        __path_parts: t.Dict[str, str]
-        __path_parts = {"id": _quote(id)}
-        __path = f'/_async_search/{__path_parts["id"]}'
+        __path = f"/_async_search/{_quote(id)}"
         __query: t.Dict[str, t.Any] = {}
         if error_trace is not None:
             __query["error_trace"] = error_trace
@@ -59,12 +57,7 @@ async def delete(
             __query["pretty"] = pretty
         __headers = {"accept": "application/json"}
         return await self.perform_request(  # type: ignore[return-value]
-            "DELETE",
-            __path,
-            params=__query,
-            headers=__headers,
-            endpoint_id="async_search.delete",
-            path_parts=__path_parts,
+            "DELETE", __path, params=__query, headers=__headers
         )
 
     @_rewrite_parameters()
@@ -106,9 +99,7 @@ async def get(
         """
         if id in SKIP_IN_PATH:
             raise ValueError("Empty value passed for parameter 'id'")
-        __path_parts: t.Dict[str, str]
-        __path_parts = {"id": _quote(id)}
-        __path = f'/_async_search/{__path_parts["id"]}'
+        __path = f"/_async_search/{_quote(id)}"
         __query: t.Dict[str, t.Any] = {}
         if error_trace is not None:
             __query["error_trace"] = error_trace
@@ -126,12 +117,7 @@ async def get(
             __query["wait_for_completion_timeout"] = wait_for_completion_timeout
         __headers = {"accept": "application/json"}
         return await self.perform_request(  # type: ignore[return-value]
-            "GET",
-            __path,
-            params=__query,
-            headers=__headers,
-            endpoint_id="async_search.get",
-            path_parts=__path_parts,
+            "GET", __path, params=__query, headers=__headers
         )
 
     @_rewrite_parameters()
@@ -154,9 +140,7 @@ async def status(
         """
         if id in SKIP_IN_PATH:
             raise ValueError("Empty value passed for parameter 'id'")
-        __path_parts: t.Dict[str, str]
-        __path_parts = {"id": _quote(id)}
-        __path = f'/_async_search/status/{__path_parts["id"]}'
+        __path = f"/_async_search/status/{_quote(id)}"
         __query: t.Dict[str, t.Any] = {}
         if error_trace is not None:
             __query["error_trace"] = error_trace
@@ -168,12 +152,7 @@ async def status(
             __query["pretty"] = pretty
         __headers = {"accept": "application/json"}
         return await self.perform_request(  # type: ignore[return-value]
-            "GET",
-            __path,
-            params=__query,
-            headers=__headers,
-            endpoint_id="async_search.status",
-            path_parts=__path_parts,
+            "GET", __path, params=__query, headers=__headers
         )
 
     @_rewrite_parameters(
@@ -449,12 +428,9 @@ async def submit(
             up to a certain timeout. When the async search completes within the timeout,
             the response won’t include the ID as the results are not stored in the cluster.
         """
-        __path_parts: t.Dict[str, str]
         if index not in SKIP_IN_PATH:
-            __path_parts = {"index": _quote(index)}
-            __path = f'/{__path_parts["index"]}/_async_search'
+            __path = f"/{_quote(index)}/_async_search"
         else:
-            __path_parts = {}
             __path = "/_async_search"
         __query: t.Dict[str, t.Any] = {}
         __body: t.Dict[str, t.Any] = body if body is not None else {}
@@ -614,11 +590,5 @@ async def submit(
         if __body is not None:
             __headers["content-type"] = "application/json"
         return await self.perform_request(  # type: ignore[return-value]
-            "POST",
-            __path,
-            params=__query,
-            headers=__headers,
-            body=__body,
-            endpoint_id="async_search.submit",
-            path_parts=__path_parts,
+            "POST", __path, params=__query, headers=__headers, body=__body
         )

elasticsearch/_async/client/async_search.py

@@ -45,9 +45,7 @@ async def delete_autoscaling_policy(
         """
         if name in SKIP_IN_PATH:
             raise ValueError("Empty value passed for parameter 'name'")
-        __path_parts: t.Dict[str, str]
-        __path_parts = {"name": _quote(name)}
-        __path = f'/_autoscaling/policy/{__path_parts["name"]}'
+        __path = f"/_autoscaling/policy/{_quote(name)}"
         __query: t.Dict[str, t.Any] = {}
         if error_trace is not None:
             __query["error_trace"] = error_trace
@@ -59,12 +57,7 @@ async def delete_autoscaling_policy(
             __query["pretty"] = pretty
         __headers = {"accept": "application/json"}
         return await self.perform_request(  # type: ignore[return-value]
-            "DELETE",
-            __path,
-            params=__query,
-            headers=__headers,
-            endpoint_id="autoscaling.delete_autoscaling_policy",
-            path_parts=__path_parts,
+            "DELETE", __path, params=__query, headers=__headers
         )
 
     @_rewrite_parameters()
@@ -82,8 +75,6 @@ async def get_autoscaling_capacity(
 
         `<https://www.elastic.co/guide/en/elasticsearch/reference/master/autoscaling-get-autoscaling-capacity.html>`_
         """
-        __path_parts: t.Dict[str, str]
-        __path_parts = {}
         __path = "/_autoscaling/capacity"
         __query: t.Dict[str, t.Any] = {}
         if error_trace is not None:
@@ -96,12 +87,7 @@ async def get_autoscaling_capacity(
             __query["pretty"] = pretty
         __headers = {"accept": "application/json"}
         return await self.perform_request(  # type: ignore[return-value]
-            "GET",
-            __path,
-            params=__query,
-            headers=__headers,
-            endpoint_id="autoscaling.get_autoscaling_capacity",
-            path_parts=__path_parts,
+            "GET", __path, params=__query, headers=__headers
         )
 
     @_rewrite_parameters()
@@ -124,9 +110,7 @@ async def get_autoscaling_policy(
         """
         if name in SKIP_IN_PATH:
             raise ValueError("Empty value passed for parameter 'name'")
-        __path_parts: t.Dict[str, str]
-        __path_parts = {"name": _quote(name)}
-        __path = f'/_autoscaling/policy/{__path_parts["name"]}'
+        __path = f"/_autoscaling/policy/{_quote(name)}"
         __query: t.Dict[str, t.Any] = {}
         if error_trace is not None:
             __query["error_trace"] = error_trace
@@ -138,12 +122,7 @@ async def get_autoscaling_policy(
             __query["pretty"] = pretty
         __headers = {"accept": "application/json"}
         return await self.perform_request(  # type: ignore[return-value]
-            "GET",
-            __path,
-            params=__query,
-            headers=__headers,
-            endpoint_id="autoscaling.get_autoscaling_policy",
-            path_parts=__path_parts,
+            "GET", __path, params=__query, headers=__headers
         )
 
     @_rewrite_parameters(
@@ -177,9 +156,7 @@ async def put_autoscaling_policy(
             )
         elif policy is not None and body is not None:
             raise ValueError("Cannot set both 'policy' and 'body'")
-        __path_parts: t.Dict[str, str]
-        __path_parts = {"name": _quote(name)}
-        __path = f'/_autoscaling/policy/{__path_parts["name"]}'
+        __path = f"/_autoscaling/policy/{_quote(name)}"
         __query: t.Dict[str, t.Any] = {}
         if error_trace is not None:
             __query["error_trace"] = error_trace
@@ -192,11 +169,5 @@ async def put_autoscaling_policy(
         __body = policy if policy is not None else body
         __headers = {"accept": "application/json", "content-type": "application/json"}
         return await self.perform_request(  # type: ignore[return-value]
-            "PUT",
-            __path,
-            params=__query,
-            headers=__headers,
-            body=__body,
-            endpoint_id="autoscaling.put_autoscaling_policy",
-            path_parts=__path_parts,
+            "PUT", __path, params=__query, headers=__headers, body=__body
         )