Movatterモバイル変換

[0]ホーム
URL:

Skip to content

Navigation Menu

Sign in
Appearance settings

Search code, repositories, users, issues, pull requests...

Provide feedback

We read every piece of feedback, and take your input very seriously.

Saved searches

Use saved searches to filter your results more quickly

 Sign up
Appearance settings

Commitd71f13a

Browse files
authored
Update Python Client to 3.0.2 (#136)
1 parentcd459a3 commitd71f13a

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
fromairflow_client.client.api.asset_apiimportAssetApi
@@ -68,7 +68,6 @@
6868
fromairflow_client.client.models.backfill_post_bodyimportBackfillPostBody
6969
fromairflow_client.client.models.backfill_responseimportBackfillResponse
7070
fromairflow_client.client.models.base_info_responseimportBaseInfoResponse
71-
fromairflow_client.client.models.bulk_actionimportBulkAction
7271
fromairflow_client.client.models.bulk_action_not_on_existenceimportBulkActionNotOnExistence
7372
fromairflow_client.client.models.bulk_action_on_existenceimportBulkActionOnExistence
7473
fromairflow_client.client.models.bulk_action_responseimportBulkActionResponse

‎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-
iflast_dag_run_stateisnotNone:
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
defget_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
fromairflow_client.client.models.backfill_post_bodyimportBackfillPostBody
2727
fromairflow_client.client.models.backfill_responseimportBackfillResponse
2828
fromairflow_client.client.models.base_info_responseimportBaseInfoResponse
29-
fromairflow_client.client.models.bulk_actionimportBulkAction
3029
fromairflow_client.client.models.bulk_action_not_on_existenceimportBulkActionNotOnExistence
3130
fromairflow_client.client.models.bulk_action_on_existenceimportBulkActionOnExistence
3231
fromairflow_client.client.models.bulk_action_responseimportBulkActionResponse

‎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
importre# noqa: F401
1818
importjson
1919

20-
frompydanticimportBaseModel,ConfigDict,Field
20+
frompydanticimportBaseModel,ConfigDict,Field,StrictStr,field_validator
2121
fromtypingimportAny,ClassVar,Dict,List,Optional
22-
fromairflow_client.client.models.bulk_actionimportBulkAction
2322
fromairflow_client.client.models.bulk_action_on_existenceimportBulkActionOnExistence
2423
fromairflow_client.client.models.connection_bodyimportConnectionBody
2524
fromtypingimportOptional,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+
defaction_validate_enum(cls,value):
38+
"""Validates the enum"""
39+
ifvaluenotinset(['create']):
40+
raiseValueError("must be one of enum values ('create')")
41+
returnvalue
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
importre# noqa: F401
1818
importjson
1919

20-
frompydanticimportBaseModel,ConfigDict,Field
20+
frompydanticimportBaseModel,ConfigDict,Field,StrictStr,field_validator
2121
fromtypingimportAny,ClassVar,Dict,List,Optional
22-
fromairflow_client.client.models.bulk_actionimportBulkAction
2322
fromairflow_client.client.models.bulk_action_on_existenceimportBulkActionOnExistence
2423
fromairflow_client.client.models.pool_bodyimportPoolBody
2524
fromtypingimportOptional,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+
defaction_validate_enum(cls,value):
38+
"""Validates the enum"""
39+
ifvaluenotinset(['create']):
40+
raiseValueError("must be one of enum values ('create')")
41+
returnvalue
42+
3743
model_config=ConfigDict(
3844
populate_by_name=True,
3945
validate_assignment=True,

0 commit comments

Comments
 (0)
[8]ページ先頭
©2009-2025 Movatter.jp