@@ -1468,7 +1468,7 @@ async def delete_by_query(
14681468 If the request can target data streams, this argument determines whether
14691469 wildcard expressions match hidden data streams. It supports comma-separated
14701470 values, such as `open,hidden`.
1471- :param from_: Starting offset (default: 0)
1471+ :param from_: Skips the specified number of documents.
14721472 :param ignore_unavailable: If `false`, the request returns an error if it targets
14731473 a missing or closed index.
14741474 :param lenient: If `true`, format-based query failures (such as providing text
@@ -3307,7 +3307,8 @@ async def msearch(
33073307 computationally expensive named queries on a large number of hits may add
33083308 significant overhead.
33093309 :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)))`.
33113312 :param max_concurrent_shard_requests: Maximum number of concurrent shard requests
33123313 that each sub-search request executes per node.
33133314 :param pre_filter_shard_size: Defines a threshold that enforces a pre-filter
@@ -3635,6 +3636,7 @@ async def open_point_in_time(
36353636 human : t .Optional [bool ] = None ,
36363637 ignore_unavailable : t .Optional [bool ] = None ,
36373638 index_filter : t .Optional [t .Mapping [str , t .Any ]] = None ,
3639+ max_concurrent_shard_requests : t .Optional [int ] = None ,
36383640 preference : t .Optional [str ] = None ,
36393641 pretty : t .Optional [bool ] = None ,
36403642 routing : t .Optional [str ] = None ,
@@ -3690,6 +3692,8 @@ async def open_point_in_time(
36903692 a missing or closed index.
36913693 :param index_filter: Filter indices if the provided query rewrites to `match_none`
36923694 on every shard.
3695+ :param max_concurrent_shard_requests: Maximum number of concurrent shard requests
3696+ that each sub-search request executes per node.
36933697 :param preference: The node or shard the operation should be performed on. By
36943698 default, it is random.
36953699 :param routing: A custom value that is used to route operations to a specific
@@ -3717,6 +3721,8 @@ async def open_point_in_time(
37173721 __query ["human" ] = human
37183722 if ignore_unavailable is not None :
37193723 __query ["ignore_unavailable" ] = ignore_unavailable
3724+ if max_concurrent_shard_requests is not None :
3725+ __query ["max_concurrent_shard_requests" ] = max_concurrent_shard_requests
37203726 if preference is not None :
37213727 __query ["preference" ] = preference
37223728 if pretty is not None :
@@ -4257,7 +4263,7 @@ async def render_search_template(
42574263 human : t .Optional [bool ] = None ,
42584264 params : t .Optional [t .Mapping [str , t .Any ]] = None ,
42594265 pretty : t .Optional [bool ] = None ,
4260- source : t .Optional [str ] = None ,
4266+ source : t .Optional [t . Union [ str , t . Mapping [ str , t . Any ]] ] = None ,
42614267 body : t .Optional [t .Dict [str , t .Any ]] = None ,
42624268 ) -> ObjectApiResponse [t .Any ]:
42634269 """
@@ -5661,7 +5667,7 @@ async def search_template(
56615667 search_type : t .Optional [
56625668 t .Union [str , t .Literal ["dfs_query_then_fetch" , "query_then_fetch" ]]
56635669 ] = None ,
5664- source : t .Optional [str ] = None ,
5670+ source : t .Optional [t . Union [ str , t . Mapping [ str , t . Any ]] ] = None ,
56655671 typed_keys : t .Optional [bool ] = None ,
56665672 body : t .Optional [t .Dict [str , t .Any ]] = None ,
56675673 ) -> ObjectApiResponse [t .Any ]:
@@ -6399,7 +6405,7 @@ async def update_by_query(
63996405 wildcard expressions match hidden data streams. It supports comma-separated
64006406 values, such as `open,hidden`. Valid values are: `all`, `open`, `closed`,
64016407 `hidden`, `none`.
6402- :param from_: Starting offset (default: 0)
6408+ :param from_: Skips the specified number of documents.
64036409 :param ignore_unavailable: If `false`, the request returns an error if it targets
64046410 a missing or closed index.
64056411 :param lenient: If `true`, format-based query failures (such as providing text
0 commit comments