Make 'body' optional on 'indices.create_data_stream' API

Author: sethmlarson

elasticsearch/_async/client/__init__.py

@@ -1432,7 +1432,8 @@ async def search(self, body=None, index=None, params=None, headers=None):
  :arg track_scores: Whether to calculate and return scores even
  if they are not used for sorting
  :arg track_total_hits: Indicate if the number of documents that
- match the query should be tracked
+ match the query should be tracked. A number can also be specified, to
+ accurately track the total hit count up to the number.
  :arg typed_keys: Specify whether aggregation and suggester names
  should be prefixed by their respective types in the response
  :arg version: Specify whether to return document version as part

elasticsearch/_async/client/indices.py

@@ -1203,17 +1203,16 @@ async def validate_query(
  )
 
  @query_params()
- async def create_data_stream(self, name, body, params=None, headers=None):
+ async def create_data_stream(self, name, body=None, params=None, headers=None):
  """
  Creates or updates a data stream
  `<https://www.elastic.co/guide/en/elasticsearch/reference/master/data-streams.html>`_
 
  :arg name: The name of the data stream
  :arg body: The data stream definition
  """
- for param in (name, body):
- if param in SKIP_IN_PATH:
- raise ValueError("Empty value passed for a required argument.")
+ if name in SKIP_IN_PATH:
+ raise ValueError("Empty value passed for a required argument 'name'.")
 
  return await self.transport.perform_request(
  "PUT",

elasticsearch/_async/client/ml.py

@@ -318,7 +318,7 @@ async def flush_job(self, job_id, body=None, params=None, headers=None):
  body=body,
  )
 
- @query_params("duration", "expires_in")
+ @query_params("duration", "expires_in", "max_model_memory")
  async def forecast(self, job_id, params=None, headers=None):
  """
  Predicts the future behavior of a time series by using its historical behavior.
@@ -328,6 +328,8 @@ async def forecast(self, job_id, params=None, headers=None):
  :arg duration: The duration of the forecast
  :arg expires_in: The time interval after which the forecast
  expires. Expired forecasts will be deleted at the first opportunity.
+ :arg max_model_memory: The max memory able to be used by the
+ forecast. Default is 20mb.
  """
  if job_id in SKIP_IN_PATH:
  raise ValueError("Empty value passed for a required argument 'job_id'.")
@@ -1244,6 +1246,7 @@ async def delete_trained_model(self, model_id, params=None, headers=None):
  @query_params(
  "allow_no_match",
  "decompress_definition",
+ "for_export",
  "from_",
  "include_model_definition",
  "size",
@@ -1261,6 +1264,8 @@ async def get_trained_models(self, model_id=None, params=None, headers=None):
  :arg decompress_definition: Should the model definition be
  decompressed into valid JSON or returned in a custom compressed format.
  Defaults to true. Default: True
+ :arg for_export: Omits fields that are illegal to set on model
+ PUT
  :arg from\\_: skips a number of trained models
  :arg include_model_definition: Should the full model definition
  be included in the results. These definitions can be large. So be

elasticsearch/_async/client/security.py

@@ -277,7 +277,7 @@ async def get_role(self, name=None, params=None, headers=None):
  Retrieves roles in the native realm.
  `<https://www.elastic.co/guide/en/elasticsearch/reference/master/security-api-get-role.html>`_
 
- :arg name: Role name
+ :arg name: A comma-separated list of role names
  """
  return await self.transport.perform_request(
  "GET", _make_path("_security", "role", name), params=params, headers=headers
@@ -289,7 +289,7 @@ async def get_role_mapping(self, name=None, params=None, headers=None):
  Retrieves role mappings.
  `<https://www.elastic.co/guide/en/elasticsearch/reference/master/security-api-get-role-mapping.html>`_
 
- :arg name: Role-Mapping name
+ :arg name: A comma-separated list of role-mapping names
  """
  return await self.transport.perform_request(
  "GET",

elasticsearch/_async/client/snapshot.py

@@ -87,7 +87,8 @@ async def delete_repository(self, repository, params=None, headers=None):
  Deletes a repository.
  `<https://www.elastic.co/guide/en/elasticsearch/reference/master/modules-snapshots.html>`_
 
- :arg repository: A comma-separated list of repository names
+ :arg repository: Name of the snapshot repository to unregister.
+ Wildcard (`*`) patterns are supported.
  :arg master_timeout: Explicit operation timeout for connection
  to master node
  :arg timeout: Explicit operation timeout

elasticsearch/client/__init__.py

@@ -1430,7 +1430,8 @@ def search(self, body=None, index=None, params=None, headers=None):
  :arg track_scores: Whether to calculate and return scores even
  if they are not used for sorting
  :arg track_total_hits: Indicate if the number of documents that
- match the query should be tracked
+ match the query should be tracked. A number can also be specified, to
+ accurately track the total hit count up to the number.
  :arg typed_keys: Specify whether aggregation and suggester names
  should be prefixed by their respective types in the response
  :arg version: Specify whether to return document version as part

elasticsearch/client/indices.py

@@ -1201,17 +1201,16 @@ def validate_query(
  )
 
  @query_params()
- def create_data_stream(self, name, body, params=None, headers=None):
+ def create_data_stream(self, name, body=None, params=None, headers=None):
  """
  Creates or updates a data stream
  `<https://www.elastic.co/guide/en/elasticsearch/reference/master/data-streams.html>`_
 
  :arg name: The name of the data stream
  :arg body: The data stream definition
  """
- for param in (name, body):
- if param in SKIP_IN_PATH:
- raise ValueError("Empty value passed for a required argument.")
+ if name in SKIP_IN_PATH:
+ raise ValueError("Empty value passed for a required argument 'name'.")
 
  return self.transport.perform_request(
  "PUT",

elasticsearch/client/ml.py

@@ -312,7 +312,7 @@ def flush_job(self, job_id, body=None, params=None, headers=None):
  body=body,
  )
 
- @query_params("duration", "expires_in")
+ @query_params("duration", "expires_in", "max_model_memory")
  def forecast(self, job_id, params=None, headers=None):
  """
  Predicts the future behavior of a time series by using its historical behavior.
@@ -322,6 +322,8 @@ def forecast(self, job_id, params=None, headers=None):
  :arg duration: The duration of the forecast
  :arg expires_in: The time interval after which the forecast
  expires. Expired forecasts will be deleted at the first opportunity.
+ :arg max_model_memory: The max memory able to be used by the
+ forecast. Default is 20mb.
  """
  if job_id in SKIP_IN_PATH:
  raise ValueError("Empty value passed for a required argument 'job_id'.")
@@ -1232,6 +1234,7 @@ def delete_trained_model(self, model_id, params=None, headers=None):
  @query_params(
  "allow_no_match",
  "decompress_definition",
+ "for_export",
  "from_",
  "include_model_definition",
  "size",
@@ -1249,6 +1252,8 @@ def get_trained_models(self, model_id=None, params=None, headers=None):
  :arg decompress_definition: Should the model definition be
  decompressed into valid JSON or returned in a custom compressed format.
  Defaults to true. Default: True
+ :arg for_export: Omits fields that are illegal to set on model
+ PUT
  :arg from\\_: skips a number of trained models
  :arg include_model_definition: Should the full model definition
  be included in the results. These definitions can be large. So be

elasticsearch/client/security.py

@@ -275,7 +275,7 @@ def get_role(self, name=None, params=None, headers=None):
  Retrieves roles in the native realm.
  `<https://www.elastic.co/guide/en/elasticsearch/reference/master/security-api-get-role.html>`_
 
- :arg name: Role name
+ :arg name: A comma-separated list of role names
  """
  return self.transport.perform_request(
  "GET", _make_path("_security", "role", name), params=params, headers=headers
@@ -287,7 +287,7 @@ def get_role_mapping(self, name=None, params=None, headers=None):
  Retrieves role mappings.
  `<https://www.elastic.co/guide/en/elasticsearch/reference/master/security-api-get-role-mapping.html>`_
 
- :arg name: Role-Mapping name
+ :arg name: A comma-separated list of role-mapping names
  """
  return self.transport.perform_request(
  "GET",

elasticsearch/client/snapshot.py

@@ -87,7 +87,8 @@ def delete_repository(self, repository, params=None, headers=None):
  Deletes a repository.
  `<https://www.elastic.co/guide/en/elasticsearch/reference/master/modules-snapshots.html>`_
 
- :arg repository: A comma-separated list of repository names
+ :arg repository: Name of the snapshot repository to unregister.
+ Wildcard (`*`) patterns are supported.
  :arg master_timeout: Explicit operation timeout for connection
  to master node
  :arg timeout: Explicit operation timeout