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

Commit7a2ccc6

Browse files
authored
Update Python Client to 3.1.3rc1 (#139)
1 parent241405e commit7a2ccc6

File tree

58 files changed

+365
-728
lines changed

Some content is hidden

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

58 files changed

+365
-728
lines changed

‎CHANGELOG.md‎

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

20+
#v3.1.3
21+
22+
##New Features:
23+
24+
- Add query limit protection to prevent excessive database queries in DAG runs list endpoints ([#57450](https://github.com/apache/airflow/pull/57450))
25+
- Change`extra` field type to`dict[str, JsonValue]` for Asset, AssetAlias, and AssetEvent models ([#57352](https://github.com/apache/airflow/pull/57352))
26+
- Add`task_display_name` alias field to EventLogResponse for better task identification ([#55160](https://github.com/apache/airflow/pull/55160))
27+
- Add`is_favorite` field to DAGs list API to support user-specific DAG favorites ([#56341](https://github.com/apache/airflow/pull/56341))
28+
29+
##Improvements:
30+
31+
- Enhance API documentation for sorting functionality ([#56617](https://github.com/apache/airflow/pull/56617))
32+
- Improve API documentation for the`order_by` query parameter ([#55988](https://github.com/apache/airflow/pull/55988))
33+
- Remove deprecated`dagReports` API endpoint ([#56609](https://github.com/apache/airflow/pull/56609))
34+
35+
##Bug Fixes:
36+
37+
- Fix logout functionality in airflow-core to properly handle session termination ([#57990](https://github.com/apache/airflow/pull/57990))
38+
- Fix API endpoint for clearing task instances to properly support mapped task instances with specific map indexes ([#56346](https://github.com/apache/airflow/pull/56346))
39+
40+
2041
#v3.1.0
2142

2243
##New Features:

‎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.1.0"
17+
__version__="3.1.3"
1818

1919
# import apis into sdk package
2020
fromairflow_client.client.api.asset_apiimportAssetApi
@@ -23,7 +23,6 @@
2323
fromairflow_client.client.api.connection_apiimportConnectionApi
2424
fromairflow_client.client.api.dag_apiimportDAGApi
2525
fromairflow_client.client.api.dag_parsing_apiimportDAGParsingApi
26-
fromairflow_client.client.api.dag_report_apiimportDagReportApi
2726
fromairflow_client.client.api.dag_run_apiimportDagRunApi
2827
fromairflow_client.client.api.dag_source_apiimportDagSourceApi
2928
fromairflow_client.client.api.dag_stats_apiimportDagStatsApi

‎airflow_client/client/api/__init__.py‎

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -7,7 +7,6 @@
77
fromairflow_client.client.api.connection_apiimportConnectionApi
88
fromairflow_client.client.api.dag_apiimportDAGApi
99
fromairflow_client.client.api.dag_parsing_apiimportDAGParsingApi
10-
fromairflow_client.client.api.dag_report_apiimportDagReportApi
1110
fromairflow_client.client.api.dag_run_apiimportDagRunApi
1211
fromairflow_client.client.api.dag_source_apiimportDagSourceApi
1312
fromairflow_client.client.api.dag_stats_apiimportDagStatsApi

‎airflow_client/client/api/asset_api.py‎

Lines changed: 18 additions & 18 deletions
Original file line numberDiff line numberDiff line change
@@ -1780,7 +1780,7 @@ def get_asset_aliases(
17801780
limit:Optional[Annotated[int,Field(strict=True,ge=0)]]=None,
17811781
offset:Optional[Annotated[int,Field(strict=True,ge=0)]]=None,
17821782
name_pattern:Annotated[Optional[StrictStr],Field(description="SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). Regular expressions are **not** supported.")]=None,
1783-
order_by:Optional[List[StrictStr]]=None,
1783+
order_by:Annotated[Optional[List[StrictStr]],Field(description="Attributes to order by, multi criteria sort is supported. Prefix with `-` for descending order. Supported attributes: `id, name`")]=None,
17841784
_request_timeout:Union[
17851785
None,
17861786
Annotated[StrictFloat,Field(gt=0)],
@@ -1804,7 +1804,7 @@ def get_asset_aliases(
18041804
:type offset: int
18051805
:param name_pattern: SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). Regular expressions are **not** supported.
18061806
:type name_pattern: str
1807-
:param order_by:
1807+
:param order_by: Attributes to order by, multi criteria sort is supported. Prefix with `-` for descending order. Supported attributes: `id, name`
18081808
:type order_by: List[str]
18091809
:param _request_timeout: timeout setting for this request. If one
18101810
number provided, it will be total request
@@ -1863,7 +1863,7 @@ def get_asset_aliases_with_http_info(
18631863
limit:Optional[Annotated[int,Field(strict=True,ge=0)]]=None,
18641864
offset:Optional[Annotated[int,Field(strict=True,ge=0)]]=None,
18651865
name_pattern:Annotated[Optional[StrictStr],Field(description="SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). Regular expressions are **not** supported.")]=None,
1866-
order_by:Optional[List[StrictStr]]=None,
1866+
order_by:Annotated[Optional[List[StrictStr]],Field(description="Attributes to order by, multi criteria sort is supported. Prefix with `-` for descending order. Supported attributes: `id, name`")]=None,
18671867
_request_timeout:Union[
18681868
None,
18691869
Annotated[StrictFloat,Field(gt=0)],
@@ -1887,7 +1887,7 @@ def get_asset_aliases_with_http_info(
18871887
:type offset: int
18881888
:param name_pattern: SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). Regular expressions are **not** supported.
18891889
:type name_pattern: str
1890-
:param order_by:
1890+
:param order_by: Attributes to order by, multi criteria sort is supported. Prefix with `-` for descending order. Supported attributes: `id, name`
18911891
:type order_by: List[str]
18921892
:param _request_timeout: timeout setting for this request. If one
18931893
number provided, it will be total request
@@ -1946,7 +1946,7 @@ def get_asset_aliases_without_preload_content(
19461946
limit:Optional[Annotated[int,Field(strict=True,ge=0)]]=None,
19471947
offset:Optional[Annotated[int,Field(strict=True,ge=0)]]=None,
19481948
name_pattern:Annotated[Optional[StrictStr],Field(description="SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). Regular expressions are **not** supported.")]=None,
1949-
order_by:Optional[List[StrictStr]]=None,
1949+
order_by:Annotated[Optional[List[StrictStr]],Field(description="Attributes to order by, multi criteria sort is supported. Prefix with `-` for descending order. Supported attributes: `id, name`")]=None,
19501950
_request_timeout:Union[
19511951
None,
19521952
Annotated[StrictFloat,Field(gt=0)],
@@ -1970,7 +1970,7 @@ def get_asset_aliases_without_preload_content(
19701970
:type offset: int
19711971
:param name_pattern: SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). Regular expressions are **not** supported.
19721972
:type name_pattern: str
1973-
:param order_by:
1973+
:param order_by: Attributes to order by, multi criteria sort is supported. Prefix with `-` for descending order. Supported attributes: `id, name`
19741974
:type order_by: List[str]
19751975
:param _request_timeout: timeout setting for this request. If one
19761976
number provided, it will be total request
@@ -2107,7 +2107,7 @@ def get_asset_events(
21072107
self,
21082108
limit:Optional[Annotated[int,Field(strict=True,ge=0)]]=None,
21092109
offset:Optional[Annotated[int,Field(strict=True,ge=0)]]=None,
2110-
order_by:Optional[List[StrictStr]]=None,
2110+
order_by:Annotated[Optional[List[StrictStr]],Field(description="Attributes to order by, multi criteria sort is supported. Prefix with `-` for descending order. Supported attributes: `source_task_id, source_dag_id, source_run_id, source_map_index, timestamp`")]=None,
21112111
asset_id:Optional[StrictInt]=None,
21122112
source_dag_id:Optional[StrictStr]=None,
21132113
source_task_id:Optional[StrictStr]=None,
@@ -2138,7 +2138,7 @@ def get_asset_events(
21382138
:type limit: int
21392139
:param offset:
21402140
:type offset: int
2141-
:param order_by:
2141+
:param order_by: Attributes to order by, multi criteria sort is supported. Prefix with `-` for descending order. Supported attributes: `source_task_id, source_dag_id, source_run_id, source_map_index, timestamp`
21422142
:type order_by: List[str]
21432143
:param asset_id:
21442144
:type asset_id: int
@@ -2222,7 +2222,7 @@ def get_asset_events_with_http_info(
22222222
self,
22232223
limit:Optional[Annotated[int,Field(strict=True,ge=0)]]=None,
22242224
offset:Optional[Annotated[int,Field(strict=True,ge=0)]]=None,
2225-
order_by:Optional[List[StrictStr]]=None,
2225+
order_by:Annotated[Optional[List[StrictStr]],Field(description="Attributes to order by, multi criteria sort is supported. Prefix with `-` for descending order. Supported attributes: `source_task_id, source_dag_id, source_run_id, source_map_index, timestamp`")]=None,
22262226
asset_id:Optional[StrictInt]=None,
22272227
source_dag_id:Optional[StrictStr]=None,
22282228
source_task_id:Optional[StrictStr]=None,
@@ -2253,7 +2253,7 @@ def get_asset_events_with_http_info(
22532253
:type limit: int
22542254
:param offset:
22552255
:type offset: int
2256-
:param order_by:
2256+
:param order_by: Attributes to order by, multi criteria sort is supported. Prefix with `-` for descending order. Supported attributes: `source_task_id, source_dag_id, source_run_id, source_map_index, timestamp`
22572257
:type order_by: List[str]
22582258
:param asset_id:
22592259
:type asset_id: int
@@ -2337,7 +2337,7 @@ def get_asset_events_without_preload_content(
23372337
self,
23382338
limit:Optional[Annotated[int,Field(strict=True,ge=0)]]=None,
23392339
offset:Optional[Annotated[int,Field(strict=True,ge=0)]]=None,
2340-
order_by:Optional[List[StrictStr]]=None,
2340+
order_by:Annotated[Optional[List[StrictStr]],Field(description="Attributes to order by, multi criteria sort is supported. Prefix with `-` for descending order. Supported attributes: `source_task_id, source_dag_id, source_run_id, source_map_index, timestamp`")]=None,
23412341
asset_id:Optional[StrictInt]=None,
23422342
source_dag_id:Optional[StrictStr]=None,
23432343
source_task_id:Optional[StrictStr]=None,
@@ -2368,7 +2368,7 @@ def get_asset_events_without_preload_content(
23682368
:type limit: int
23692369
:param offset:
23702370
:type offset: int
2371-
:param order_by:
2371+
:param order_by: Attributes to order by, multi criteria sort is supported. Prefix with `-` for descending order. Supported attributes: `source_task_id, source_dag_id, source_run_id, source_map_index, timestamp`
23722372
:type order_by: List[str]
23732373
:param asset_id:
23742374
:type asset_id: int
@@ -2902,7 +2902,7 @@ def get_assets(
29022902
uri_pattern:Annotated[Optional[StrictStr],Field(description="SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). Regular expressions are **not** supported.")]=None,
29032903
dag_ids:Optional[List[StrictStr]]=None,
29042904
only_active:Optional[StrictBool]=None,
2905-
order_by:Optional[List[StrictStr]]=None,
2905+
order_by:Annotated[Optional[List[StrictStr]],Field(description="Attributes to order by, multi criteria sort is supported. Prefix with `-` for descending order. Supported attributes: `id, name, uri, created_at, updated_at`")]=None,
29062906
_request_timeout:Union[
29072907
None,
29082908
Annotated[StrictFloat,Field(gt=0)],
@@ -2932,7 +2932,7 @@ def get_assets(
29322932
:type dag_ids: List[str]
29332933
:param only_active:
29342934
:type only_active: bool
2935-
:param order_by:
2935+
:param order_by: Attributes to order by, multi criteria sort is supported. Prefix with `-` for descending order. Supported attributes: `id, name, uri, created_at, updated_at`
29362936
:type order_by: List[str]
29372937
:param _request_timeout: timeout setting for this request. If one
29382938
number provided, it will be total request
@@ -2997,7 +2997,7 @@ def get_assets_with_http_info(
29972997
uri_pattern:Annotated[Optional[StrictStr],Field(description="SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). Regular expressions are **not** supported.")]=None,
29982998
dag_ids:Optional[List[StrictStr]]=None,
29992999
only_active:Optional[StrictBool]=None,
3000-
order_by:Optional[List[StrictStr]]=None,
3000+
order_by:Annotated[Optional[List[StrictStr]],Field(description="Attributes to order by, multi criteria sort is supported. Prefix with `-` for descending order. Supported attributes: `id, name, uri, created_at, updated_at`")]=None,
30013001
_request_timeout:Union[
30023002
None,
30033003
Annotated[StrictFloat,Field(gt=0)],
@@ -3027,7 +3027,7 @@ def get_assets_with_http_info(
30273027
:type dag_ids: List[str]
30283028
:param only_active:
30293029
:type only_active: bool
3030-
:param order_by:
3030+
:param order_by: Attributes to order by, multi criteria sort is supported. Prefix with `-` for descending order. Supported attributes: `id, name, uri, created_at, updated_at`
30313031
:type order_by: List[str]
30323032
:param _request_timeout: timeout setting for this request. If one
30333033
number provided, it will be total request
@@ -3092,7 +3092,7 @@ def get_assets_without_preload_content(
30923092
uri_pattern:Annotated[Optional[StrictStr],Field(description="SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). Regular expressions are **not** supported.")]=None,
30933093
dag_ids:Optional[List[StrictStr]]=None,
30943094
only_active:Optional[StrictBool]=None,
3095-
order_by:Optional[List[StrictStr]]=None,
3095+
order_by:Annotated[Optional[List[StrictStr]],Field(description="Attributes to order by, multi criteria sort is supported. Prefix with `-` for descending order. Supported attributes: `id, name, uri, created_at, updated_at`")]=None,
30963096
_request_timeout:Union[
30973097
None,
30983098
Annotated[StrictFloat,Field(gt=0)],
@@ -3122,7 +3122,7 @@ def get_assets_without_preload_content(
31223122
:type dag_ids: List[str]
31233123
:param only_active:
31243124
:type only_active: bool
3125-
:param order_by:
3125+
:param order_by: Attributes to order by, multi criteria sort is supported. Prefix with `-` for descending order. Supported attributes: `id, name, uri, created_at, updated_at`
31263126
:type order_by: List[str]
31273127
:param _request_timeout: timeout setting for this request. If one
31283128
number provided, it will be total request

‎airflow_client/client/api/backfill_api.py‎

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -1167,7 +1167,7 @@ def list_backfills(
11671167
dag_id:StrictStr,
11681168
limit:Optional[Annotated[int,Field(strict=True,ge=0)]]=None,
11691169
offset:Optional[Annotated[int,Field(strict=True,ge=0)]]=None,
1170-
order_by:Optional[List[StrictStr]]=None,
1170+
order_by:Annotated[Optional[List[StrictStr]],Field(description="Attributes to order by, multi criteria sort is supported. Prefix with `-` for descending order. Supported attributes: `id`")]=None,
11711171
_request_timeout:Union[
11721172
None,
11731173
Annotated[StrictFloat,Field(gt=0)],
@@ -1190,7 +1190,7 @@ def list_backfills(
11901190
:type limit: int
11911191
:param offset:
11921192
:type offset: int
1193-
:param order_by:
1193+
:param order_by: Attributes to order by, multi criteria sort is supported. Prefix with `-` for descending order. Supported attributes: `id`
11941194
:type order_by: List[str]
11951195
:param _request_timeout: timeout setting for this request. If one
11961196
number provided, it will be total request
@@ -1248,7 +1248,7 @@ def list_backfills_with_http_info(
12481248
dag_id:StrictStr,
12491249
limit:Optional[Annotated[int,Field(strict=True,ge=0)]]=None,
12501250
offset:Optional[Annotated[int,Field(strict=True,ge=0)]]=None,
1251-
order_by:Optional[List[StrictStr]]=None,
1251+
order_by:Annotated[Optional[List[StrictStr]],Field(description="Attributes to order by, multi criteria sort is supported. Prefix with `-` for descending order. Supported attributes: `id`")]=None,
12521252
_request_timeout:Union[
12531253
None,
12541254
Annotated[StrictFloat,Field(gt=0)],
@@ -1271,7 +1271,7 @@ def list_backfills_with_http_info(
12711271
:type limit: int
12721272
:param offset:
12731273
:type offset: int
1274-
:param order_by:
1274+
:param order_by: Attributes to order by, multi criteria sort is supported. Prefix with `-` for descending order. Supported attributes: `id`
12751275
:type order_by: List[str]
12761276
:param _request_timeout: timeout setting for this request. If one
12771277
number provided, it will be total request
@@ -1329,7 +1329,7 @@ def list_backfills_without_preload_content(
13291329
dag_id:StrictStr,
13301330
limit:Optional[Annotated[int,Field(strict=True,ge=0)]]=None,
13311331
offset:Optional[Annotated[int,Field(strict=True,ge=0)]]=None,
1332-
order_by:Optional[List[StrictStr]]=None,
1332+
order_by:Annotated[Optional[List[StrictStr]],Field(description="Attributes to order by, multi criteria sort is supported. Prefix with `-` for descending order. Supported attributes: `id`")]=None,
13331333
_request_timeout:Union[
13341334
None,
13351335
Annotated[StrictFloat,Field(gt=0)],
@@ -1352,7 +1352,7 @@ def list_backfills_without_preload_content(
13521352
:type limit: int
13531353
:param offset:
13541354
:type offset: int
1355-
:param order_by:
1355+
:param order_by: Attributes to order by, multi criteria sort is supported. Prefix with `-` for descending order. Supported attributes: `id`
13561356
:type order_by: List[str]
13571357
:param _request_timeout: timeout setting for this request. If one
13581358
number provided, it will be total request

0 commit comments

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