8000 Update Python Client to 3.0.2 · apache/airflow-client-python@9b3a3b1 · GitHub
[go: up one dir, main page]
Skip to content

Commit 9b3a3b1

Browse files
kaxilkaxil
committed
Update Python Client to 3.0.2
1 parent cd459a3 commit 9b3a3b1

File tree

51 files changed

+179
-212
lines changed

Some content is hidden

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

51 files changed

+179
-212
lines changed

‎CHANGELOG.md

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

20+
# v3.0.2
21+
22+
## Major changes:
23+
24+
- Add `owner_links` field to DAGDetailsResponse ([#50557](https://github.com/apache/airflow/pull/50557))
25+
- Allow non-string valid JSON values in Variable import ([#49844](https://github.com/apache/airflow/pull/49844))
26+
- Add `bundle_version` to DagRun response ([#49726](https://github.com/apache/airflow/pull/49726))
27+
- Use `NonNegativeInt` for `backfill_id` ([#49691](https://github.com/apache/airflow/pull/49691))
28+
- Rename operation IDs for task instance endpoints to include map indexes ([#49608](https://github.com/apache/airflow/pull/49608))
29+
- Remove filtering by last dag run state in patch dags endpoint ([#51176](https://github.com/apache/airflow/pull/51176))
30+
- Make `dag_run` nullable in Details page ([#50719](https://github.com/apache/airflow/pull/50719))
31+
32+
## Bug Fixes
33+
34+
- Fix OpenAPI schema for `get_log` API ([#50547](https://github.com/apache/airflow/pull/50547))
35+
- Fix bulk action annotation ([#50852](https://github.com/apache/airflow/pull/50852))
36+
- Fix `patch_task_instance` endpoint ([#50550](https://github.com/apache/airflow/pull/50550))
37+
2038
# v3.0.0
2139

2240
This is the first release of the **Airflow 3.0.0** Python client. It introduces compatibility with the new [Airflow 3.0 REST API](https://airflow.apache.org/docs/apache-airflow/3.0.0/stable-rest-api-ref.html), and includes several **breaking changes** and behavior updates.

‎airflow_client/client/__init__.py

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -14,7 +14,7 @@
1414
""" # noqa: E501
1515

1616

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

1919
# import apis into sdk package
2020
from airflow_client.client.api.asset_api import AssetApi
@@ -68,7 +68,6 @@
6868
from airflow_client.client.models.backfill_post_body import BackfillPostBody
6969
from airflow_client.client.models.backfill_response import BackfillResponse
7070
from airflow_client.client.models.base_info_response import BaseInfoResponse
71-
from airflow_client.client.models.bulk_action import BulkAction
7271
from airflow_client.client.models.bulk_action_not_on_existence import BulkActionNotOnExistence
7372
from airflow_client.client.models.bulk_action_on_existence import BulkActionOnExistence
7473
from airflow_client.client.models.bulk_action_response import BulkActionResponse

‎airflow_client/client/api/dag_api.py

Lines changed: 0 additions & 17 deletions
Original file line numberDiff line numberDiff line change
@@ -2097,7 +2097,6 @@ def patch_dags(
20972097
dag_id_pattern: Optional[StrictStr] = None,
20982098
exclude_stale: Optional[StrictBool] = None,
20992099
paused: Optional[StrictBool] = None,
2100-
last_dag_run_state: Optional[DagRunState] = None,
21012100
_request_timeout: Union[
21022101
None,
21032102
Annotated[StrictFloat, Field(gt=0)],
@@ -2135,8 +2134,6 @@ def patch_dags(
21352134
:type exclude_stale: bool
21362135
:param paused:
21372136
:type paused: bool
2138-
:param last_dag_run_state:
2139-
:type last_dag_run_state: DagRunState
21402137
:param _request_timeout: timeout setting for this request. If one
21412138
number provided, it will be total request
21422139
timeout. It can also be a pair (tuple) of
@@ -2170,7 +2167,6 @@ def patch_dags(
21702167
dag_id_pattern=dag_id_pattern,
21712168
exclude_stale=exclude_stale,
21722169
paused=paused,
2173-
last_dag_run_state=last_dag_run_state,
21742170
_request_auth=_request_auth,
21752171
_content_type=_content_type,
21762172
_headers=_headers,
@@ -2209,7 +2205,6 @@ def patch_dags_with_http_info(
22092205
dag_id_pattern: Optional[StrictStr] = None,
22102206
exclude_stale: Optional[StrictBool] = None,
22112207
paused: Optional[StrictBool] = None,
2212-
last_dag_run_state: Optional[DagRunState] = None,
22132208
_request_timeout: Union[
22142209
None,
22152210
Annotated[StrictFloat, Field(gt=0)],
@@ -2247,8 +2242,6 @@ def patch_dags_with_http_info(
22472242
:type exclude_stale: bool
22482243
:param paused:
22492244
:type paused: bool
2250-
:param last_dag_run_state:
2251-
:type last_dag_run_state: DagRunState
22522245
:param _request_timeout: timeout setting for this request. If one
22532246
number provided, it will be total request
22542247
timeout. It can also be a pair (tuple) of
@@ -2282,7 +2275,6 @@ def patch_dags_with_http_info(
22822275
dag_id_pattern=dag_id_pattern,
22832276
exclude_stale=exclude_stale,
22842277
paused=paused,
2285-
last_dag_run_state=last_dag_run_state,
22862278
_request_auth=_request_auth,
22872279
_content_type=_content_type,
22882280
_headers=_headers,
@@ -2321,7 +2313,6 @@ def patch_dags_without_preload_content(
23212313
dag_id_pattern: Optional[StrictStr] = None,
23222314
exclude_stale: Optional[StrictBool] = None,
23232315
paused: Optional[StrictBool] = None,
2324-
last_dag_run_state: Optional[DagRunState] = None,
23252316
_request_timeout: Union[
23262317
None,
23272318
Annotated[StrictFloat, Field(gt=0)],
@@ -2359,8 +2350,6 @@ def patch_dags_without_preload_content(
23592350
:type exclude_stale: bool
23602351
:param paused:
23612352
:type paused: bool
2362-
:param last_dag_run_state:
2363-
:type last_dag_run_state: DagRunState
23642353
:param _request_timeout: timeout setting for this request. If one
23652354
number provided, it will be total request
23662355
timeout. It can also be a pair (tuple) of
@@ -2394,7 +2383,6 @@ def patch_dags_without_preload_content(
23942383
dag_id_pattern=dag_id_pattern,
23952384
exclude_stale=exclude_stale,
23962385
paused=paused,
2397-
last_dag_run_state=last_dag_run_state,
23982386
_request_auth=_request_auth,
23992387
_content_type=_content_type,
24002388
_headers=_headers,
@@ -2428,7 +2416,6 @@ def _patch_dags_serialize(
24282416
dag_id_pattern,
24292417
exclude_stale,
24302418
paused,
2431-
last_dag_run_state,
24322419
_request_auth,
24332420
_content_type,
24342421
_headers,
@@ -2490,10 +2477,6 @@ def _patch_dags_serialize(
24902477

24912478
_query_params.append(('paused', paused))
24922479

2493-
if last_dag_run_state is not None:
2494-
2495-
_query_params.append(('last_dag_run_state', last_dag_run_state.value))
2496-
24972480
# process the header parameters
24982481
# process the form parameters
24992482
# process the body parameter

‎airflow_client/client/api/task_instance_api.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -726,7 +726,7 @@ def _get_log_serialize(
726726
_header_params['Accept'] = self.api_client.select_header_accept(
727727
[
728728
'application/json',
729-
'text/plain'
729+
'application/x-ndjson'
730730
]
731731
)
732732

‎airflow_client/client/api_client.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -90,7 +90,7 @@ def __init__(
9090
self.default_headers[header_name] = header_value
9191
self.cookie = cookie
9292
# Set default User-Agent.
93-
self.user_agent = 'OpenAPI-Generator/3.0.0/python'
93+
self.user_agent = 'OpenAPI-Generator/3.0.2/python'
9494
self.client_side_validation = configuration.client_side_validation
9595

9696
def __enter__(self):

‎airflow_client/client/configuration.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -510,7 +510,7 @@ def to_debug_report(self) -> str:
510510
"OS: {env}\n"\
511511
"Python Version: {pyversion}\n"\
512512
"Version of the API: 2\n"\
513-
"SDK Package Version: 3.0.0".\
513+
"SDK Package Version: 3.0.2".\
514514
format(env=sys.platform, pyversion=sys.version)
515515

516516
def get_host_settings(self) -> List[HostSetting]:

‎airflow_client/client/models/__init__.py

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -26,7 +26,6 @@
2626
from airflow_client.client.models.backfill_post_body import BackfillPostBody
2727
from airflow_client.client.models.backfill_response import BackfillResponse
2828
from airflow_client.client.models.base_info_response import BaseInfoResponse
29-
from airflow_client.client.models.bulk_action import BulkAction
3029
from airflow_client.client.models.bulk_action_not_on_existence import BulkActionNotOnExistence
3130
from airflow_client.client.models.bulk_action_on_existence import BulkActionOnExistence
3231
from airflow_client.client.models.bulk_action_response import BulkActionResponse

‎airflow_client/client/models/bulk_action.py

Lines changed: 0 additions & 38 deletions
This file was deleted.

‎airflow_client/client/models/bulk_create_action_connection_body.py

Lines changed: 9 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -17,9 +17,8 @@
1717
import re # noqa: F401
1818
import json
1919

20-
from pydantic import BaseModel, ConfigDict, Field
20+
from pydantic import BaseModel, ConfigDict, Field, StrictStr, field_validator
2121
from typing import Any, ClassVar, Dict, List, Optional
22-
from airflow_client.client.models.bulk_action import BulkAction
2322
from airflow_client.client.models.bulk_action_on_existence import BulkActionOnExistence
2423
from airflow_client.client.models.connection_body import ConnectionBody
2524
from typing import Optional, Set
@@ -29,11 +28,18 @@ class BulkCreateActionConnectionBody(BaseModel):
2928
"""
3029
BulkCreateActionConnectionBody
3130
""" # noqa: E501
32-
action: BulkAction = Field(description="The action to be performed on the entities.")
31+
action: StrictStr = Field(description="The action to be performed on the entities.")
3332
action_on_existence: Optional[BulkActionOnExistence] = None
3433
entities: List[ConnectionBody] = Field(description="A list of entities to be created.")
3534
__properties: ClassVar[List[str]] = ["action", "action_on_existence", "entities"]
3635

36+
@field_validator('action')
37+
def action_validate_enum(cls, value):
38+
"""Validates the enum"""
39+
if value not in set(['create']):
40+
raise ValueError("must be one of enum values ('create')")
41+
return value
42+
3743
model_config = ConfigDict(
3844
populate_by_name=True,
3945
validate_assignment=True,

‎airflow_client/client/models/bulk_create_action_pool_body.py

Lines changed: 9 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -17,9 +17,8 @@
1717
import re # noqa: F401
1818
import json
1919

20-
from pydantic import BaseModel, ConfigDict, Field
20+
from pydantic import BaseModel, ConfigDict, Field, StrictStr, field_validator
2121
from typing import Any, ClassVar, Dict, List, Optional
22-
from airflow_client.client.models.bulk_action import BulkAction
2322
from airflow_client.client.models.bulk_action_on_existence import BulkActionOnExistence
2423
from airflow_client.client.models.pool_body import PoolBody
2524
from typing import Optional, Set
@@ -29,11 +28,18 @@ class BulkCreateActionPoolBody(BaseModel):
2928
"""
3029
BulkCreateActionPoolBody
3130
""" # noqa: E501
32-
action: BulkAction = Field(description="The action to be performed on the entities.")
31+
action: StrictStr = Field(description="The action to be performed on the entities.")
3332
action_on_existence: Optional[BulkActionOnExistence] = None
3433
entities: List[PoolBody] = Field(description="A list of entities to be created.")
3534
__properties: ClassVar[List[str]] = ["action", "action_on_existence", "entities"]
3635

36+
@field_validator('action')
37+
def action_validate_enum(cls, value):
38+
"""Validates the enum"""
39+
if value not in set(['create']):
40+
raise ValueError("must be one of enum values ('create')")
41+
return value
42+
3743
model_config = ConfigDict(
3844
populate_by_name=True,
3945
validate_assignment=True,

0 commit comments

Comments
 (0)
0