Skip to content

Commit 241405e

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

File tree

231 files changed

+16763
-2238
lines changed

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

231 files changed

+16763
-2238
lines changed

CHANGELOG.md

Lines changed: 36 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -17,6 +17,42 @@
1717
under the License.
1818
-->
1919

20+
# v3.1.0
21+
22+
## New Features:
23+
24+
- Add `map_index` filter to TaskInstance API queries ([#55614](https://github.com/apache/airflow/pull/55614))
25+
- Add `has_import_errors` filter to Core API GET /dags endpoint ([#54563](https://github.com/apache/airflow/pull/54563))
26+
- Add `dag_version` filter to get_dag_runs endpoint ([#54882](https://github.com/apache/airflow/pull/54882))
27+
- Implement pattern search for event log endpoint ([#55114](https://github.com/apache/airflow/pull/55114))
28+
- Add asset-based filtering support to DAG API endpoint ([#54263](https://github.com/apache/airflow/pull/54263))
29+
- Add Greater Than and Less Than range filters to DagRuns and Task Instance list ([#54302](https://github.com/apache/airflow/pull/54302))
30+
- Add `try_number` as filter to task instances ([#54695](https://github.com/apache/airflow/pull/54695))
31+
- Add filters to Browse XComs endpoint ([#54049](https://github.com/apache/airflow/pull/54049))
32+
- Add Filtering by DAG Bundle Name and Version to API routes ([#54004](https://github.com/apache/airflow/pull/54004))
33+
- Add search filter for DAG runs by triggering user name ([#53652](https://github.com/apache/airflow/pull/53652))
34+
- Enable multi sorting (AIP-84) ([#53408](https://github.com/apache/airflow/pull/53408))
35+
- Add `run_on_latest_version` support for backfill and clear operations ([#52177](https://github.com/apache/airflow/pull/52177))
36+
- Add `run_id_pattern` search for Dag Run API ([#52437](https://github.com/apache/airflow/pull/52437))
37+
- Add tracking of triggering user to Dag runs ([#51738](https://github.com/apache/airflow/pull/51738))
38+
- Expose DAG parsing duration in the API ([#54752](https://github.com/apache/airflow/pull/54752))
39+
40+
## New API Endpoints:
41+
42+
- 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))
43+
- Add endpoint to watch dag run until finish ([#51920](https://github.com/apache/airflow/pull/51920))
44+
- Add TI bulk actions endpoint ([#50443](https://github.com/apache/airflow/pull/50443))
45+
- Add Keycloak Refresh Token Endpoint ([#51657](https://github.com/apache/airflow/pull/51657))
46+
47+
## Deprecations:
48+
49+
- Mark `DagDetailsResponse.concurrency` as deprecated ([#55150](https://github.com/apache/airflow/pull/55150))
50+
51+
## Bug Fixes:
52+
53+
- Fix dag import error modal pagination ([#55719](https://github.com/apache/airflow/pull/55719))
54+
55+
2056
# v3.0.2
2157

2258
## Major changes:

README.md

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -394,6 +394,7 @@ Class | Method | HTTP request | Description
394394
*DagRunApi* | [**get_dag_runs**](docs/DagRunApi.md#get_dag_runs) | **GET** /api/v2/dags/{dag_id}/dagRuns | Get Dag Runs
395395
*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
396396
*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
397+
*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.
397398
*DagRunApi* | [**patch_dag_run**](docs/DagRunApi.md#patch_dag_run) | **PATCH** /api/v2/dags/{dag_id}/dagRuns/{dag_run_id} | Patch Dag Run
398399
*DagRunApi* | [**trigger_dag_run**](docs/DagRunApi.md#trigger_dag_run) | **POST** /api/v2/dags/{dag_id}/dagRuns | Trigger Dag Run
399400
*DagSourceApi* | [**get_dag_source**](docs/DagSourceApi.md#get_dag_source) | **GET** /api/v2/dagSources/{dag_id} | Get Dag Source

airflow_client/client/__init__.py

Lines changed: 21 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -14,7 +14,7 @@
1414
""" # noqa: E501
1515

1616

17-
__version__ = "3.0.2"
17+
__version__ = "3.1.0"
1818

1919
# import apis into sdk package
2020
from airflow_client.client.api.asset_api import AssetApi
@@ -43,6 +43,7 @@
4343
from airflow_client.client.api.variable_api import VariableApi
4444
from airflow_client.client.api.version_api import VersionApi
4545
from airflow_client.client.api.x_com_api import XComApi
46+
from airflow_client.client.api.experimental_api import ExperimentalApi
4647

4748
# import ApiClient
4849
from airflow_client.client.api_response import ApiResponse
@@ -71,19 +72,26 @@
7172
from airflow_client.client.models.bulk_action_not_on_existence import BulkActionNotOnExistence
7273
from airflow_client.client.models.bulk_action_on_existence import BulkActionOnExistence
7374
from airflow_client.client.models.bulk_action_response import BulkActionResponse
75+
from airflow_client.client.models.bulk_body_bulk_task_instance_body import BulkBodyBulkTaskInstanceBody
76+
from airflow_client.client.models.bulk_body_bulk_task_instance_body_actions_inner import BulkBodyBulkTaskInstanceBodyActionsInner
7477
from airflow_client.client.models.bulk_body_connection_body import BulkBodyConnectionBody
7578
from airflow_client.client.models.bulk_body_connection_body_actions_inner import BulkBodyConnectionBodyActionsInner
7679
from airflow_client.client.models.bulk_body_pool_body import BulkBodyPoolBody
7780
from airflow_client.client.models.bulk_body_pool_body_actions_inner import BulkBodyPoolBodyActionsInner
7881
from airflow_client.client.models.bulk_body_variable_body import BulkBodyVariableBody
7982
from airflow_client.client.models.bulk_body_variable_body_actions_inner import BulkBodyVariableBodyActionsInner
83+
from airflow_client.client.models.bulk_create_action_bulk_task_instance_body import BulkCreateActionBulkTaskInstanceBody
8084
from airflow_client.client.models.bulk_create_action_connection_body import BulkCreateActionConnectionBody
8185
from airflow_client.client.models.bulk_create_action_pool_body import BulkCreateActionPoolBody
8286
from airflow_client.client.models.bulk_create_action_variable_body import BulkCreateActionVariableBody
87+
from airflow_client.client.models.bulk_delete_action_bulk_task_instance_body import BulkDeleteActionBulkTaskInstanceBody
88+
from airflow_client.client.models.bulk_delete_action_bulk_task_instance_body_entities_inner import BulkDeleteActionBulkTaskInstanceBodyEntitiesInner
8389
from airflow_client.client.models.bulk_delete_action_connection_body import BulkDeleteActionConnectionBody
8490
from airflow_client.client.models.bulk_delete_action_pool_body import BulkDeleteActionPoolBody
8591
from airflow_client.client.models.bulk_delete_action_variable_body import BulkDeleteActionVariableBody
8692
from airflow_client.client.models.bulk_response import BulkResponse
93+
from airflow_client.client.models.bulk_task_instance_body import BulkTaskInstanceBody
94+
from airflow_client.client.models.bulk_update_action_bulk_task_instance_body import BulkUpdateActionBulkTaskInstanceBody
8795
from airflow_client.client.models.bulk_update_action_connection_body import BulkUpdateActionConnectionBody
8896
from airflow_client.client.models.bulk_update_action_pool_body import BulkUpdateActionPoolBody
8997
from airflow_client.client.models.bulk_update_action_variable_body import BulkUpdateActionVariableBody
@@ -130,18 +138,27 @@
130138
from airflow_client.client.models.dry_run_backfill_response import DryRunBackfillResponse
131139
from airflow_client.client.models.event_log_collection_response import EventLogCollectionResponse
132140
from airflow_client.client.models.event_log_response import EventLogResponse
141+
from airflow_client.client.models.external_log_url_response import ExternalLogUrlResponse
142+
from airflow_client.client.models.external_view_response import ExternalViewResponse
133143
from airflow_client.client.models.extra_link_collection_response import ExtraLinkCollectionResponse
134144
from airflow_client.client.models.fast_api_app_response import FastAPIAppResponse
135145
from airflow_client.client.models.fast_api_root_middleware_response import FastAPIRootMiddlewareResponse
146+
from airflow_client.client.models.hitl_detail import HITLDetail
147+
from airflow_client.client.models.hitl_detail_collection import HITLDetailCollection
148+
from airflow_client.client.models.hitl_detail_response import HITLDetailResponse
149+
from airflow_client.client.models.hitl_user import HITLUser
136150
from airflow_client.client.models.http_exception_response import HTTPExceptionResponse
137151
from airflow_client.client.models.http_validation_error import HTTPValidationError
138152
from airflow_client.client.models.health_info_response import HealthInfoResponse
139153
from airflow_client.client.models.import_error_collection_response import ImportErrorCollectionResponse
140154
from airflow_client.client.models.import_error_response import ImportErrorResponse
141155
from airflow_client.client.models.job_collection_response import JobCollectionResponse
142156
from airflow_client.client.models.job_response import JobResponse
157+
from airflow_client.client.models.last_asset_event_response import LastAssetEventResponse
143158
from airflow_client.client.models.patch_task_instance_body import PatchTaskInstanceBody
144159
from airflow_client.client.models.plugin_collection_response import PluginCollectionResponse
160+
from airflow_client.client.models.plugin_import_error_collection_response import PluginImportErrorCollectionResponse
161+
from airflow_client.client.models.plugin_import_error_response import PluginImportErrorResponse
145162
from airflow_client.client.models.plugin_response import PluginResponse
146163
from airflow_client.client.models.pool_body import PoolBody
147164
from airflow_client.client.models.pool_collection_response import PoolCollectionResponse
@@ -151,6 +168,7 @@
151168
from airflow_client.client.models.provider_response import ProviderResponse
152169
from airflow_client.client.models.queued_event_collection_response import QueuedEventCollectionResponse
153170
from airflow_client.client.models.queued_event_response import QueuedEventResponse
171+
from airflow_client.client.models.react_app_response import ReactAppResponse
154172
from airflow_client.client.models.reprocess_behavior import ReprocessBehavior
155173
from airflow_client.client.models.response_clear_dag_run import ResponseClearDagRun
156174
from airflow_client.client.models.response_get_xcom_entry import ResponseGetXcomEntry
@@ -159,6 +177,7 @@
159177
from airflow_client.client.models.task_collection_response import TaskCollectionResponse
160178
from airflow_client.client.models.task_dependency_collection_response import TaskDependencyCollectionResponse
161179
from airflow_client.client.models.task_dependency_response import TaskDependencyResponse
180+
from airflow_client.client.models.task_inlet_asset_reference import TaskInletAssetReference
162181
from airflow_client.client.models.task_instance_collection_response import TaskInstanceCollectionResponse
163182
from airflow_client.client.models.task_instance_history_collection_response import TaskInstanceHistoryCollectionResponse
164183
from airflow_client.client.models.task_instance_history_response import TaskInstanceHistoryResponse
@@ -172,6 +191,7 @@
172191
from airflow_client.client.models.trigger_dag_run_post_body import TriggerDAGRunPostBody
173192
from airflow_client.client.models.trigger_response import TriggerResponse
174193
from airflow_client.client.models.triggerer_info_response import TriggererInfoResponse
194+
from airflow_client.client.models.update_hitl_detail_payload import UpdateHITLDetailPayload
175195
from airflow_client.client.models.validation_error import ValidationError
176196
from airflow_client.client.models.validation_error_loc_inner import ValidationErrorLocInner
177197
from airflow_client.client.models.value import Value

airflow_client/client/api/__init__.py

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -27,4 +27,5 @@
2727
from airflow_client.client.api.variable_api import VariableApi
2828
from airflow_client.client.api.version_api import VersionApi
2929
from airflow_client.client.api.x_com_api import XComApi
30+
from airflow_client.client.api.experimental_api import ExperimentalApi
3031

0 commit comments

Comments
 (0)