@@ -2652,7 +2652,6 @@ async def get_source(
2652
2652
source : t .Optional [t .Union [bool , t .Union [str , t .Sequence [str ]]]] = None ,
2653
2653
source_excludes : t .Optional [t .Union [str , t .Sequence [str ]]] = None ,
2654
2654
source_includes : t .Optional [t .Union [str , t .Sequence [str ]]] = None ,
2655
- stored_fields : t .Optional [t .Union [str , t .Sequence [str ]]] = None ,
2656
2655
version : t .Optional [int ] = None ,
2657
2656
version_type : t .Optional [
2658
2657
t .Union [str , t .Literal ["external" , "external_gte" , "force" , "internal" ]]
@@ -2689,8 +2688,6 @@ async def get_source(
2689
2688
the response.
2690
2689
:param source_includes: A comma-separated list of source fields to include in
2691
2690
the response.
2692
- :param stored_fields: A comma-separated list of stored fields to return as part
2693
- of a hit.
2694
2691
:param version: The version number for concurrency control. It must match the
2695
2692
current version of the document for the request to succeed.
2696
2693
:param version_type: The version type.
@@ -2724,8 +2721,6 @@ async def get_source(
2724
2721
__query ["_source_excludes" ] = source_excludes
2725
2722
if source_includes is not None :
2726
2723
__query ["_source_includes" ] = source_includes
2727
- if stored_fields is not None :
2728
- __query ["stored_fields" ] = stored_fields
2729
2724
if version is not None :
2730
2725
__query ["version" ] = version
2731
2726
if version_type is not None :
@@ -2834,6 +2829,7 @@ async def index(
2834
2829
t .Union [bool , str , t .Literal ["false" , "true" , "wait_for" ]]
2835
2830
] = None ,
2836
2831
require_alias : t .Optional [bool ] = None ,
2832
+ require_data_stream : t .Optional [bool ] = None ,
2837
2833
routing : t .Optional [str ] = None ,
2838
2834
timeout : t .Optional [t .Union [str , t .Literal [- 1 ], t .Literal [0 ]]] = None ,
2839
2835
version : t .Optional [int ] = None ,
@@ -2969,6 +2965,8 @@ async def index(
2969
2965
this operation visible to search. If `wait_for`, it waits for a refresh to
2970
2966
make this operation visible to search. If `false`, it does nothing with refreshes.
2971
2967
:param require_alias: If `true`, the destination must be an index alias.
2968
+ :param require_data_stream: If `true`, the request's actions must target a data
2969
+ stream (existing or to be created).
2972
2970
:param routing: A custom value that is used to route operations to a specific
2973
2971
shard.
2974
2972
:param timeout: The period the request waits for the following operations: automatic
@@ -3030,6 +3028,8 @@ async def index(
3030
3028
__query ["refresh" ] = refresh
3031
3029
if require_alias is not None :
3032
3030
__query ["require_alias" ] = require_alias
3031
+ if require_data_stream is not None :
3032
+ __query ["require_data_stream" ] = require_data_stream
3033
3033
if routing is not None :
3034
3034
__query ["routing" ] = routing
3035
3035
if timeout is not None :
@@ -3798,8 +3798,7 @@ async def open_point_in_time(
3798
3798
:param expand_wildcards: The type of index that wildcard patterns can match.
3799
3799
If the request can target data streams, this argument determines whether
3800
3800
wildcard expressions match hidden data streams. It supports comma-separated
3801
- values, such as `open,hidden`. Valid values are: `all`, `open`, `closed`,
3802
- `hidden`, `none`.
3801
+ values, such as `open,hidden`.
3803
3802
:param ignore_unavailable: If `false`, the request returns an error if it targets
3804
3803
a missing or closed index.
3805
3804
:param index_filter: Filter indices if the provided query rewrites to `match_none`
@@ -5695,7 +5694,7 @@ async def search_shards(
5695
5694
:param expand_wildcards: Type of index that wildcard patterns can match. If the
5696
5695
request can target data streams, this argument determines whether wildcard
5697
5696
expressions match hidden data streams. Supports comma-separated values, such
5698
- as `open,hidden`. Valid values are: `all`, `open`, `closed`, `hidden`, `none`.
5697
+ as `open,hidden`.
5699
5698
:param ignore_unavailable: If `false`, the request returns an error if it targets
5700
5699
a missing or closed index.
5701
5700
:param local: If `true`, the request retrieves information from the local node
@@ -5807,8 +5806,7 @@ async def search_template(
5807
5806
:param expand_wildcards: The type of index that wildcard patterns can match.
5808
5807
If the request can target data streams, this argument determines whether
5809
5808
wildcard expressions match hidden data streams. Supports comma-separated
5810
- values, such as `open,hidden`. Valid values are: `all`, `open`, `closed`,
5811
- `hidden`, `none`.
5809
+ values, such as `open,hidden`.
5812
5810
:param explain: If `true`, returns detailed information about score calculation
5813
5811
as part of each hit. If you specify both this and the `explain` query parameter,
5814
5812
the API uses only the query parameter.
@@ -6519,8 +6517,7 @@ async def update_by_query(
6519
6517
:param expand_wildcards: The type of index that wildcard patterns can match.
6520
6518
If the request can target data streams, this argument determines whether
6521
6519
wildcard expressions match hidden data streams. It supports comma-separated
6522
- values, such as `open,hidden`. Valid values are: `all`, `open`, `closed`,
6523
- `hidden`, `none`.
6520
+ values, such as `open,hidden`.
6524
6521
:param from_: Skips the specified number of documents.
6525
6522
:param ignore_unavailable: If `false`, the request returns an error if it targets
6526
6523
a missing or closed index.
0 commit comments