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] = {}
@@ -2323,7 +2323,7 @@ async def knn_search(
         self,
         *,
         index: t.Union[str, t.Sequence[str]],
-        knn: t.Mapping[str, t.Any],
+        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] = {}
@@ -2888,7 +2888,7 @@ async def put_script(
         self,
         *,
         id: str,
-        script: t.Mapping[str, t.Any],
+        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] = {}
@@ -4234,7 +4234,7 @@ async def terms_enum(
         self,
         *,
         index: str,
-        field: str,
+        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] = {}

elasticsearch/_async/client/ccr.py

@@ -441,7 +441,7 @@ async def put_auto_follow_pattern(
         self,
         *,
         name: str,
-        remote_cluster: str,
+        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] = {}

elasticsearch/_async/client/cluster.py

@@ -602,7 +602,7 @@ async def put_component_template(
         self,
         *,
         name: str,
-        template: t.Mapping[str, t.Any],
+        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/eql.py

@@ -166,7 +166,7 @@ async def search(
         self,
         *,
         index: t.Union[str, t.Sequence[str]],
-        query: str,
+        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/indices.py

@@ -2246,7 +2246,7 @@ async def migrate_to_data_stream(
     async def modify_data_stream(
         self,
         *,
-        actions: t.Sequence[t.Mapping[str, t.Any]],
+        actions: t.Optional[t.Sequence[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,
@@ -2260,7 +2260,7 @@ async def modify_data_stream(
 
         :param actions: Actions to perform.
         """
-        if actions is None:
+        if actions is None and body is None:
             raise ValueError("Empty value passed for parameter 'actions'")
         __path = "/_data_stream/_modify"
         __query: t.Dict[str, t.Any] = {}

elasticsearch/_async/client/ml.py

@@ -695,8 +695,8 @@ async def estimate_model_memory(
     async def evaluate_data_frame(
         self,
         *,
-        evaluation: t.Mapping[str, t.Any],
-        index: str,
+        evaluation: t.Optional[t.Mapping[str, t.Any]] = None,
+        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,
@@ -714,9 +714,9 @@ async def evaluate_data_frame(
         :param query: A query clause that retrieves a subset of data from the source
             index.
         """
-        if evaluation is None:
+        if evaluation is None and body is None:
             raise ValueError("Empty value passed for parameter 'evaluation'")
-        if index is None:
+        if index is None and body is None:
             raise ValueError("Empty value passed for parameter 'index'")
         __path = "/_ml/data_frame/_evaluate"
         __query: t.Dict[str, t.Any] = {}
@@ -2219,7 +2219,7 @@ async def infer_trained_model(
         self,
         *,
         model_id: str,
-        docs: t.Sequence[t.Mapping[str, t.Any]],
+        docs: t.Optional[t.Sequence[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,
@@ -2244,7 +2244,7 @@ async def infer_trained_model(
         """
         if model_id in SKIP_IN_PATH:
             raise ValueError("Empty value passed for parameter 'model_id'")
-        if docs is None:
+        if docs is None and body is None:
             raise ValueError("Empty value passed for parameter 'docs'")
         __path = f"/_ml/trained_models/{_quote(model_id)}/_infer"
         __query: t.Dict[str, t.Any] = {}
@@ -2352,7 +2352,7 @@ async def post_calendar_events(
         self,
         *,
         calendar_id: str,
-        events: t.Sequence[t.Mapping[str, t.Any]],
+        events: t.Optional[t.Sequence[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,
@@ -2371,7 +2371,7 @@ async def post_calendar_events(
         """
         if calendar_id in SKIP_IN_PATH:
             raise ValueError("Empty value passed for parameter 'calendar_id'")
-        if events is None:
+        if events is None and body is None:
             raise ValueError("Empty value passed for parameter 'events'")
         __path = f"/_ml/calendars/{_quote(calendar_id)}/events"
         __query: t.Dict[str, t.Any] = {}
@@ -2678,9 +2678,9 @@ async def put_data_frame_analytics(
         self,
         *,
         id: str,
-        analysis: t.Mapping[str, t.Any],
-        dest: t.Mapping[str, t.Any],
-        source: t.Mapping[str, t.Any],
+        analysis: t.Optional[t.Mapping[str, t.Any]] = None,
+        dest: t.Optional[t.Mapping[str, t.Any]] = None,
+        source: t.Optional[t.Mapping[str, t.Any]] = None,
         allow_lazy_start: t.Optional[bool] = None,
         analyzed_fields: t.Optional[t.Mapping[str, t.Any]] = None,
         description: t.Optional[str] = None,
@@ -2756,11 +2756,11 @@ async def put_data_frame_analytics(
         """
         if id in SKIP_IN_PATH:
             raise ValueError("Empty value passed for parameter 'id'")
-        if analysis is None:
+        if analysis is None and body is None:
             raise ValueError("Empty value passed for parameter 'analysis'")
-        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 = f"/_ml/data_frame/analytics/{_quote(id)}"
         __query: t.Dict[str, t.Any] = {}
@@ -3057,8 +3057,8 @@ async def put_job(
         self,
         *,
         job_id: str,
-        analysis_config: t.Mapping[str, t.Any],
-        data_description: t.Mapping[str, t.Any],
+        analysis_config: t.Optional[t.Mapping[str, t.Any]] = None,
+        data_description: t.Optional[t.Mapping[str, t.Any]] = None,
         allow_lazy_open: t.Optional[bool] = None,
         analysis_limits: t.Optional[t.Mapping[str, t.Any]] = None,
         background_persist_interval: t.Optional[
@@ -3160,9 +3160,9 @@ async def put_job(
         """
         if job_id in SKIP_IN_PATH:
             raise ValueError("Empty value passed for parameter 'job_id'")
-        if analysis_config is None:
+        if analysis_config is None and body is None:
             raise ValueError("Empty value passed for parameter 'analysis_config'")
-        if data_description is None:
+        if data_description is None and body is None:
             raise ValueError("Empty value passed for parameter 'data_description'")
         __path = f"/_ml/anomaly_detectors/{_quote(job_id)}"
         __query: t.Dict[str, t.Any] = {}
@@ -3379,9 +3379,9 @@ async def put_trained_model_definition_part(
         *,
         model_id: str,
         part: int,
-        definition: str,
-        total_definition_length: int,
-        total_parts: int,
+        definition: t.Optional[str] = None,
+        total_definition_length: t.Optional[int] = None,
+        total_parts: t.Optional[int] = None,
         error_trace: t.Optional[bool] = None,
         filter_path: t.Optional[t.Union[str, t.Sequence[str]]] = None,
         human: t.Optional[bool] = None,
@@ -3408,13 +3408,13 @@ async def put_trained_model_definition_part(
             raise ValueError("Empty value passed for parameter 'model_id'")
         if part in SKIP_IN_PATH:
             raise ValueError("Empty value passed for parameter 'part'")
-        if definition is None:
+        if definition is None and body is None:
             raise ValueError("Empty value passed for parameter 'definition'")
-        if total_definition_length is None:
+        if total_definition_length is None and body is None:
             raise ValueError(
                 "Empty value passed for parameter 'total_definition_length'"
             )
-        if total_parts is None:
+        if total_parts is None and body is None:
             raise ValueError("Empty value passed for parameter 'total_parts'")
         __path = f"/_ml/trained_models/{_quote(model_id)}/definition/{_quote(part)}"
         __query: t.Dict[str, t.Any] = {}
@@ -3446,7 +3446,7 @@ async def put_trained_model_vocabulary(
         self,
         *,
         model_id: str,
-        vocabulary: t.Sequence[str],
+        vocabulary: t.Optional[t.Sequence[str]] = None,
         error_trace: t.Optional[bool] = None,
         filter_path: t.Optional[t.Union[str, t.Sequence[str]]] = None,
         human: t.Optional[bool] = None,
@@ -3467,7 +3467,7 @@ async def put_trained_model_vocabulary(
         """
         if model_id in SKIP_IN_PATH:
             raise ValueError("Empty value passed for parameter 'model_id'")
-        if vocabulary is None:
+        if vocabulary is None and body is None:
             raise ValueError("Empty value passed for parameter 'vocabulary'")
         __path = f"/_ml/trained_models/{_quote(model_id)}/vocabulary"
         __query: t.Dict[str, t.Any] = {}

elasticsearch/_async/client/query_ruleset.py

@@ -139,7 +139,7 @@ async def put(
         self,
         *,
         ruleset_id: str,
-        rules: t.Sequence[t.Mapping[str, t.Any]],
+        rules: t.Optional[t.Sequence[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,
@@ -157,7 +157,7 @@ async def put(
         """
         if ruleset_id in SKIP_IN_PATH:
             raise ValueError("Empty value passed for parameter 'ruleset_id'")
-        if rules is None:
+        if rules is None and body is None:
             raise ValueError("Empty value passed for parameter 'rules'")
         __path = f"/_query_rules/{_quote(ruleset_id)}"
         __query: t.Dict[str, t.Any] = {}