Merge branch 'main' into use-unbuffered-queue

Author: miguelgrinberg

.buildkite/pipeline.yml

@@ -5,7 +5,7 @@ steps:
     env:
       PYTHON_VERSION: "{{ matrix.python }}"
       TEST_SUITE: "platinum"
-      STACK_VERSION: "9.1.0-SNAPSHOT"
+      STACK_VERSION: "9.2.0-SNAPSHOT"
       PYTHON_CONNECTION_CLASS: "{{ matrix.connection }}"
       NOX_SESSION: "{{ matrix.nox_session }}"
     matrix:

docs/reference/dsl_how_to_guides.md

@@ -927,7 +927,7 @@ first = Post.get(id=42)
 first.update(published=True, published_by='me')
 ```
 
-In case you wish to use a `painless` script to perform the update you can pass in the script string as `script` or the `id` of a [stored script](docs-content://explore-analyze/scripting/modules-scripting-using.md#script-stored-scripts) via `script_id`. All additional keyword arguments to the `update` method will then be passed in as parameters of the script. The document will not be updated in place.
+In case you wish to use a `painless` script to perform the update you can pass in the script string as `script` or the `id` of a [stored script](docs-content://explore-analyze/scripting/modules-scripting-using.md) via `script_id`. All additional keyword arguments to the `update` method will then be passed in as parameters of the script. The document will not be updated in place.
 
 ```python
 # retrieve the document

docs/sphinx/api/indices.rst

@@ -6,4 +6,4 @@ Indices
    :no-index:
 
 .. autoclass:: IndicesClient
-   :members:
+   :members:

docs/sphinx/api/project.rst

@@ -0,0 +1,9 @@
+.. _project:
+
+Project
+-------
+.. py:module:: elasticsearch.client
+   :no-index:
+
+.. autoclass:: ProjectClient
+   :members:

docs/sphinx/api/streams.rst

@@ -0,0 +1,9 @@
+.. _streams:
+
+Streams
+-------
+.. py:module:: elasticsearch.client
+   :no-index:
+
+.. autoclass:: StreamsClient
+   :members:

docs/sphinx/es_api.rst

@@ -39,6 +39,7 @@ arguments are required for all calls.
    api/ml
    api/monitoring
    api/nodes
+   api/project
    api/query-rules
    api/rollup-indices
    api/search-application
@@ -50,6 +51,7 @@ arguments are required for all calls.
    api/snapshots
    api/snapshottable-features
    api/sql
+   api/streams
    api/synonyms
    api/tls-ssl
    api/tasks

elasticsearch/_async/client/__init__.py

@@ -287,6 +287,7 @@ async def submit(
         preference: t.Optional[str] = None,
         pretty: t.Optional[bool] = None,
         profile: t.Optional[bool] = None,
+        project_routing: t.Optional[str] = None,
         q: t.Optional[str] = None,
         query: t.Optional[t.Mapping[str, t.Any]] = None,
         request_cache: t.Optional[bool] = None,
@@ -408,6 +409,10 @@ async def submit(
         :param preference: Specify the node or shard the operation should be performed
             on (default: random)
         :param profile:
+        :param project_routing: Specifies a subset of projects to target for the search
+            using project metadata tags in a subset of Lucene query syntax. Allowed Lucene
+            queries: the _alias tag and a single value (possibly wildcarded). Examples:
+            _alias:my-project _alias:_origin _alias:*pr* Supported in serverless only.
         :param q: Query in the Lucene query string syntax
         :param query: Defines the search definition using the Query DSL.
         :param request_cache: Specify if request cache should be used for this request
@@ -528,6 +533,8 @@ async def submit(
             __query["preference"] = preference
         if pretty is not None:
             __query["pretty"] = pretty
+        if project_routing is not None:
+            __query["project_routing"] = project_routing
         if q is not None:
             __query["q"] = q
         if request_cache is not None:

elasticsearch/_async/client/async_search.py

@@ -103,7 +103,7 @@ async def delete(
 
         :param connector_id: The unique identifier of the connector to be deleted
         :param delete_sync_jobs: A flag indicating if associated sync jobs should be
-            also removed. Defaults to false.
+            also removed.
         :param hard: A flag indicating if the connector should be hard deleted.
         """
         if connector_id in SKIP_IN_PATH:
@@ -360,7 +360,7 @@ async def list(
 
         :param connector_name: A comma-separated list of connector names to fetch connector
             documents for
-        :param from_: Starting offset (default: 0)
+        :param from_: Starting offset
         :param include_deleted: A flag to indicate if the desired connector should be
             fetched, even if it was soft-deleted.
         :param index_name: A comma-separated list of connector index names to fetch connector
@@ -955,7 +955,7 @@ async def sync_job_list(
         `<https://www.elastic.co/docs/api/doc/elasticsearch/operation/operation-connector-sync-job-list>`_
 
         :param connector_id: A connector id to fetch connector sync jobs for
-        :param from_: Starting offset (default: 0)
+        :param from_: Starting offset
         :param job_type: A comma-separated list of job types to fetch the sync jobs for
         :param size: Specifies a max number of results to get
         :param status: A sync job status to fetch connector sync jobs for