Update Python Client to 3.1.0

CHANGELOG.md

@@ -17,6 +17,42 @@
  under the License.
  -->
 
+# v3.1.0
+
+## New Features:
+
+- Add `map_index` filter to TaskInstance API queries ([#55614](https://github.com/apache/airflow/pull/55614))
+- Add `has_import_errors` filter to Core API GET /dags endpoint ([#54563](https://github.com/apache/airflow/pull/54563))
+- Add `dag_version` filter to get_dag_runs endpoint ([#54882](https://github.com/apache/airflow/pull/54882))
+- Implement pattern search for event log endpoint ([#55114](https://github.com/apache/airflow/pull/55114))
+- Add asset-based filtering support to DAG API endpoint ([#54263](https://github.com/apache/airflow/pull/54263))
+- Add Greater Than and Less Than range filters to DagRuns and Task Instance list ([#54302](https://github.com/apache/airflow/pull/54302))
+- Add `try_number` as filter to task instances ([#54695](https://github.com/apache/airflow/pull/54695))
+- Add filters to Browse XComs endpoint ([#54049](https://github.com/apache/airflow/pull/54049))
+- Add Filtering by DAG Bundle Name and Version to API routes ([#54004](https://github.com/apache/airflow/pull/54004))
+- Add search filter for DAG runs by triggering user name ([#53652](https://github.com/apache/airflow/pull/53652))
+- Enable multi sorting (AIP-84) ([#53408](https://github.com/apache/airflow/pull/53408))
+- Add `run_on_latest_version` support for backfill and clear operations ([#52177](https://github.com/apache/airflow/pull/52177))
+- Add `run_id_pattern` search for Dag Run API ([#52437](https://github.com/apache/airflow/pull/52437))
+- Add tracking of triggering user to Dag runs ([#51738](https://github.com/apache/airflow/pull/51738))
+- Expose DAG parsing duration in the API ([#54752](https://github.com/apache/airflow/pull/54752))
+
+## New API Endpoints:
+
+- Add Human-in-the-Loop (HITL) endpoints for approval workflows ([#52868](https://github.com/apache/airflow/pull/52868), [#53373](https://github.com/apache/airflow/pull/53373), [#53376](https://github.com/apache/airflow/pull/53376), [#53885](https://github.com/apache/airflow/pull/53885), [#53923](https://github.com/apache/airflow/pull/53923), [#54308](https://github.com/apache/airflow/pull/54308), [#54310](https://github.com/apache/airflow/pull/54310), [#54723](https://github.com/apache/airflow/pull/54723), [#54773](https://github.com/apache/airflow/pull/54773), [#55019](https://github.com/apache/airflow/pull/55019), [#55463](https://github.com/apache/airflow/pull/55463), [#55525](https://github.com/apache/airflow/pull/55525), [#55535](https://github.com/apache/airflow/pull/55535), [#55603](https://github.com/apache/airflow/pull/55603), [#55776](https://github.com/apache/airflow/pull/55776))
+- Add endpoint to watch dag run until finish ([#51920](https://github.com/apache/airflow/pull/51920))
+- Add TI bulk actions endpoint ([#50443](https://github.com/apache/airflow/pull/50443))
+- Add Keycloak Refresh Token Endpoint ([#51657](https://github.com/apache/airflow/pull/51657))
+
+## Deprecations:
+
+- Mark `DagDetailsResponse.concurrency` as deprecated ([#55150](https://github.com/apache/airflow/pull/55150))
+
+## Bug Fixes:
+
+- Fix dag import error modal pagination ([#55719](https://github.com/apache/airflow/pull/55719))
+
+
 # v3.0.2
 
 ## Major changes:

README.md

@@ -394,6 +394,7 @@ Class | Method | HTTP request | Description
 *DagRunApi* | [**get_dag_runs**](docs/DagRunApi.md#get_dag_runs) | **GET** /api/v2/dags/{dag_id}/dagRuns | Get Dag Runs
 *DagRunApi* | [**get_list_dag_runs_batch**](docs/DagRunApi.md#get_list_dag_runs_batch) | **POST** /api/v2/dags/{dag_id}/dagRuns/list | Get List Dag Runs Batch
 *DagRunApi* | [**get_upstream_asset_events**](docs/DagRunApi.md#get_upstream_asset_events) | **GET** /api/v2/dags/{dag_id}/dagRuns/{dag_run_id}/upstreamAssetEvents | Get Upstream Asset Events
+*DagRunApi* | [**wait_dag_run_until_finished**](docs/DagRunApi.md#wait_dag_run_until_finished) | **GET** /api/v2/dags/{dag_id}/dagRuns/{dag_run_id}/wait | Experimental: Wait for a dag run to complete, and return task results if requested.
 *DagRunApi* | [**patch_dag_run**](docs/DagRunApi.md#patch_dag_run) | **PATCH** /api/v2/dags/{dag_id}/dagRuns/{dag_run_id} | Patch Dag Run
 *DagRunApi* | [**trigger_dag_run**](docs/DagRunApi.md#trigger_dag_run) | **POST** /api/v2/dags/{dag_id}/dagRuns | Trigger Dag Run
 *DagSourceApi* | [**get_dag_source**](docs/DagSourceApi.md#get_dag_source) | **GET** /api/v2/dagSources/{dag_id} | Get Dag Source

airflow_client/client/__init__.py

@@ -14,7 +14,7 @@
 """  # noqa: E501
 
 
-__version__ = "3.0.2"
+__version__ = "3.1.0"
 
 # import apis into sdk package
 from airflow_client.client.api.asset_api import AssetApi
@@ -43,6 +43,7 @@
 from airflow_client.client.api.variable_api import VariableApi
 from airflow_client.client.api.version_api import VersionApi
 from airflow_client.client.api.x_com_api import XComApi
+from airflow_client.client.api.experimental_api import ExperimentalApi
 
 # import ApiClient
 from airflow_client.client.api_response import ApiResponse
@@ -71,19 +72,26 @@
 from airflow_client.client.models.bulk_action_not_on_existence import BulkActionNotOnExistence
 from airflow_client.client.models.bulk_action_on_existence import BulkActionOnExistence
 from airflow_client.client.models.bulk_action_response import BulkActionResponse
+from airflow_client.client.models.bulk_body_bulk_task_instance_body import BulkBodyBulkTaskInstanceBody
+from airflow_client.client.models.bulk_body_bulk_task_instance_body_actions_inner import BulkBodyBulkTaskInstanceBodyActionsInner
 from airflow_client.client.models.bulk_body_connection_body import BulkBodyConnectionBody
 from airflow_client.client.models.bulk_body_connection_body_actions_inner import BulkBodyConnectionBodyActionsInner
 from airflow_client.client.models.bulk_body_pool_body import BulkBodyPoolBody
 from airflow_client.client.models.bulk_body_pool_body_actions_inner import BulkBodyPoolBodyActionsInner
 from airflow_client.client.models.bulk_body_variable_body import BulkBodyVariableBody
 from airflow_client.client.models.bulk_body_variable_body_actions_inner import BulkBodyVariableBodyActionsInner
+from airflow_client.client.models.bulk_create_action_bulk_task_instance_body import BulkCreateActionBulkTaskInstanceBody
 from airflow_client.client.models.bulk_create_action_connection_body import BulkCreateActionConnectionBody
 from airflow_client.client.models.bulk_create_action_pool_body import BulkCreateActionPoolBody
 from airflow_client.client.models.bulk_create_action_variable_body import BulkCreateActionVariableBody
+from airflow_client.client.models.bulk_delete_action_bulk_task_instance_body import BulkDeleteActionBulkTaskInstanceBody
+from airflow_client.client.models.bulk_delete_action_bulk_task_instance_body_entities_inner import BulkDeleteActionBulkTaskInstanceBodyEntitiesInner
 from airflow_client.client.models.bulk_delete_action_connection_body import BulkDeleteActionConnectionBody
 from airflow_client.client.models.bulk_delete_action_pool_body import BulkDeleteActionPoolBody
 from airflow_client.client.models.bulk_delete_action_variable_body import BulkDeleteActionVariableBody
 from airflow_client.client.models.bulk_response import BulkResponse
+from airflow_client.client.models.bulk_task_instance_body import BulkTaskInstanceBody
+from airflow_client.client.models.bulk_update_action_bulk_task_instance_body import BulkUpdateActionBulkTaskInstanceBody
 from airflow_client.client.models.bulk_update_action_connection_body import BulkUpdateActionConnectionBody
 from airflow_client.client.models.bulk_update_action_pool_body import BulkUpdateActionPoolBody
 from airflow_client.client.models.bulk_update_action_variable_body import BulkUpdateActionVariableBody
@@ -130,18 +138,27 @@
 from airflow_client.client.models.dry_run_backfill_response import DryRunBackfillResponse
 from airflow_client.client.models.event_log_collection_response import EventLogCollectionResponse
 from airflow_client.client.models.event_log_response import EventLogResponse
+from airflow_client.client.models.external_log_url_response import ExternalLogUrlResponse
+from airflow_client.client.models.external_view_response import ExternalViewResponse
 from airflow_client.client.models.extra_link_collection_response import ExtraLinkCollectionResponse
 from airflow_client.client.models.fast_api_app_response import FastAPIAppResponse
 from airflow_client.client.models.fast_api_root_middleware_response import FastAPIRootMiddlewareResponse
+from airflow_client.client.models.hitl_detail import HITLDetail
+from airflow_client.client.models.hitl_detail_collection import HITLDetailCollection
+from airflow_client.client.models.hitl_detail_response import HITLDetailResponse
+from airflow_client.client.models.hitl_user import HITLUser
 from airflow_client.client.models.http_exception_response import HTTPExceptionResponse
 from airflow_client.client.models.http_validation_error import HTTPValidationError
 from airflow_client.client.models.health_info_response import HealthInfoResponse
 from airflow_client.client.models.import_error_collection_response import ImportErrorCollectionResponse
 from airflow_client.client.models.import_error_response import ImportErrorResponse
 from airflow_client.client.models.job_collection_response import JobCollectionResponse
 from airflow_client.client.models.job_response import JobResponse
+from airflow_client.client.models.last_asset_event_response import LastAssetEventResponse
 from airflow_client.client.models.patch_task_instance_body import PatchTaskInstanceBody
 from airflow_client.client.models.plugin_collection_response import PluginCollectionResponse
+from airflow_client.client.models.plugin_import_error_collection_response import PluginImportErrorCollectionResponse
+from airflow_client.client.models.plugin_import_error_response import PluginImportErrorResponse
 from airflow_client.client.models.plugin_response import PluginResponse
 from airflow_client.client.models.pool_body import PoolBody
 from airflow_client.client.models.pool_collection_response import PoolCollectionResponse
@@ -151,6 +168,7 @@
 from airflow_client.client.models.provider_response import ProviderResponse
 from airflow_client.client.models.queued_event_collection_response import QueuedEventCollectionResponse
 from airflow_client.client.models.queued_event_response import QueuedEventResponse
+from airflow_client.client.models.react_app_response import ReactAppResponse
 from airflow_client.client.models.reprocess_behavior import ReprocessBehavior
 from airflow_client.client.models.response_clear_dag_run import ResponseClearDagRun
 from airflow_client.client.models.response_get_xcom_entry import ResponseGetXcomEntry
@@ -159,6 +177,7 @@
 from airflow_client.client.models.task_collection_response import TaskCollectionResponse
 from airflow_client.client.models.task_dependency_collection_response import TaskDependencyCollectionResponse
 from airflow_client.client.models.task_dependency_response import TaskDependencyResponse
+from airflow_client.client.models.task_inlet_asset_reference import TaskInletAssetReference
 from airflow_client.client.models.task_instance_collection_response import TaskInstanceCollectionResponse
 from airflow_client.client.models.task_instance_history_collection_response import TaskInstanceHistoryCollectionResponse
 from airflow_client.client.models.task_instance_history_response import TaskInstanceHistoryResponse
@@ -172,6 +191,7 @@
 from airflow_client.client.models.trigger_dag_run_post_body import TriggerDAGRunPostBody
 from airflow_client.client.models.trigger_response import TriggerResponse
 from airflow_client.client.models.triggerer_info_response import TriggererInfoResponse
+from airflow_client.client.models.update_hitl_detail_payload import UpdateHITLDetailPayload
 from airflow_client.client.models.validation_error import ValidationError
 from airflow_client.client.models.validation_error_loc_inner import ValidationErrorLocInner
 from airflow_client.client.models.value import Value

airflow_client/client/api/__init__.py

@@ -27,4 +27,5 @@
 from airflow_client.client.api.variable_api import VariableApi
 from airflow_client.client.api.version_api import VersionApi
 from airflow_client.client.api.x_com_api import XComApi
+from airflow_client.client.api.experimental_api import ExperimentalApi