@@ -626,12 +626,14 @@ async def bulk(
626626 error_trace : t .Optional [bool ] = None ,
627627 filter_path : t .Optional [t .Union [str , t .Sequence [str ]]] = None ,
628628 human : t .Optional [bool ] = None ,
629+ list_executed_pipelines : t .Optional [bool ] = None ,
629630 pipeline : t .Optional [str ] = None ,
630631 pretty : t .Optional [bool ] = None ,
631632 refresh : t .Optional [
632633 t .Union [bool , str , t .Literal ["false" , "true" , "wait_for" ]]
633634 ] = None ,
634635 require_alias : t .Optional [bool ] = None ,
636+ require_data_stream : t .Optional [bool ] = None ,
635637 routing : t .Optional [str ] = None ,
636638 source : t .Optional [t .Union [bool , t .Union [str , t .Sequence [str ]]]] = None ,
637639 source_excludes : t .Optional [t .Union [str , t .Sequence [str ]]] = None ,
@@ -651,6 +653,8 @@ async def bulk(
651653 :param operations:
652654 :param index: Name of the data stream, index, or index alias to perform bulk
653655 actions on.
656+ :param list_executed_pipelines: If `true`, the response will include the ingest
657+ pipelines that were executed for each index or create.
654658 :param pipeline: ID of the pipeline to use to preprocess incoming documents.
655659 If the index has a default ingest pipeline specified, then setting the value
656660 to `_none` disables the default ingest pipeline for this request. If a final
@@ -661,6 +665,8 @@ async def bulk(
661665 make this operation visible to search, if `false` do nothing with refreshes.
662666 Valid values: `true`, `false`, `wait_for`.
663667 :param require_alias: If `true`, the request’s actions must target an index alias.
668+ :param require_data_stream: If `true`, the request's actions must target a data
669+ stream (existing or to-be-created).
664670 :param routing: Custom value used to route operations to a specific shard.
665671 :param source: `true` or `false` to return the `_source` field or not, or a list
666672 of fields to return.
@@ -694,6 +700,8 @@ async def bulk(
694700 __query ["filter_path" ] = filter_path
695701 if human is not None :
696702 __query ["human" ] = human
703+ if list_executed_pipelines is not None :
704+ __query ["list_executed_pipelines" ] = list_executed_pipelines
697705 if pipeline is not None :
698706 __query ["pipeline" ] = pipeline
699707 if pretty is not None :
@@ -702,6 +710,8 @@ async def bulk(
702710 __query ["refresh" ] = refresh
703711 if require_alias is not None :
704712 __query ["require_alias" ] = require_alias
713+ if require_data_stream is not None :
714+ __query ["require_data_stream" ] = require_data_stream
705715 if routing is not None :
706716 __query ["routing" ] = routing
707717 if source is not None :
@@ -2274,7 +2284,26 @@ async def health_report(
22742284 verbose : t .Optional [bool ] = None ,
22752285 ) -> ObjectApiResponse [t .Any ]:
22762286 """
2277- Returns the health of the cluster.
2287+ Get the cluster health. Get a report with the health status of an Elasticsearch
2288+ cluster. The report contains a list of indicators that compose Elasticsearch
2289+ functionality. Each indicator has a health status of: green, unknown, yellow
2290+ or red. The indicator will provide an explanation and metadata describing the
2291+ reason for its current health status. The cluster’s status is controlled by the
2292+ worst indicator status. In the event that an indicator’s status is non-green,
2293+ a list of impacts may be present in the indicator result which detail the functionalities
2294+ that are negatively affected by the health issue. Each impact carries with it
2295+ a severity level, an area of the system that is affected, and a simple description
2296+ of the impact on the system. Some health indicators can determine the root cause
2297+ of a health problem and prescribe a set of steps that can be performed in order
2298+ to improve the health of the system. The root cause and remediation steps are
2299+ encapsulated in a diagnosis. A diagnosis contains a cause detailing a root cause
2300+ analysis, an action containing a brief description of the steps to take to fix
2301+ the problem, the list of affected resources (if applicable), and a detailed step-by-step
2302+ troubleshooting guide to fix the diagnosed problem. NOTE: The health indicators
2303+ perform root cause analysis of non-green health statuses. This can be computationally
2304+ expensive when called frequently. When setting up automated polling of the API
2305+ for health status, set verbose to false to disable the more expensive analysis
2306+ logic.
22782307
22792308 `<https://www.elastic.co/guide/en/elasticsearch/reference/8.16/health-api.html>`_
22802309
0 commit comments