Skip to content

Commit

Permalink
Auto-generated API code (#2467)
Browse files Browse the repository at this point in the history
  • Loading branch information
@elasticmachine
elasticmachine authored Mar 10, 2024
1 parent f02b7fa commit 53c5ea3
Show file tree
Hide file tree
Showing 76 changed files with 798 additions and 1,316 deletions.
81 changes: 27 additions & 54 deletions elasticsearch/_async/client/__init__.py
View file
Original file line number Diff line number Diff line change
Expand Up @@ -743,8 +743,7 @@ async def clear_scroll(
:param scroll_id: Scroll IDs to clear. To clear all scroll IDs, use `_all`.
"""
__path_parts: t.Dict[str, str]
__path_parts = {}
__path_parts: t.Dict[str, str] = {}
__path = "/_search/scroll"
__query: t.Dict[str, t.Any] = {}
__body: t.Dict[str, t.Any] = body if body is not None else {}
Expand Down Expand Up @@ -796,8 +795,7 @@ async def close_point_in_time(
"""
if id is None and body is None:
raise ValueError("Empty value passed for parameter 'id'")
__path_parts: t.Dict[str, str]
__path_parts = {}
__path_parts: t.Dict[str, str] = {}
__path = "/_pit"
__query: t.Dict[str, t.Any] = {}
__body: t.Dict[str, t.Any] = body if body is not None else {}
Expand Down Expand Up @@ -1038,8 +1036,7 @@ async def create(
)
elif document is not None and body is not None:
raise ValueError("Cannot set both 'document' and 'body'")
__path_parts: t.Dict[str, str]
__path_parts = {"index": _quote(index), "id": _quote(id)}
__path_parts: t.Dict[str, str] = {"index": _quote(index), "id": _quote(id)}
__path = f'/{__path_parts["index"]}/_create/{__path_parts["id"]}'
__query: t.Dict[str, t.Any] = {}
if error_trace is not None:
Expand Down Expand Up @@ -1130,8 +1127,7 @@ async def delete(
raise ValueError("Empty value passed for parameter 'index'")
if id in SKIP_IN_PATH:
raise ValueError("Empty value passed for parameter 'id'")
__path_parts: t.Dict[str, str]
__path_parts = {"index": _quote(index), "id": _quote(id)}
__path_parts: t.Dict[str, str] = {"index": _quote(index), "id": _quote(id)}
__path = f'/{__path_parts["index"]}/_doc/{__path_parts["id"]}'
__query: t.Dict[str, t.Any] = {}
if error_trace is not None:
Expand Down Expand Up @@ -1296,8 +1292,7 @@ async def delete_by_query(
"""
if index in SKIP_IN_PATH:
raise ValueError("Empty value passed for parameter 'index'")
__path_parts: t.Dict[str, str]
__path_parts = {"index": _quote(index)}
__path_parts: t.Dict[str, str] = {"index": _quote(index)}
__path = f'/{__path_parts["index"]}/_delete_by_query'
__query: t.Dict[str, t.Any] = {}
__body: t.Dict[str, t.Any] = body if body is not None else {}
Expand Down Expand Up @@ -1416,8 +1411,7 @@ async def delete_by_query_rethrottle(
"""
if task_id in SKIP_IN_PATH:
raise ValueError("Empty value passed for parameter 'task_id'")
__path_parts: t.Dict[str, str]
__path_parts = {"task_id": _quote(task_id)}
__path_parts: t.Dict[str, str] = {"task_id": _quote(task_id)}
__path = f'/_delete_by_query/{__path_parts["task_id"]}/_rethrottle'
__query: t.Dict[str, t.Any] = {}
if error_trace is not None:
Expand Down Expand Up @@ -1468,8 +1462,7 @@ async def delete_script(
"""
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_parts: t.Dict[str, str] = {"id": _quote(id)}
__path = f'/_scripts/{__path_parts["id"]}'
__query: t.Dict[str, t.Any] = {}
if error_trace is not None:
Expand Down Expand Up @@ -1555,8 +1548,7 @@ async def exists(
raise ValueError("Empty value passed for parameter 'index'")
if id in SKIP_IN_PATH:
raise ValueError("Empty value passed for parameter 'id'")
__path_parts: t.Dict[str, str]
__path_parts = {"index": _quote(index), "id": _quote(id)}
__path_parts: t.Dict[str, str] = {"index": _quote(index), "id": _quote(id)}
__path = f'/{__path_parts["index"]}/_doc/{__path_parts["id"]}'
__query: t.Dict[str, t.Any] = {}
if error_trace is not None:
Expand Down Expand Up @@ -1654,8 +1646,7 @@ async def exists_source(
raise ValueError("Empty value passed for parameter 'index'")
if id in SKIP_IN_PATH:
raise ValueError("Empty value passed for parameter 'id'")
__path_parts: t.Dict[str, str]
__path_parts = {"index": _quote(index), "id": _quote(id)}
__path_parts: t.Dict[str, str] = {"index": _quote(index), "id": _quote(id)}
__path = f'/{__path_parts["index"]}/_source/{__path_parts["id"]}'
__query: t.Dict[str, t.Any] = {}
if error_trace is not None:
Expand Down Expand Up @@ -1761,8 +1752,7 @@ async def explain(
raise ValueError("Empty value passed for parameter 'index'")
if id in SKIP_IN_PATH:
raise ValueError("Empty value passed for parameter 'id'")
__path_parts: t.Dict[str, str]
__path_parts = {"index": _quote(index), "id": _quote(id)}
__path_parts: t.Dict[str, str] = {"index": _quote(index), "id": _quote(id)}
__path = f'/{__path_parts["index"]}/_explain/{__path_parts["id"]}'
__query: t.Dict[str, t.Any] = {}
__body: t.Dict[str, t.Any] = body if body is not None else {}
Expand Down Expand Up @@ -1992,8 +1982,7 @@ async def get(
raise ValueError("Empty value passed for parameter 'index'")
if id in SKIP_IN_PATH:
raise ValueError("Empty value passed for parameter 'id'")
__path_parts: t.Dict[str, str]
__path_parts = {"index": _quote(index), "id": _quote(id)}
__path_parts: t.Dict[str, str] = {"index": _quote(index), "id": _quote(id)}
__path = f'/{__path_parts["index"]}/_doc/{__path_parts["id"]}'
__query: t.Dict[str, t.Any] = {}
if error_trace is not None:
Expand Down Expand Up @@ -2057,8 +2046,7 @@ async def get_script(
"""
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_parts: t.Dict[str, str] = {"id": _quote(id)}
__path = f'/_scripts/{__path_parts["id"]}'
__query: t.Dict[str, t.Any] = {}
if error_trace is not None:
Expand Down Expand Up @@ -2095,8 +2083,7 @@ async def get_script_context(
`<https://www.elastic.co/guide/en/elasticsearch/painless/master/painless-contexts.html>`_
"""
__path_parts: t.Dict[str, str]
__path_parts = {}
__path_parts: t.Dict[str, str] = {}
__path = "/_script_context"
__query: t.Dict[str, t.Any] = {}
if error_trace is not None:
Expand Down Expand Up @@ -2131,8 +2118,7 @@ async def get_script_languages(
`<https://www.elastic.co/guide/en/elasticsearch/reference/master/modules-scripting.html>`_
"""
__path_parts: t.Dict[str, str]
__path_parts = {}
__path_parts: t.Dict[str, str] = {}
__path = "/_script_language"
__query: t.Dict[str, t.Any] = {}
if error_trace is not None:
Expand Down Expand Up @@ -2211,8 +2197,7 @@ async def get_source(
raise ValueError("Empty value passed for parameter 'index'")
if id in SKIP_IN_PATH:
raise ValueError("Empty value passed for parameter 'id'")
__path_parts: t.Dict[str, str]
__path_parts = {"index": _quote(index), "id": _quote(id)}
__path_parts: t.Dict[str, str] = {"index": _quote(index), "id": _quote(id)}
__path = f'/{__path_parts["index"]}/_source/{__path_parts["id"]}'
__query: t.Dict[str, t.Any] = {}
if error_trace is not None:
Expand Down Expand Up @@ -2455,8 +2440,7 @@ async def info(
`<https://www.elastic.co/guide/en/elasticsearch/reference/master/index.html>`_
"""
__path_parts: t.Dict[str, str]
__path_parts = {}
__path_parts: t.Dict[str, str] = {}
__path = "/"
__query: t.Dict[str, t.Any] = {}
if error_trace is not None:
Expand Down Expand Up @@ -2537,8 +2521,7 @@ async def knn_search(
raise ValueError("Empty value passed for parameter 'index'")
if knn is None and body is None:
raise ValueError("Empty value passed for parameter 'knn'")
__path_parts: t.Dict[str, str]
__path_parts = {"index": _quote(index)}
__path_parts: t.Dict[str, str] = {"index": _quote(index)}
__path = f'/{__path_parts["index"]}/_knn_search'
__query: t.Dict[str, t.Any] = {}
__body: t.Dict[str, t.Any] = body if body is not None else {}
Expand Down Expand Up @@ -3069,8 +3052,7 @@ async def open_point_in_time(
raise ValueError("Empty value passed for parameter 'index'")
if keep_alive is None:
raise ValueError("Empty value passed for parameter 'keep_alive'")
__path_parts: t.Dict[str, str]
__path_parts = {"index": _quote(index)}
__path_parts: t.Dict[str, str] = {"index": _quote(index)}
__path = f'/{__path_parts["index"]}/_pit'
__query: t.Dict[str, t.Any] = {}
if keep_alive is not None:
Expand Down Expand Up @@ -3335,8 +3317,7 @@ async def reindex(
raise ValueError("Empty value passed for parameter 'dest'")
if source is None and body is None:
raise ValueError("Empty value passed for parameter 'source'")
__path_parts: t.Dict[str, str]
__path_parts = {}
__path_parts: t.Dict[str, str] = {}
__path = "/_reindex"
__query: t.Dict[str, t.Any] = {}
__body: t.Dict[str, t.Any] = body if body is not None else {}
Expand Down Expand Up @@ -3410,8 +3391,7 @@ async def reindex_rethrottle(
"""
if task_id in SKIP_IN_PATH:
raise ValueError("Empty value passed for parameter 'task_id'")
__path_parts: t.Dict[str, str]
__path_parts = {"task_id": _quote(task_id)}
__path_parts: t.Dict[str, str] = {"task_id": _quote(task_id)}
__path = f'/_reindex/{__path_parts["task_id"]}/_rethrottle'
__query: t.Dict[str, t.Any] = {}
if error_trace is not None:
Expand Down Expand Up @@ -3528,8 +3508,7 @@ async def scripts_painless_execute(
:param context_setup: Additional parameters for the `context`.
:param script: The Painless script to execute.
"""
__path_parts: t.Dict[str, str]
__path_parts = {}
__path_parts: t.Dict[str, str] = {}
__path = "/_scripts/painless/_execute"
__query: t.Dict[str, t.Any] = {}
__body: t.Dict[str, t.Any] = body if body is not None else {}
Expand Down Expand Up @@ -3591,8 +3570,7 @@ async def scroll(
"""
if scroll_id is None and body is None:
raise ValueError("Empty value passed for parameter 'scroll_id'")
__path_parts: t.Dict[str, str]
__path_parts = {}
__path_parts: t.Dict[str, str] = {}
__path = "/_search/scroll"
__query: t.Dict[str, t.Any] = {}
__body: t.Dict[str, t.Any] = body if body is not None else {}
Expand Down Expand Up @@ -4234,8 +4212,7 @@ async def search_mvt(
raise ValueError("Empty value passed for parameter 'x'")
if y in SKIP_IN_PATH:
raise ValueError("Empty value passed for parameter 'y'")
__path_parts: t.Dict[str, str]
__path_parts = {
__path_parts: t.Dict[str, str] = {
"index": _quote(index),
"field": _quote(field),
"zoom": _quote(zoom),
Expand Down Expand Up @@ -4593,8 +4570,7 @@ async def terms_enum(
raise ValueError("Empty value passed for parameter 'index'")
if field is None and body is None:
raise ValueError("Empty value passed for parameter 'field'")
__path_parts: t.Dict[str, str]
__path_parts = {"index": _quote(index)}
__path_parts: t.Dict[str, str] = {"index": _quote(index)}
__path = f'/{__path_parts["index"]}/_terms_enum'
__query: t.Dict[str, t.Any] = {}
__body: t.Dict[str, t.Any] = body if body is not None else {}
Expand Down Expand Up @@ -4854,8 +4830,7 @@ async def update(
raise ValueError("Empty value passed for parameter 'index'")
if id in SKIP_IN_PATH:
raise ValueError("Empty value passed for parameter 'id'")
__path_parts: t.Dict[str, str]
__path_parts = {"index": _quote(index), "id": _quote(id)}
__path_parts: t.Dict[str, str] = {"index": _quote(index), "id": _quote(id)}
__path = f'/{__path_parts["index"]}/_update/{__path_parts["id"]}'
__query: t.Dict[str, t.Any] = {}
__body: t.Dict[str, t.Any] = body if body is not None else {}
Expand Down Expand Up @@ -5054,8 +5029,7 @@ async def update_by_query(
"""
if index in SKIP_IN_PATH:
raise ValueError("Empty value passed for parameter 'index'")
__path_parts: t.Dict[str, str]
__path_parts = {"index": _quote(index)}
__path_parts: t.Dict[str, str] = {"index": _quote(index)}
__path = f'/{__path_parts["index"]}/_update_by_query'
__query: t.Dict[str, t.Any] = {}
__body: t.Dict[str, t.Any] = body if body is not None else {}
Expand Down Expand Up @@ -5182,8 +5156,7 @@ async def update_by_query_rethrottle(
"""
if task_id in SKIP_IN_PATH:
raise ValueError("Empty value passed for parameter 'task_id'")
__path_parts: t.Dict[str, str]
__path_parts = {"task_id": _quote(task_id)}
__path_parts: t.Dict[str, str] = {"task_id": _quote(task_id)}
__path = f'/_update_by_query/{__path_parts["task_id"]}/_rethrottle'
__query: t.Dict[str, t.Any] = {}
if error_trace is not None:
Expand Down
9 changes: 3 additions & 6 deletions elasticsearch/_async/client/async_search.py
View file
Original file line number Diff line number Diff line change
Expand Up @@ -45,8 +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_parts: t.Dict[str, str] = {"id": _quote(id)}
__path = f'/_async_search/{__path_parts["id"]}'
__query: t.Dict[str, t.Any] = {}
if error_trace is not None:
Expand Down Expand Up @@ -106,8 +105,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_parts: t.Dict[str, str] = {"id": _quote(id)}
__path = f'/_async_search/{__path_parts["id"]}'
__query: t.Dict[str, t.Any] = {}
if error_trace is not None:
Expand Down Expand Up @@ -154,8 +152,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_parts: t.Dict[str, str] = {"id": _quote(id)}
__path = f'/_async_search/status/{__path_parts["id"]}'
__query: t.Dict[str, t.Any] = {}
if error_trace is not None:
Expand Down
12 changes: 4 additions & 8 deletions elasticsearch/_async/client/autoscaling.py
View file
Original file line number Diff line number Diff line change
Expand Up @@ -45,8 +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_parts: t.Dict[str, str] = {"name": _quote(name)}
__path = f'/_autoscaling/policy/{__path_parts["name"]}'
__query: t.Dict[str, t.Any] = {}
if error_trace is not None:
Expand Down Expand Up @@ -82,8 +81,7 @@ 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_parts: t.Dict[str, str] = {}
__path = "/_autoscaling/capacity"
__query: t.Dict[str, t.Any] = {}
if error_trace is not None:
Expand Down Expand Up @@ -124,8 +122,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_parts: t.Dict[str, str] = {"name": _quote(name)}
__path = f'/_autoscaling/policy/{__path_parts["name"]}'
__query: t.Dict[str, t.Any] = {}
if error_trace is not None:
Expand Down Expand Up @@ -177,8 +174,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_parts: t.Dict[str, str] = {"name": _quote(name)}
__path = f'/_autoscaling/policy/{__path_parts["name"]}'
__query: t.Dict[str, t.Any] = {}
if error_trace is not None:
Expand Down
Loading

0 comments on commit 53c5ea3

Please sign in to comment.