@@ -1468,7 +1468,7 @@ async def delete_by_query(
1468
1468
If the request can target data streams, this argument determines whether
1469
1469
wildcard expressions match hidden data streams. It supports comma-separated
1470
1470
values, such as `open,hidden`.
1471
- :param from_: Starting offset (default: 0)
1471
+ :param from_: Skips the specified number of documents.
1472
1472
:param ignore_unavailable: If `false`, the request returns an error if it targets
1473
1473
a missing or closed index.
1474
1474
:param lenient: If `true`, format-based query failures (such as providing text
@@ -3307,7 +3307,8 @@ async def msearch(
3307
3307
computationally expensive named queries on a large number of hits may add
3308
3308
significant overhead.
3309
3309
:param max_concurrent_searches: Maximum number of concurrent searches the multi
3310
- search API can execute.
3310
+ search API can execute. Defaults to `max(1, (# of data nodes * min(search
3311
+ thread pool size, 10)))`.
3311
3312
:param max_concurrent_shard_requests: Maximum number of concurrent shard requests
3312
3313
that each sub-search request executes per node.
3313
3314
:param pre_filter_shard_size: Defines a threshold that enforces a pre-filter
@@ -3635,6 +3636,7 @@ async def open_point_in_time(
3635
3636
human : t .Optional [bool ] = None ,
3636
3637
ignore_unavailable : t .Optional [bool ] = None ,
3637
3638
index_filter : t .Optional [t .Mapping [str , t .Any ]] = None ,
3639
+ max_concurrent_shard_requests : t .Optional [int ] = None ,
3638
3640
preference : t .Optional [str ] = None ,
3639
3641
pretty : t .Optional [bool ] = None ,
3640
3642
routing : t .Optional [str ] = None ,
@@ -3690,6 +3692,8 @@ async def open_point_in_time(
3690
3692
a missing or closed index.
3691
3693
:param index_filter: Filter indices if the provided query rewrites to `match_none`
3692
3694
on every shard.
3695
+ :param max_concurrent_shard_requests: Maximum number of concurrent shard requests
3696
+ that each sub-search request executes per node.
3693
3697
:param preference: The node or shard the operation should be performed on. By
3694
3698
default, it is random.
3695
3699
:param routing: A custom value that is used to route operations to a specific
@@ -3717,6 +3721,8 @@ async def open_point_in_time(
3717
3721
__query ["human" ] = human
3718
3722
if ignore_unavailable is not None :
3719
3723
__query ["ignore_unavailable" ] = ignore_unavailable
3724
+ if max_concurrent_shard_requests is not None :
3725
+ __query ["max_concurrent_shard_requests" ] = max_concurrent_shard_requests
3720
3726
if preference is not None :
3721
3727
__query ["preference" ] = preference
3722
3728
if pretty is not None :
@@ -4257,7 +4263,7 @@ async def render_search_template(
4257
4263
human : t .Optional [bool ] = None ,
4258
4264
params : t .Optional [t .Mapping [str , t .Any ]] = None ,
4259
4265
pretty : t .Optional [bool ] = None ,
4260
- source : t .Optional [str ] = None ,
4266
+ source : t .Optional [t . Union [ str , t . Mapping [ str , t . Any ]] ] = None ,
4261
4267
body : t .Optional [t .Dict [str , t .Any ]] = None ,
4262
4268
) -> ObjectApiResponse [t .Any ]:
4263
4269
"""
@@ -5661,7 +5667,7 @@ async def search_template(
5661
5667
search_type : t .Optional [
5662
5668
t .Union [str , t .Literal ["dfs_query_then_fetch" , "query_then_fetch" ]]
5663
5669
] = None ,
5664
- source : t .Optional [str ] = None ,
5670
+ source : t .Optional [t . Union [ str , t . Mapping [ str , t . Any ]] ] = None ,
5665
5671
typed_keys : t .Optional [bool ] = None ,
5666
5672
body : t .Optional [t .Dict [str , t .Any ]] = None ,
5667
5673
) -> ObjectApiResponse [t .Any ]:
@@ -6399,7 +6405,7 @@ async def update_by_query(
6399
6405
wildcard expressions match hidden data streams. It supports comma-separated
6400
6406
values, such as `open,hidden`. Valid values are: `all`, `open`, `closed`,
6401
6407
`hidden`, `none`.
6402
- :param from_: Starting offset (default: 0)
6408
+ :param from_: Skips the specified number of documents.
6403
6409
:param ignore_unavailable: If `false`, the request returns an error if it targets
6404
6410
a missing or closed index.
6405
6411
:param lenient: If `true`, format-based query failures (such as providing text
0 commit comments