Auto-generated code for 9.2 (#3326)

* Auto-generated API code

* remove streams

---------

Co-authored-by: Miguel Grinberg <miguel.grinberg@gmail.com>

Author: elasticmachine

docs/sphinx/api/streams.rst

@@ -51,7 +51,6 @@ arguments are required for all calls.
    api/snapshots
    api/snapshottable-features
    api/sql
-   api/streams
    api/synonyms
    api/tls-ssl
    api/tasks

docs/sphinx/es_api.rst

@@ -75,7 +75,6 @@
 from .snapshot import SnapshotClient
 from .sql import SqlClient
 from .ssl import SslClient
-from .streams import StreamsClient
 from .synonyms import SynonymsClient
 from .tasks import TasksClient
 from .text_structure import TextStructureClient
@@ -381,7 +380,6 @@ def __init__(
         self.shutdown = ShutdownClient(self)
         self.sql = SqlClient(self)
         self.ssl = SslClient(self)
-        self.streams = StreamsClient(self)
         self.synonyms = SynonymsClient(self)
         self.text_structure = TextStructureClient(self)
         self.transform = TransformClient(self)

elasticsearch/_async/client/__init__.py

@@ -204,8 +204,10 @@ async def get(
 
         `<https://www.elastic.co/docs/api/doc/elasticsearch/operation/operation-inference-get>`_
 
-        :param task_type: The task type
-        :param inference_id: The inference Id
+        :param task_type: The task type of the endpoint to return
+        :param inference_id: The inference Id of the endpoint to return. Using `_all`
+            or `*` will return all endpoints with the specified `task_type` if one is
+            specified, or all endpoints for all task types if no `task_type` is specified
         """
         __path_parts: t.Dict[str, str]
         if task_type not in SKIP_IN_PATH and inference_id not in SKIP_IN_PATH:
@@ -214,6 +216,9 @@ async def get(
                 "inference_id": _quote(inference_id),
             }
             __path = f'/_inference/{__path_parts["task_type"]}/{__path_parts["inference_id"]}'
+        elif task_type not in SKIP_IN_PATH:
+            __path_parts = {"task_type": _quote(task_type)}
+            __path = f'/_inference/{__path_parts["task_type"]}/_all'
         elif inference_id not in SKIP_IN_PATH:
             __path_parts = {"inference_id": _quote(inference_id)}
             __path = f'/_inference/{__path_parts["inference_id"]}'

elasticsearch/_async/client/inference.py

@@ -75,7 +75,6 @@
 from .snapshot import SnapshotClient
 from .sql import SqlClient
 from .ssl import SslClient
-from .streams import StreamsClient
 from .synonyms import SynonymsClient
 from .tasks import TasksClient
 from .text_structure import TextStructureClient
@@ -381,7 +380,6 @@ def __init__(
         self.shutdown = ShutdownClient(self)
         self.sql = SqlClient(self)
         self.ssl = SslClient(self)
-        self.streams = StreamsClient(self)
         self.synonyms = SynonymsClient(self)
         self.text_structure = TextStructureClient(self)
         self.transform = TransformClient(self)

elasticsearch/_async/client/streams.py

@@ -204,8 +204,10 @@ def get(
 
         `<https://www.elastic.co/docs/api/doc/elasticsearch/operation/operation-inference-get>`_
 
-        :param task_type: The task type
-        :param inference_id: The inference Id
+        :param task_type: The task type of the endpoint to return
+        :param inference_id: The inference Id of the endpoint to return. Using `_all`
+            or `*` will return all endpoints with the specified `task_type` if one is
+            specified, or all endpoints for all task types if no `task_type` is specified
         """
         __path_parts: t.Dict[str, str]
         if task_type not in SKIP_IN_PATH and inference_id not in SKIP_IN_PATH:
@@ -214,6 +216,9 @@ def get(
                 "inference_id": _quote(inference_id),
             }
             __path = f'/_inference/{__path_parts["task_type"]}/{__path_parts["inference_id"]}'
+        elif task_type not in SKIP_IN_PATH:
+            __path_parts = {"task_type": _quote(task_type)}
+            __path = f'/_inference/{__path_parts["task_type"]}/_all'
         elif inference_id not in SKIP_IN_PATH:
             __path_parts = {"inference_id": _quote(inference_id)}
             __path = f'/_inference/{__path_parts["inference_id"]}'

elasticsearch/_sync/client/__init__.py

@@ -16,4 +16,4 @@
 #  under the License.
 
 __versionstr__ = "9.2.1"
-__es_specification_commit__ = "2d0d012abee4769e1b8606ef92a65f7ed5b4303f"
+__es_specification_commit__ = "a3b1c72f0409bc84a2397e6382d6c25b9b0f13d4"

elasticsearch/_sync/client/inference.py

@@ -63,7 +63,6 @@
 from ._sync.client.snapshot import SnapshotClient as SnapshotClient  # noqa: F401
 from ._sync.client.sql import SqlClient as SqlClient  # noqa: F401
 from ._sync.client.ssl import SslClient as SslClient  # noqa: F401
-from ._sync.client.streams import StreamsClient as StreamsClient  # noqa: F401
 from ._sync.client.synonyms import SynonymsClient as SynonymsClient  # noqa: F401
 from ._sync.client.tasks import TasksClient as TasksClient  # noqa: F401
 from ._sync.client.text_structure import (  # noqa: F401
@@ -118,7 +117,6 @@
     "SnapshotClient",
     "SqlClient",
     "SslClient",
-    "StreamsClient",
     "TasksClient",
     "TextStructureClient",
     "TransformClient",

elasticsearch/_version.py

@@ -2676,23 +2676,30 @@ def __init__(
 
 class MultiTermLookup(AttrDict[Any]):
     """
-    :arg field: (required) A fields from which to retrieve terms.
+    :arg field: A field from which to retrieve terms. It is required if
+        `script` is not provided.
+    :arg script: A script to calculate terms to aggregate on. It is
+        required if `field` is not provided.
     :arg missing: The value to apply to documents that do not have a
         value. By default, documents without a value are ignored.
     """
 
     field: Union[str, InstrumentedField, DefaultType]
+    script: Union["Script", Dict[str, Any], DefaultType]
     missing: Union[str, int, float, bool, DefaultType]
 
     def __init__(
         self,
         *,
         field: Union[str, InstrumentedField, DefaultType] = DEFAULT,
+        script: Union["Script", Dict[str, Any], DefaultType] = DEFAULT,
         missing: Union[str, int, float, bool, DefaultType] = DEFAULT,
         **kwargs: Any,
     ):
         if field is not DEFAULT:
             kwargs["field"] = str(field)
+        if script is not DEFAULT:
+            kwargs["script"] = script
         if missing is not DEFAULT:
             kwargs["missing"] = missing
         super().__init__(kwargs)