Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
129 changes: 54 additions & 75 deletions elasticsearch/_async/client/__init__.py

Large diffs are not rendered by default.

12 changes: 4 additions & 8 deletions elasticsearch/_async/client/async_search.py
Original file line number Diff line number Diff line change
Expand Up @@ -44,7 +44,7 @@ async def delete(
If the Elasticsearch security features are enabled, the deletion of a specific async search is restricted to: the authenticated user that submitted the original search request; users that have the <code>cancel_task</code> cluster privilege.</p>


`<https://www.elastic.co/guide/en/elasticsearch/reference/8.17/async-search.html>`_
`<https://www.elastic.co/guide/en/elasticsearch/reference/8.19/async-search.html>`_

:param id: A unique identifier for the async search.
"""
Expand Down Expand Up @@ -94,7 +94,7 @@ async def get(
If the Elasticsearch security features are enabled, access to the results of a specific async search is restricted to the user or API key that submitted it.</p>


`<https://www.elastic.co/guide/en/elasticsearch/reference/8.17/async-search.html>`_
`<https://www.elastic.co/guide/en/elasticsearch/reference/8.19/async-search.html>`_

:param id: A unique identifier for the async search.
:param keep_alive: The length of time that the async search should be available
Expand Down Expand Up @@ -164,7 +164,7 @@ async def status(
</ul>


`<https://www.elastic.co/guide/en/elasticsearch/reference/8.17/async-search.html>`_
`<https://www.elastic.co/guide/en/elasticsearch/reference/8.19/async-search.html>`_

:param id: A unique identifier for the async search.
:param keep_alive: The length of time that the async search needs to be available.
Expand Down Expand Up @@ -281,7 +281,6 @@ async def submit(
] = None,
lenient: t.Optional[bool] = None,
max_concurrent_shard_requests: t.Optional[int] = None,
min_compatible_shard_node: t.Optional[str] = None,
min_score: t.Optional[float] = None,
pit: t.Optional[t.Mapping[str, t.Any]] = None,
post_filter: t.Optional[t.Mapping[str, t.Any]] = None,
Expand Down Expand Up @@ -346,7 +345,7 @@ async def submit(
The maximum allowed size for a stored async search response can be set by changing the <code>search.max_async_search_response_size</code> cluster level setting.</p>


`<https://www.elastic.co/guide/en/elasticsearch/reference/8.17/async-search.html>`_
`<https://www.elastic.co/guide/en/elasticsearch/reference/8.19/async-search.html>`_

:param index: A comma-separated list of index names to search; use `_all` or
empty string to perform the operation on all indices
Expand Down Expand Up @@ -401,7 +400,6 @@ async def submit(
per node this search executes concurrently. This value should be used to
limit the impact of the search on the cluster in order to limit the number
of concurrent shard requests
:param min_compatible_shard_node:
:param min_score: Minimum _score for matching documents. Documents with a lower
_score are not included in search results and results collected by aggregations.
:param pit: Limits the search to a point in time (PIT). If you provide a PIT,
Expand Down Expand Up @@ -526,8 +524,6 @@ async def submit(
__query["lenient"] = lenient
if max_concurrent_shard_requests is not None:
__query["max_concurrent_shard_requests"] = max_concurrent_shard_requests
if min_compatible_shard_node is not None:
__query["min_compatible_shard_node"] = min_compatible_shard_node
if preference is not None:
__query["preference"] = preference
if pretty is not None:
Expand Down
8 changes: 4 additions & 4 deletions elasticsearch/_async/client/autoscaling.py
Original file line number Diff line number Diff line change
Expand Up @@ -44,7 +44,7 @@ async def delete_autoscaling_policy(
<p>NOTE: This feature is designed for indirect use by Elasticsearch Service, Elastic Cloud Enterprise, and Elastic Cloud on Kubernetes. Direct use is not supported.</p>


`<https://www.elastic.co/guide/en/elasticsearch/reference/8.17/autoscaling-delete-autoscaling-policy.html>`_
`<https://www.elastic.co/guide/en/elasticsearch/reference/8.19/autoscaling-delete-autoscaling-policy.html>`_

:param name: the name of the autoscaling policy
:param master_timeout: Period to wait for a connection to the master node. If
Expand Down Expand Up @@ -104,7 +104,7 @@ async def get_autoscaling_capacity(
Do not use this information to make autoscaling decisions.</p>


`<https://www.elastic.co/guide/en/elasticsearch/reference/8.17/autoscaling-get-autoscaling-capacity.html>`_
`<https://www.elastic.co/guide/en/elasticsearch/reference/8.19/autoscaling-get-autoscaling-capacity.html>`_

:param master_timeout: Period to wait for a connection to the master node. If
no response is received before the timeout expires, the request fails and
Expand Down Expand Up @@ -151,7 +151,7 @@ async def get_autoscaling_policy(
<p>NOTE: This feature is designed for indirect use by Elasticsearch Service, Elastic Cloud Enterprise, and Elastic Cloud on Kubernetes. Direct use is not supported.</p>


`<https://www.elastic.co/guide/en/elasticsearch/reference/8.17/autoscaling-get-autoscaling-capacity.html>`_
`<https://www.elastic.co/guide/en/elasticsearch/reference/8.19/autoscaling-get-autoscaling-capacity.html>`_

:param name: the name of the autoscaling policy
:param master_timeout: Period to wait for a connection to the master node. If
Expand Down Expand Up @@ -206,7 +206,7 @@ async def put_autoscaling_policy(
<p>NOTE: This feature is designed for indirect use by Elasticsearch Service, Elastic Cloud Enterprise, and Elastic Cloud on Kubernetes. Direct use is not supported.</p>


`<https://www.elastic.co/guide/en/elasticsearch/reference/8.17/autoscaling-put-autoscaling-policy.html>`_
`<https://www.elastic.co/guide/en/elasticsearch/reference/8.19/autoscaling-put-autoscaling-policy.html>`_

:param name: the name of the autoscaling policy
:param policy:
Expand Down
Loading