Update generated code to allow using body for required parameters

Author: pquentin

elasticsearch/_async/client/__init__.py

@@ -759,7 +759,7 @@ async def clear_scroll(
     async def close_point_in_time(
         self,
         *,
-        id: str,
+        id: t.Optional[str] = None,
         error_trace: t.Optional[bool] = None,
         filter_path: t.Optional[t.Union[str, t.Sequence[str]]] = None,
         human: t.Optional[bool] = None,
@@ -773,7 +773,7 @@ async def close_point_in_time(
 
         :param id: The ID of the point-in-time.
         """
-        if id is None:
+        if id is None and body is None:
             raise ValueError("Empty value passed for parameter 'id'")
         __path = "/_pit"
         __query: t.Dict[str, t.Any] = {}
@@ -1122,7 +1122,7 @@ async def delete(
     async def delete_by_query(
         self,
         *,
-        index: t.Union[str, t.Sequence[str]],
+        index: t.Optional[t.Union[str, t.Sequence[str]]] = None,
         allow_no_indices: t.Optional[bool] = None,
         analyze_wildcard: t.Optional[bool] = None,
         analyzer: t.Optional[str] = None,
@@ -1616,8 +1616,8 @@ async def exists_source(
     async def explain(
         self,
         *,
-        index: str,
-        id: str,
+        index: t.Optional[str] = None,
+        id: t.Optional[str] = None,
         analyze_wildcard: t.Optional[bool] = None,
         analyzer: t.Optional[str] = None,
         default_operator: t.Optional[t.Union["t.Literal['and', 'or']", str]] = None,
@@ -2322,8 +2322,8 @@ async def info(
     async def knn_search(
         self,
         *,
-        index: t.Union[str, t.Sequence[str]],
-        knn: t.Mapping[str, t.Any],
+        index: t.Optional[t.Union[str, t.Sequence[str]]] = None,
+        knn: t.Optional[t.Mapping[str, t.Any]] = None,
         docvalue_fields: t.Optional[t.Sequence[t.Mapping[str, t.Any]]] = None,
         error_trace: t.Optional[bool] = None,
         fields: t.Optional[t.Union[str, t.Sequence[str]]] = None,
@@ -2366,7 +2366,7 @@ async def knn_search(
         """
         if index in SKIP_IN_PATH:
             raise ValueError("Empty value passed for parameter 'index'")
-        if knn is None:
+        if knn is None and body is None:
             raise ValueError("Empty value passed for parameter 'knn'")
         __path = f"/{_quote(index)}/_knn_search"
         __query: t.Dict[str, t.Any] = {}
@@ -2887,8 +2887,8 @@ async def open_point_in_time(
     async def put_script(
         self,
         *,
-        id: str,
-        script: t.Mapping[str, t.Any],
+        id: t.Optional[str] = None,
+        script: t.Optional[t.Mapping[str, t.Any]] = None,
         context: t.Optional[str] = None,
         error_trace: t.Optional[bool] = None,
         filter_path: t.Optional[t.Union[str, t.Sequence[str]]] = None,
@@ -2920,7 +2920,7 @@ async def put_script(
         """
         if id in SKIP_IN_PATH:
             raise ValueError("Empty value passed for parameter 'id'")
-        if script is None:
+        if script is None and body is None:
             raise ValueError("Empty value passed for parameter 'script'")
         if id not in SKIP_IN_PATH and context not in SKIP_IN_PATH:
             __path = f"/_scripts/{_quote(id)}/{_quote(context)}"
@@ -2956,7 +2956,7 @@ async def put_script(
     async def rank_eval(
         self,
         *,
-        requests: t.Sequence[t.Mapping[str, t.Any]],
+        requests: t.Optional[t.Sequence[t.Mapping[str, t.Any]]] = None,
         index: t.Optional[t.Union[str, t.Sequence[str]]] = None,
         allow_no_indices: t.Optional[bool] = None,
         error_trace: t.Optional[bool] = None,
@@ -3000,7 +3000,7 @@ async def rank_eval(
         :param metric: Definition of the evaluation metric to calculate.
         :param search_type: Search operation type
         """
-        if requests is None:
+        if requests is None and body is None:
             raise ValueError("Empty value passed for parameter 'requests'")
         if index not in SKIP_IN_PATH:
             __path = f"/{_quote(index)}/_rank_eval"
@@ -3040,8 +3040,8 @@ async def rank_eval(
     async def reindex(
         self,
         *,
-        dest: t.Mapping[str, t.Any],
-        source: t.Mapping[str, t.Any],
+        dest: t.Optional[t.Mapping[str, t.Any]] = None,
+        source: t.Optional[t.Mapping[str, t.Any]] = None,
         conflicts: t.Optional[t.Union["t.Literal['abort', 'proceed']", str]] = None,
         error_trace: t.Optional[bool] = None,
         filter_path: t.Optional[t.Union[str, t.Sequence[str]]] = None,
@@ -3093,9 +3093,9 @@ async def reindex(
         :param wait_for_completion: If `true`, the request blocks until the operation
             is complete.
         """
-        if dest is None:
+        if dest is None and body is None:
             raise ValueError("Empty value passed for parameter 'dest'")
-        if source is None:
+        if source is None and body is None:
             raise ValueError("Empty value passed for parameter 'source'")
         __path = "/_reindex"
         __query: t.Dict[str, t.Any] = {}
@@ -3299,7 +3299,7 @@ async def scripts_painless_execute(
     async def scroll(
         self,
         *,
-        scroll_id: str,
+        scroll_id: t.Optional[str] = None,
         error_trace: t.Optional[bool] = None,
         filter_path: t.Optional[t.Union[str, t.Sequence[str]]] = None,
         human: t.Optional[bool] = None,
@@ -3319,7 +3319,7 @@ async def scroll(
             is returned as an object.
         :param scroll: Period to retain the search context for scrolling.
         """
-        if scroll_id is None:
+        if scroll_id is None and body is None:
             raise ValueError("Empty value passed for parameter 'scroll_id'")
         __path = "/_search/scroll"
         __query: t.Dict[str, t.Any] = {}
@@ -3856,11 +3856,11 @@ async def search(
     async def search_mvt(
         self,
         *,
-        index: t.Union[str, t.Sequence[str]],
-        field: str,
-        zoom: int,
-        x: int,
-        y: int,
+        index: t.Optional[t.Union[str, t.Sequence[str]]] = None,
+        field: t.Optional[str] = None,
+        zoom: t.Optional[int] = None,
+        x: t.Optional[int] = None,
+        y: t.Optional[int] = None,
         aggs: t.Optional[t.Mapping[str, t.Mapping[str, t.Any]]] = None,
         buffer: t.Optional[int] = None,
         error_trace: t.Optional[bool] = None,
@@ -4233,8 +4233,8 @@ async def search_template(
     async def terms_enum(
         self,
         *,
-        index: str,
-        field: str,
+        index: t.Optional[str] = None,
+        field: t.Optional[str] = None,
         case_insensitive: t.Optional[bool] = None,
         error_trace: t.Optional[bool] = None,
         filter_path: t.Optional[t.Union[str, t.Sequence[str]]] = None,
@@ -4273,7 +4273,7 @@ async def terms_enum(
         """
         if index in SKIP_IN_PATH:
             raise ValueError("Empty value passed for parameter 'index'")
-        if field is None:
+        if field is None and body is None:
             raise ValueError("Empty value passed for parameter 'field'")
         __path = f"/{_quote(index)}/_terms_enum"
         __query: t.Dict[str, t.Any] = {}
@@ -4316,7 +4316,7 @@ async def terms_enum(
     async def termvectors(
         self,
         *,
-        index: str,
+        index: t.Optional[str] = None,
         id: t.Optional[str] = None,
         doc: t.Optional[t.Mapping[str, t.Any]] = None,
         error_trace: t.Optional[bool] = None,
@@ -4444,8 +4444,8 @@ async def termvectors(
     async def update(
         self,
         *,
-        index: str,
-        id: str,
+        index: t.Optional[str] = None,
+        id: t.Optional[str] = None,
         detect_noop: t.Optional[bool] = None,
         doc: t.Optional[t.Mapping[str, t.Any]] = None,
         doc_as_upsert: t.Optional[bool] = None,
@@ -4579,7 +4579,7 @@ async def update(
     async def update_by_query(
         self,
         *,
-        index: t.Union[str, t.Sequence[str]],
+        index: t.Optional[t.Union[str, t.Sequence[str]]] = None,
         allow_no_indices: t.Optional[bool] = None,
         analyze_wildcard: t.Optional[bool] = None,
         analyzer: t.Optional[str] = None,

elasticsearch/_async/client/ccr.py

@@ -77,7 +77,7 @@ async def delete_auto_follow_pattern(
     async def follow(
         self,
         *,
-        index: str,
+        index: t.Optional[str] = None,
         error_trace: t.Optional[bool] = None,
         filter_path: t.Optional[t.Union[str, t.Sequence[str]]] = None,
         human: t.Optional[bool] = None,
@@ -260,7 +260,7 @@ async def follow_stats(
     async def forget_follower(
         self,
         *,
-        index: str,
+        index: t.Optional[str] = None,
         error_trace: t.Optional[bool] = None,
         filter_path: t.Optional[t.Union[str, t.Sequence[str]]] = None,
         follower_cluster: t.Optional[str] = None,
@@ -440,8 +440,8 @@ async def pause_follow(
     async def put_auto_follow_pattern(
         self,
         *,
-        name: str,
-        remote_cluster: str,
+        name: t.Optional[str] = None,
+        remote_cluster: t.Optional[str] = None,
         error_trace: t.Optional[bool] = None,
         filter_path: t.Optional[t.Union[str, t.Sequence[str]]] = None,
         follow_index_pattern: t.Optional[str] = None,
@@ -518,7 +518,7 @@ async def put_auto_follow_pattern(
         """
         if name in SKIP_IN_PATH:
             raise ValueError("Empty value passed for parameter 'name'")
-        if remote_cluster is None:
+        if remote_cluster is None and body is None:
             raise ValueError("Empty value passed for parameter 'remote_cluster'")
         __path = f"/_ccr/auto_follow/{_quote(name)}"
         __query: t.Dict[str, t.Any] = {}
@@ -627,7 +627,7 @@ async def resume_auto_follow_pattern(
     async def resume_follow(
         self,
         *,
-        index: str,
+        index: t.Optional[str] = None,
         error_trace: t.Optional[bool] = None,
         filter_path: t.Optional[t.Union[str, t.Sequence[str]]] = None,
         human: t.Optional[bool] = None,

elasticsearch/_async/client/cluster.py

@@ -601,8 +601,8 @@ async def post_voting_config_exclusions(
     async def put_component_template(
         self,
         *,
-        name: str,
-        template: t.Mapping[str, t.Any],
+        name: t.Optional[str] = None,
+        template: t.Optional[t.Mapping[str, t.Any]] = None,
         allow_auto_create: t.Optional[bool] = None,
         create: t.Optional[bool] = None,
         error_trace: t.Optional[bool] = None,
@@ -652,7 +652,7 @@ async def put_component_template(
         """
         if name in SKIP_IN_PATH:
             raise ValueError("Empty value passed for parameter 'name'")
-        if template is None:
+        if template is None and body is None:
             raise ValueError("Empty value passed for parameter 'template'")
         __path = f"/_component_template/{_quote(name)}"
         __query: t.Dict[str, t.Any] = {}

elasticsearch/_async/client/enrich.py

@@ -139,7 +139,7 @@ async def get_policy(
     async def put_policy(
         self,
         *,
-        name: str,
+        name: t.Optional[str] = None,
         error_trace: t.Optional[bool] = None,
         filter_path: t.Optional[t.Union[str, t.Sequence[str]]] = None,
         geo_match: t.Optional[t.Mapping[str, t.Any]] = None,

elasticsearch/_async/client/eql.py

@@ -165,8 +165,8 @@ async def get_status(
     async def search(
         self,
         *,
-        index: t.Union[str, t.Sequence[str]],
-        query: str,
+        index: t.Optional[t.Union[str, t.Sequence[str]]] = None,
+        query: t.Optional[str] = None,
         allow_no_indices: t.Optional[bool] = None,
         case_sensitive: t.Optional[bool] = None,
         error_trace: t.Optional[bool] = None,
@@ -235,7 +235,7 @@ async def search(
         """
         if index in SKIP_IN_PATH:
             raise ValueError("Empty value passed for parameter 'index'")
-        if query is None:
+        if query is None and body is None:
             raise ValueError("Empty value passed for parameter 'query'")
         __path = f"/{_quote(index)}/_eql/search"
         __query: t.Dict[str, t.Any] = {}

elasticsearch/_async/client/fleet.py

@@ -263,7 +263,7 @@ async def msearch(
     async def search(
         self,
         *,
-        index: str,
+        index: t.Optional[str] = None,
         aggregations: t.Optional[t.Mapping[str, t.Mapping[str, t.Any]]] = None,
         aggs: t.Optional[t.Mapping[str, t.Mapping[str, t.Any]]] = None,
         allow_no_indices: t.Optional[bool] = None,

elasticsearch/_async/client/graph.py

@@ -30,7 +30,7 @@ class GraphClient(NamespacedClient):
     async def explore(
         self,
         *,
-        index: t.Union[str, t.Sequence[str]],
+        index: t.Optional[t.Union[str, t.Sequence[str]]] = None,
         connections: t.Optional[t.Mapping[str, t.Any]] = None,
         controls: t.Optional[t.Mapping[str, t.Any]] = None,
         error_trace: t.Optional[bool] = None,

elasticsearch/_async/client/ilm.py

@@ -271,7 +271,7 @@ async def migrate_to_data_tiers(
     async def move_to_step(
         self,
         *,
-        index: str,
+        index: t.Optional[str] = None,
         current_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,
@@ -322,7 +322,7 @@ async def move_to_step(
     async def put_lifecycle(
         self,
         *,
-        name: str,
+        name: t.Optional[str] = None,
         error_trace: t.Optional[bool] = None,
         filter_path: t.Optional[t.Union[str, t.Sequence[str]]] = None,
         human: t.Optional[bool] = None,