diff --git a/elasticsearch/_async/client/esql.py b/elasticsearch/_async/client/esql.py index 23e858e35..c2e5fff2c 100644 --- a/elasticsearch/_async/client/esql.py +++ b/elasticsearch/_async/client/esql.py @@ -38,7 +38,14 @@ async def query( error_trace: t.Optional[bool] = None, filter: t.Optional[t.Mapping[str, t.Any]] = None, filter_path: t.Optional[t.Union[str, t.Sequence[str]]] = None, - format: t.Optional[str] = None, + format: t.Optional[ + t.Union[ + str, + t.Literal[ + "arrow", "cbor", "csv", "json", "smile", "tsv", "txt", "yaml" + ], + ] + ] = None, human: t.Optional[bool] = None, locale: t.Optional[str] = None, params: t.Optional[t.Sequence[t.Union[None, bool, float, int, str]]] = None, diff --git a/elasticsearch/_async/client/ilm.py b/elasticsearch/_async/client/ilm.py index 1c10912c9..b9519579d 100644 --- a/elasticsearch/_async/client/ilm.py +++ b/elasticsearch/_async/client/ilm.py @@ -304,10 +304,10 @@ async def move_to_step( *, index: str, current_step: t.Optional[t.Mapping[str, t.Any]] = None, + next_step: t.Optional[t.Mapping[str, t.Any]] = None, error_trace: t.Optional[bool] = None, filter_path: t.Optional[t.Union[str, t.Sequence[str]]] = None, human: t.Optional[bool] = None, - next_step: t.Optional[t.Mapping[str, t.Any]] = None, pretty: t.Optional[bool] = None, body: t.Optional[t.Dict[str, t.Any]] = None, ) -> ObjectApiResponse[t.Any]: @@ -322,6 +322,10 @@ async def move_to_step( """ if index in SKIP_IN_PATH: raise ValueError("Empty value passed for parameter 'index'") + if current_step is None and body is None: + raise ValueError("Empty value passed for parameter 'current_step'") + if next_step is None and body is None: + raise ValueError("Empty value passed for parameter 'next_step'") __path_parts: t.Dict[str, str] = {"index": _quote(index)} __path = f'/_ilm/move/{__path_parts["index"]}' __query: t.Dict[str, t.Any] = {} diff --git a/elasticsearch/_async/client/ingest.py b/elasticsearch/_async/client/ingest.py index 4b81b435d..431bb2348 100644 --- a/elasticsearch/_async/client/ingest.py +++ b/elasticsearch/_async/client/ingest.py @@ -40,7 +40,7 @@ async def delete_geoip_database( """ Deletes a geoip database configuration. - ``_ + ``_ :param id: A comma-separated list of geoip database configurations to delete :param master_timeout: Period to wait for a connection to the master node. If @@ -177,7 +177,7 @@ async def get_geoip_database( """ Returns information about one or more geoip database configurations. - ``_ + ``_ :param id: Comma-separated list of database configuration IDs to retrieve. Wildcard (`*`) expressions are supported. To get all database configurations, omit @@ -327,7 +327,7 @@ async def put_geoip_database( """ Returns information about one or more geoip database configurations. - ``_ + ``_ :param id: ID of the database configuration to create or update. :param maxmind: The configuration necessary to identify which IP geolocation diff --git a/elasticsearch/_sync/client/esql.py b/elasticsearch/_sync/client/esql.py index 38e5c6950..9b66b2fc0 100644 --- a/elasticsearch/_sync/client/esql.py +++ b/elasticsearch/_sync/client/esql.py @@ -38,7 +38,14 @@ def query( error_trace: t.Optional[bool] = None, filter: t.Optional[t.Mapping[str, t.Any]] = None, filter_path: t.Optional[t.Union[str, t.Sequence[str]]] = None, - format: t.Optional[str] = None, + format: t.Optional[ + t.Union[ + str, + t.Literal[ + "arrow", "cbor", "csv", "json", "smile", "tsv", "txt", "yaml" + ], + ] + ] = None, human: t.Optional[bool] = None, locale: t.Optional[str] = None, params: t.Optional[t.Sequence[t.Union[None, bool, float, int, str]]] = None, diff --git a/elasticsearch/_sync/client/ilm.py b/elasticsearch/_sync/client/ilm.py index 028d847b9..abaa57031 100644 --- a/elasticsearch/_sync/client/ilm.py +++ b/elasticsearch/_sync/client/ilm.py @@ -304,10 +304,10 @@ def move_to_step( *, index: str, current_step: t.Optional[t.Mapping[str, t.Any]] = None, + next_step: t.Optional[t.Mapping[str, t.Any]] = None, error_trace: t.Optional[bool] = None, filter_path: t.Optional[t.Union[str, t.Sequence[str]]] = None, human: t.Optional[bool] = None, - next_step: t.Optional[t.Mapping[str, t.Any]] = None, pretty: t.Optional[bool] = None, body: t.Optional[t.Dict[str, t.Any]] = None, ) -> ObjectApiResponse[t.Any]: @@ -322,6 +322,10 @@ def move_to_step( """ if index in SKIP_IN_PATH: raise ValueError("Empty value passed for parameter 'index'") + if current_step is None and body is None: + raise ValueError("Empty value passed for parameter 'current_step'") + if next_step is None and body is None: + raise ValueError("Empty value passed for parameter 'next_step'") __path_parts: t.Dict[str, str] = {"index": _quote(index)} __path = f'/_ilm/move/{__path_parts["index"]}' __query: t.Dict[str, t.Any] = {} diff --git a/elasticsearch/_sync/client/ingest.py b/elasticsearch/_sync/client/ingest.py index 317aff910..0d50dbb83 100644 --- a/elasticsearch/_sync/client/ingest.py +++ b/elasticsearch/_sync/client/ingest.py @@ -40,7 +40,7 @@ def delete_geoip_database( """ Deletes a geoip database configuration. - ``_ + ``_ :param id: A comma-separated list of geoip database configurations to delete :param master_timeout: Period to wait for a connection to the master node. If @@ -177,7 +177,7 @@ def get_geoip_database( """ Returns information about one or more geoip database configurations. - ``_ + ``_ :param id: Comma-separated list of database configuration IDs to retrieve. Wildcard (`*`) expressions are supported. To get all database configurations, omit @@ -327,7 +327,7 @@ def put_geoip_database( """ Returns information about one or more geoip database configurations. - ``_ + ``_ :param id: ID of the database configuration to create or update. :param maxmind: The configuration necessary to identify which IP geolocation