@@ -1581,7 +1581,7 @@ async def delete_by_query(
15811581 If the request can target data streams, this argument determines whether
15821582 wildcard expressions match hidden data streams. It supports comma-separated
15831583 values, such as `open,hidden`.
1584- :param from_: Starting offset (default: 0)
1584+ :param from_: Skips the specified number of documents.
15851585 :param ignore_unavailable: If `false`, the request returns an error if it targets
15861586 a missing or closed index.
15871587 :param lenient: If `true`, format-based query failures (such as providing text
@@ -3420,7 +3420,8 @@ async def msearch(
34203420 computationally expensive named queries on a large number of hits may add
34213421 significant overhead.
34223422 :param max_concurrent_searches: Maximum number of concurrent searches the multi
3423- search API can execute.
3423+ search API can execute. Defaults to `max(1, (# of data nodes * min(search
3424+ thread pool size, 10)))`.
34243425 :param max_concurrent_shard_requests: Maximum number of concurrent shard requests
34253426 that each sub-search request executes per node.
34263427 :param pre_filter_shard_size: Defines a threshold that enforces a pre-filter
@@ -3748,6 +3749,7 @@ async def open_point_in_time(
37483749 human : t .Optional [bool ] = None ,
37493750 ignore_unavailable : t .Optional [bool ] = None ,
37503751 index_filter : t .Optional [t .Mapping [str , t .Any ]] = None ,
3752+ max_concurrent_shard_requests : t .Optional [int ] = None ,
37513753 preference : t .Optional [str ] = None ,
37523754 pretty : t .Optional [bool ] = None ,
37533755 routing : t .Optional [str ] = None ,
@@ -3803,6 +3805,8 @@ async def open_point_in_time(
38033805 a missing or closed index.
38043806 :param index_filter: Filter indices if the provided query rewrites to `match_none`
38053807 on every shard.
3808+ :param max_concurrent_shard_requests: Maximum number of concurrent shard requests
3809+ that each sub-search request executes per node.
38063810 :param preference: The node or shard the operation should be performed on. By
38073811 default, it is random.
38083812 :param routing: A custom value that is used to route operations to a specific
@@ -3830,6 +3834,8 @@ async def open_point_in_time(
38303834 __query ["human" ] = human
38313835 if ignore_unavailable is not None :
38323836 __query ["ignore_unavailable" ] = ignore_unavailable
3837+ if max_concurrent_shard_requests is not None :
3838+ __query ["max_concurrent_shard_requests" ] = max_concurrent_shard_requests
38333839 if preference is not None :
38343840 __query ["preference" ] = preference
38353841 if pretty is not None :
@@ -4370,7 +4376,7 @@ async def render_search_template(
43704376 human : t .Optional [bool ] = None ,
43714377 params : t .Optional [t .Mapping [str , t .Any ]] = None ,
43724378 pretty : t .Optional [bool ] = None ,
4373- source : t .Optional [str ] = None ,
4379+ source : t .Optional [t . Union [ str , t . Mapping [ str , t . Any ]] ] = None ,
43744380 body : t .Optional [t .Dict [str , t .Any ]] = None ,
43754381 ) -> ObjectApiResponse [t .Any ]:
43764382 """
@@ -5774,7 +5780,7 @@ async def search_template(
57745780 search_type : t .Optional [
57755781 t .Union [str , t .Literal ["dfs_query_then_fetch" , "query_then_fetch" ]]
57765782 ] = None ,
5777- source : t .Optional [str ] = None ,
5783+ source : t .Optional [t . Union [ str , t . Mapping [ str , t . Any ]] ] = None ,
57785784 typed_keys : t .Optional [bool ] = None ,
57795785 body : t .Optional [t .Dict [str , t .Any ]] = None ,
57805786 ) -> ObjectApiResponse [t .Any ]:
@@ -6512,7 +6518,7 @@ async def update_by_query(
65126518 wildcard expressions match hidden data streams. It supports comma-separated
65136519 values, such as `open,hidden`. Valid values are: `all`, `open`, `closed`,
65146520 `hidden`, `none`.
6515- :param from_: Starting offset (default: 0)
6521+ :param from_: Skips the specified number of documents.
65166522 :param ignore_unavailable: If `false`, the request returns an error if it targets
65176523 a missing or closed index.
65186524 :param lenient: If `true`, format-based query failures (such as providing text
0 commit comments