8000 Update Python Client to 3.0.2 (#136) · apache/airflow-client-python@d71f13a · GitHub
[go: up one dir, main page]
Skip to content

Commit d71f13a

Browse files
kaxilkaxil
authored
Update Python Client to 3.0.2 (#136)
1 parent cd459a3 commit d71f13a

File tree

51 files changed

+179
-212
lines changed
  • docs
  • pyproject.toml
  • spec
  • test
  • version.txt

    • 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