Auto-generated code for main (#3394)

elasticmachine · miguelgrinberg · web-flow · commit 676ff30fe72a · 2026-04-20T10:46:03.000+01:00
* Auto-generated API code

* add missing imports

---------

Co-authored-by: Miguel Grinberg &lt;miguel.grinberg@gmail.com&gt;
diff --git a/elasticsearch/_async/client/security.py b/elasticsearch/_async/client/security.py
@@ -20,7 +20,13 @@
 from elastic_transport import ObjectApiResponse
 
 from ._base import NamespacedClient
-from .utils import SKIP_IN_PATH, _quote, _rewrite_parameters
+from .utils import (
+    SKIP_IN_PATH,
+    Stability,
+    _availability_warning,
+    _quote,
+    _rewrite_parameters,
+)
 
 
 class SecurityClient(NamespacedClient):
@@ -682,6 +688,89 @@ async def clear_cached_service_tokens(
             path_parts=__path_parts,
         )
 
+    @_rewrite_parameters(
+        body_fields=("api_key", "expiration", "metadata", "name"),
+        ignore_deprecated_options={"api_key"},
+    )
+    @_availability_warning(Stability.EXPERIMENTAL)
+    async def clone_api_key(
+        self,
+        *,
+        api_key: t.Optional[str] = None,
+        error_trace: t.Optional[bool] = None,
+        expiration: t.Optional[t.Union[str, t.Literal[-1], t.Literal[0]]] = None,
+        filter_path: t.Optional[t.Union[str, t.Sequence[str]]] = None,
+        human: t.Optional[bool] = None,
+        metadata: t.Optional[t.Mapping[str, t.Any]] = None,
+        name: t.Optional[str] = None,
+        pretty: t.Optional[bool] = None,
+        refresh: t.Optional[
+            t.Union[bool, str, t.Literal["false", "true", "wait_for"]]
+        ] = None,
+        body: t.Optional[t.Dict[str, t.Any]] = None,
+    ) -> ObjectApiResponse[t.Any]:
+        """
+        .. raw:: html
+
+          <p>Clone an API key.</p>
+          <p>Create a copy of an existing API key with a new ID.
+          The cloned key inherits the role descriptors of the source key.
+          This is intended for applications (such as Kibana) that need to
+          create API keys on behalf of a user using an existing API key credential,
+          since derived API keys (API keys created by API keys) are not otherwise supported.</p>
+
+
+        `<https://www.elastic.co/docs/api/doc/elasticsearch#TODO>`_
+
+        :param api_key: The credentials of the API key to clone. This is the secret value
+            returned when the key was originally created.
+        :param expiration: The expiration time for the cloned API key. By default, API
+            keys never expire. Set to `null` to explicitly create a key with no expiration.
+        :param metadata: Arbitrary metadata to associate with the cloned API key. It
+            supports nested data structure. Within the metadata object, keys beginning
+            with `_` are reserved for system usage.
+        :param name: A name for the cloned API key. If not provided, the name of the
+            source key is used.
+        :param refresh: If `true` (the default) then refresh the affected shards to make
+            this operation visible to search, if `wait_for` then wait for a refresh to
+            make this operation visible to search, if `false` then do nothing with refreshes.
+        """
+        if api_key is None and body is None:
+            raise ValueError("Empty value passed for parameter 'api_key'")
+        __path_parts: t.Dict[str, str] = {}
+        __path = "/_security/api_key/clone"
+        __query: t.Dict[str, t.Any] = {}
+        __body: t.Dict[str, t.Any] = body if body is not None else {}
+        if error_trace is not None:
+            __query["error_trace"] = error_trace
+        if filter_path is not None:
+            __query["filter_path"] = filter_path
+        if human is not None:
+            __query["human"] = human
+        if pretty is not None:
+            __query["pretty"] = pretty
+        if refresh is not None:
+            __query["refresh"] = refresh
+        if not __body:
+            if api_key is not None:
+                __body["api_key"] = api_key
+            if expiration is not None:
+                __body["expiration"] = expiration
+            if metadata is not None:
+                __body["metadata"] = metadata
+            if name is not None:
+                __body["name"] = name
+        __headers = {"accept": "application/json", "content-type": "application/json"}
+        return await self.perform_request(  # type: ignore[return-value]
+            "PUT",
+            __path,
+            params=__query,
+            headers=__headers,
+            body=__body,
+            endpoint_id="security.clone_api_key",
+            path_parts=__path_parts,
+        )
+
     @_rewrite_parameters(
         body_fields=("expiration", "metadata", "name", "role_descriptors"),
     )
diff --git a/elasticsearch/_async/client/tasks.py b/elasticsearch/_async/client/tasks.py
@@ -113,6 +113,7 @@ async def get(
         task_id: str,
         error_trace: t.Optional[bool] = None,
         filter_path: t.Optional[t.Union[str, t.Sequence[str]]] = None,
+        follow_relocations: t.Optional[bool] = None,
         human: t.Optional[bool] = None,
         pretty: t.Optional[bool] = None,
         timeout: t.Optional[t.Union[str, t.Literal[-1], t.Literal[0]]] = None,
@@ -131,6 +132,7 @@ async def get(
         `<https://www.elastic.co/docs/api/doc/elasticsearch/group/endpoint-tasks>`_
 
         :param task_id: The task identifier.
+        :param follow_relocations: Internal use only
         :param timeout: The period to wait for a response. If no response is received
             before the timeout expires, the request fails and returns an error.
         :param wait_for_completion: If `true`, the request blocks until the task has
@@ -145,6 +147,8 @@ async def get(
             __query["error_trace"] = error_trace
         if filter_path is not None:
             __query["filter_path"] = filter_path
+        if follow_relocations is not None:
+            __query["follow_relocations"] = follow_relocations
         if human is not None:
             __query["human"] = human
         if pretty is not None:
diff --git a/elasticsearch/_async/client/transform.py b/elasticsearch/_async/client/transform.py
@@ -592,6 +592,7 @@ async def schedule_now_transform(
         self,
         *,
         transform_id: str,
+        defer: t.Optional[bool] = None,
         error_trace: t.Optional[bool] = None,
         filter_path: t.Optional[t.Union[str, t.Sequence[str]]] = None,
         human: t.Optional[bool] = None,
@@ -612,13 +613,18 @@ async def schedule_now_transform(
         `<https://www.elastic.co/docs/api/doc/elasticsearch/operation/operation-transform-schedule-now-transform>`_
 
         :param transform_id: Identifier for the transform.
+        :param defer: When true, defers the scheduling by the transform's configured
+            sync delay instead of triggering immediately. The transform will process
+            new data after the delay elapses rather than right away.
         :param timeout: Controls the time to wait for the scheduling to take place
         """
         if transform_id in SKIP_IN_PATH:
             raise ValueError("Empty value passed for parameter 'transform_id'")
         __path_parts: t.Dict[str, str] = {"transform_id": _quote(transform_id)}
         __path = f'/_transform/{__path_parts["transform_id"]}/_schedule_now'
         __query: t.Dict[str, t.Any] = {}
+        if defer is not None:
+            __query["defer"] = defer
         if error_trace is not None:
             __query["error_trace"] = error_trace
         if filter_path is not None:
diff --git a/elasticsearch/_sync/client/security.py b/elasticsearch/_sync/client/security.py
@@ -20,7 +20,13 @@
 from elastic_transport import ObjectApiResponse
 
 from ._base import NamespacedClient
-from .utils import SKIP_IN_PATH, _quote, _rewrite_parameters
+from .utils import (
+    SKIP_IN_PATH,
+    Stability,
+    _availability_warning,
+    _quote,
+    _rewrite_parameters,
+)
 
 
 class SecurityClient(NamespacedClient):
@@ -682,6 +688,89 @@ def clear_cached_service_tokens(
             path_parts=__path_parts,
         )
 
+    @_rewrite_parameters(
+        body_fields=("api_key", "expiration", "metadata", "name"),
+        ignore_deprecated_options={"api_key"},
+    )
+    @_availability_warning(Stability.EXPERIMENTAL)
+    def clone_api_key(
+        self,
+        *,
+        api_key: t.Optional[str] = None,
+        error_trace: t.Optional[bool] = None,
+        expiration: t.Optional[t.Union[str, t.Literal[-1], t.Literal[0]]] = None,
+        filter_path: t.Optional[t.Union[str, t.Sequence[str]]] = None,
+        human: t.Optional[bool] = None,
+        metadata: t.Optional[t.Mapping[str, t.Any]] = None,
+        name: t.Optional[str] = None,
+        pretty: t.Optional[bool] = None,
+        refresh: t.Optional[
+            t.Union[bool, str, t.Literal["false", "true", "wait_for"]]
+        ] = None,
+        body: t.Optional[t.Dict[str, t.Any]] = None,
+    ) -> ObjectApiResponse[t.Any]:
+        """
+        .. raw:: html
+
+          <p>Clone an API key.</p>
+          <p>Create a copy of an existing API key with a new ID.
+          The cloned key inherits the role descriptors of the source key.
+          This is intended for applications (such as Kibana) that need to
+          create API keys on behalf of a user using an existing API key credential,
+          since derived API keys (API keys created by API keys) are not otherwise supported.</p>
+
+
+        `<https://www.elastic.co/docs/api/doc/elasticsearch#TODO>`_
+
+        :param api_key: The credentials of the API key to clone. This is the secret value
+            returned when the key was originally created.
+        :param expiration: The expiration time for the cloned API key. By default, API
+            keys never expire. Set to `null` to explicitly create a key with no expiration.
+        :param metadata: Arbitrary metadata to associate with the cloned API key. It
+            supports nested data structure. Within the metadata object, keys beginning
+            with `_` are reserved for system usage.
+        :param name: A name for the cloned API key. If not provided, the name of the
+            source key is used.
+        :param refresh: If `true` (the default) then refresh the affected shards to make
+            this operation visible to search, if `wait_for` then wait for a refresh to
+            make this operation visible to search, if `false` then do nothing with refreshes.
+        """
+        if api_key is None and body is None:
+            raise ValueError("Empty value passed for parameter 'api_key'")
+        __path_parts: t.Dict[str, str] = {}
+        __path = "/_security/api_key/clone"
+        __query: t.Dict[str, t.Any] = {}
+        __body: t.Dict[str, t.Any] = body if body is not None else {}
+        if error_trace is not None:
+            __query["error_trace"] = error_trace
+        if filter_path is not None:
+            __query["filter_path"] = filter_path
+        if human is not None:
+            __query["human"] = human
+        if pretty is not None:
+            __query["pretty"] = pretty
+        if refresh is not None:
+            __query["refresh"] = refresh
+        if not __body:
+            if api_key is not None:
+                __body["api_key"] = api_key
+            if expiration is not None:
+                __body["expiration"] = expiration
+            if metadata is not None:
+                __body["metadata"] = metadata
+            if name is not None:
+                __body["name"] = name
+        __headers = {"accept": "application/json", "content-type": "application/json"}
+        return self.perform_request(  # type: ignore[return-value]
+            "PUT",
+            __path,
+            params=__query,
+            headers=__headers,
+            body=__body,
+            endpoint_id="security.clone_api_key",
+            path_parts=__path_parts,
+        )
+
     @_rewrite_parameters(
         body_fields=("expiration", "metadata", "name", "role_descriptors"),
     )
diff --git a/elasticsearch/_sync/client/tasks.py b/elasticsearch/_sync/client/tasks.py
@@ -113,6 +113,7 @@ def get(
         task_id: str,
         error_trace: t.Optional[bool] = None,
         filter_path: t.Optional[t.Union[str, t.Sequence[str]]] = None,
+        follow_relocations: t.Optional[bool] = None,
         human: t.Optional[bool] = None,
         pretty: t.Optional[bool] = None,
         timeout: t.Optional[t.Union[str, t.Literal[-1], t.Literal[0]]] = None,
@@ -131,6 +132,7 @@ def get(
         `<https://www.elastic.co/docs/api/doc/elasticsearch/group/endpoint-tasks>`_
 
         :param task_id: The task identifier.
+        :param follow_relocations: Internal use only
         :param timeout: The period to wait for a response. If no response is received
             before the timeout expires, the request fails and returns an error.
         :param wait_for_completion: If `true`, the request blocks until the task has
@@ -145,6 +147,8 @@ def get(
             __query["error_trace"] = error_trace
         if filter_path is not None:
             __query["filter_path"] = filter_path
+        if follow_relocations is not None:
+            __query["follow_relocations"] = follow_relocations
         if human is not None:
             __query["human"] = human
         if pretty is not None:
diff --git a/elasticsearch/_sync/client/transform.py b/elasticsearch/_sync/client/transform.py
@@ -592,6 +592,7 @@ def schedule_now_transform(
         self,
         *,
         transform_id: str,
+        defer: t.Optional[bool] = None,
         error_trace: t.Optional[bool] = None,
         filter_path: t.Optional[t.Union[str, t.Sequence[str]]] = None,
         human: t.Optional[bool] = None,
@@ -612,13 +613,18 @@ def schedule_now_transform(
         `<https://www.elastic.co/docs/api/doc/elasticsearch/operation/operation-transform-schedule-now-transform>`_
 
         :param transform_id: Identifier for the transform.
+        :param defer: When true, defers the scheduling by the transform's configured
+            sync delay instead of triggering immediately. The transform will process
+            new data after the delay elapses rather than right away.
         :param timeout: Controls the time to wait for the scheduling to take place
         """
         if transform_id in SKIP_IN_PATH:
             raise ValueError("Empty value passed for parameter 'transform_id'")
         __path_parts: t.Dict[str, str] = {"transform_id": _quote(transform_id)}
         __path = f'/_transform/{__path_parts["transform_id"]}/_schedule_now'
         __query: t.Dict[str, t.Any] = {}
+        if defer is not None:
+            __query["defer"] = defer
         if error_trace is not None:
             __query["error_trace"] = error_trace
         if filter_path is not None:
diff --git a/elasticsearch/_version.py b/elasticsearch/_version.py
@@ -16,5 +16,5 @@
 #  under the License.
 
 __versionstr__ = "9.4.0"
-__es_specification_commit__ = "c376fd6d01cd8d60c6ce229ca4822624de4563fd"
+__es_specification_commit__ = "fae5541d686e2e66291c999773f4140bdfd936e9"
 _SERVERLESS_API_VERSION = "2023-10-31"
