From aee724c8275b2b1b0c1f45644954e6d0b06e49e4 Mon Sep 17 00:00:00 2001 From: vatsrahul1001 Date: Wed, 25 Mar 2026 19:25:26 +0530 Subject: [PATCH 1/2] Update Python Client to 3.1.8rc1 --- CHANGELOG.md | 9 +++++ airflow_client/client/__init__.py | 26 +++++++------- airflow_client/client/api/asset_api.py | 9 +---- airflow_client/client/api/backfill_api.py | 3 +- airflow_client/client/api/config_api.py | 3 +- airflow_client/client/api/connection_api.py | 3 +- airflow_client/client/api/dag_api.py | 3 +- airflow_client/client/api/dag_parsing_api.py | 3 +- airflow_client/client/api/dag_run_api.py | 11 +++--- airflow_client/client/api/dag_source_api.py | 3 +- airflow_client/client/api/dag_stats_api.py | 3 +- airflow_client/client/api/dag_version_api.py | 3 +- airflow_client/client/api/dag_warning_api.py | 3 +- airflow_client/client/api/event_log_api.py | 3 +- airflow_client/client/api/experimental_api.py | 11 +++--- airflow_client/client/api/extra_links_api.py | 3 +- airflow_client/client/api/import_error_api.py | 3 +- airflow_client/client/api/job_api.py | 3 +- airflow_client/client/api/login_api.py | 3 +- airflow_client/client/api/monitor_api.py | 3 +- airflow_client/client/api/plugin_api.py | 3 +- airflow_client/client/api/pool_api.py | 3 +- airflow_client/client/api/provider_api.py | 3 +- airflow_client/client/api/task_api.py | 3 +- .../client/api/task_instance_api.py | 9 +++-- airflow_client/client/api/variable_api.py | 3 +- airflow_client/client/api/version_api.py | 3 +- airflow_client/client/api/x_com_api.py | 3 +- airflow_client/client/api_client.py | 9 ++--- airflow_client/client/configuration.py | 10 +++--- airflow_client/client/exceptions.py | 3 +- airflow_client/client/models/__init__.py | 12 +++---- ...body_actions_inner.py => actions_inner.py} | 16 ++++----- ...ody_actions_inner.py => actions_inner1.py} | 16 ++++----- ...ody_actions_inner.py => actions_inner2.py} | 16 ++++----- ...ody_actions_inner.py => actions_inner3.py} | 16 ++++----- .../bulk_body_bulk_task_instance_body.py | 6 ++-- .../models/bulk_body_connection_body.py | 6 ++-- .../client/models/bulk_body_pool_body.py | 6 ++-- .../client/models/bulk_body_variable_body.py | 6 ++-- ...k_delete_action_bulk_task_instance_body.py | 6 ++-- .../bulk_delete_action_connection_body.py | 6 ++-- .../models/bulk_delete_action_pool_body.py | 6 ++-- .../bulk_delete_action_variable_body.py | 6 ++-- ...dy_entities_inner.py => entities_inner.py} | 12 +++---- ...n_error_loc_inner.py => location_inner.py} | 12 +++---- airflow_client/client/models/pool_body.py | 4 +-- .../client/models/pool_patch_body.py | 5 +-- airflow_client/client/models/pool_response.py | 5 +-- .../client/models/validation_error.py | 6 ++-- .../client/models/x_com_response.py | 4 ++- .../client/models/x_com_response_native.py | 4 ++- .../client/models/x_com_response_string.py | 4 ++- docs/ActionsInner.md | 32 +++++++++++++++++ docs/ActionsInner1.md | 32 +++++++++++++++++ docs/ActionsInner2.md | 32 +++++++++++++++++ docs/ActionsInner3.md | 32 +++++++++++++++++ docs/AssetApi.md | 2 -- docs/BulkBodyBulkTaskInstanceBody.md | 2 +- ...ulkBodyBulkTaskInstanceBodyActionsInner.md | 32 ----------------- docs/BulkBodyConnectionBody.md | 2 +- docs/BulkBodyConnectionBodyActionsInner.md | 32 ----------------- docs/BulkBodyPoolBody.md | 2 +- docs/BulkBodyPoolBodyActionsInner.md | 32 ----------------- docs/BulkBodyVariableBody.md | 2 +- docs/BulkBodyVariableBodyActionsInner.md | 32 ----------------- docs/BulkDeleteActionBulkTaskInstanceBody.md | 2 +- ...ActionBulkTaskInstanceBodyEntitiesInner.md | 36 ------------------- docs/BulkDeleteActionConnectionBody.md | 2 +- docs/BulkDeleteActionPoolBody.md | 2 +- docs/BulkDeleteActionVariableBody.md | 2 +- docs/EntitiesInner.md | 36 +++++++++++++++++++ docs/LocationInner.md | 28 +++++++++++++++ docs/PoolBody.md | 2 +- docs/PoolPatchBody.md | 2 +- docs/PoolResponse.md | 2 +- docs/ResponseGetXcomEntry.md | 1 + docs/ValidationError.md | 2 +- docs/ValidationErrorLocInner.md | 28 --------------- docs/XComResponse.md | 1 + docs/XComResponseNative.md | 1 + docs/XComResponseString.md | 1 + pyproject.toml | 10 +++++- spec/v2.yaml | 33 ++++++++++------- ...actions_inner.py => test_actions_inner.py} | 22 ++++++------ ...ctions_inner.py => test_actions_inner1.py} | 22 ++++++------ ...ctions_inner.py => test_actions_inner2.py} | 22 ++++++------ ...ctions_inner.py => test_actions_inner3.py} | 22 ++++++------ test/test_bulk_create_action_pool_body.py | 4 +-- test/test_bulk_update_action_pool_body.py | 4 +-- ...tities_inner.py => test_entities_inner.py} | 22 ++++++------ ...or_loc_inner.py => test_location_inner.py} | 22 ++++++------ test/test_pool_body.py | 4 +-- test/test_pool_collection_response.py | 4 +-- test/test_pool_patch_body.py | 2 +- test/test_pool_response.py | 4 +-- test/test_response_get_xcom_entry.py | 2 ++ test/test_x_com_collection_response.py | 2 ++ test/test_x_com_response.py | 2 ++ test/test_x_com_response_native.py | 2 ++ test/test_x_com_response_string.py | 2 ++ version.txt | 2 +- 102 files changed, 489 insertions(+), 477 deletions(-) rename airflow_client/client/models/{bulk_body_bulk_task_instance_body_actions_inner.py => actions_inner.py} (82%) rename airflow_client/client/models/{bulk_body_connection_body_actions_inner.py => actions_inner1.py} (83%) rename airflow_client/client/models/{bulk_body_pool_body_actions_inner.py => actions_inner2.py} (85%) rename airflow_client/client/models/{bulk_body_variable_body_actions_inner.py => actions_inner3.py} (84%) rename airflow_client/client/models/{bulk_delete_action_bulk_task_instance_body_entities_inner.py => entities_inner.py} (88%) rename airflow_client/client/models/{validation_error_loc_inner.py => location_inner.py} (91%) create mode 100644 docs/ActionsInner.md create mode 100644 docs/ActionsInner1.md create mode 100644 docs/ActionsInner2.md create mode 100644 docs/ActionsInner3.md delete mode 100644 docs/BulkBodyBulkTaskInstanceBodyActionsInner.md delete mode 100644 docs/BulkBodyConnectionBodyActionsInner.md delete mode 100644 docs/BulkBodyPoolBodyActionsInner.md delete mode 100644 docs/BulkBodyVariableBodyActionsInner.md delete mode 100644 docs/BulkDeleteActionBulkTaskInstanceBodyEntitiesInner.md create mode 100644 docs/EntitiesInner.md create mode 100644 docs/LocationInner.md delete mode 100644 docs/ValidationErrorLocInner.md rename test/{test_bulk_body_pool_body_actions_inner.py => test_actions_inner.py} (67%) rename test/{test_bulk_body_variable_body_actions_inner.py => test_actions_inner1.py} (65%) rename test/{test_bulk_body_connection_body_actions_inner.py => test_actions_inner2.py} (65%) rename test/{test_bulk_body_bulk_task_instance_body_actions_inner.py => test_actions_inner3.py} (63%) rename test/{test_bulk_delete_action_bulk_task_instance_body_entities_inner.py => test_entities_inner.py} (60%) rename test/{test_validation_error_loc_inner.py => test_location_inner.py} (63%) diff --git a/CHANGELOG.md b/CHANGELOG.md index b5e9aa85..8ea0d3d5 100644 --- a/CHANGELOG.md +++ b/CHANGELOG.md @@ -17,6 +17,15 @@ under the License. --> +# v3.1.8 + +## Bug Fixes: + + - Fix: 404 queued asset events from API server logs ([#62934](https://github.com/apache/airflow/pull/62934)) + - Fix executor slots showing negative infinity ([#61140](https://github.com/apache/airflow/pull/61140)) + - Fix Pool API slots validation ([#61071](https://github.com/apache/airflow/pull/61071)) + - Add ``run_after`` alias to ``XComResponse`` for backward compatibility ([#61443](https://github.com/apache/airflow/pull/61443)) + # v3.1.6 ## Bug Fixes: diff --git a/airflow_client/client/__init__.py b/airflow_client/client/__init__.py index d3bc15d4..c2913a48 100644 --- a/airflow_client/client/__init__.py +++ b/airflow_client/client/__init__.py @@ -14,7 +14,7 @@ """ # noqa: E501 -__version__ = "3.1.6" +__version__ = "3.1.8" # Define package exports __all__ = [ @@ -53,6 +53,10 @@ "ApiKeyError", "ApiAttributeError", "ApiException", + "ActionsInner", + "ActionsInner1", + "ActionsInner2", + "ActionsInner3", "AppBuilderMenuItemResponse", "AppBuilderViewResponse", "AssetAliasCollectionResponse", @@ -69,19 +73,14 @@ "BulkActionOnExistence", "BulkActionResponse", "BulkBodyBulkTaskInstanceBody", - "BulkBodyBulkTaskInstanceBodyActionsInner", "BulkBodyConnectionBody", - "BulkBodyConnectionBodyActionsInner", "BulkBodyPoolBody", - "BulkBodyPoolBodyActionsInner", "BulkBodyVariableBody", - "BulkBodyVariableBodyActionsInner", "BulkCreateActionBulkTaskInstanceBody", "BulkCreateActionConnectionBody", "BulkCreateActionPoolBody", "BulkCreateActionVariableBody", "BulkDeleteActionBulkTaskInstanceBody", - "BulkDeleteActionBulkTaskInstanceBodyEntitiesInner", "BulkDeleteActionConnectionBody", "BulkDeleteActionPoolBody", "BulkDeleteActionVariableBody", @@ -132,6 +131,7 @@ "Detail", "DryRunBackfillCollectionResponse", "DryRunBackfillResponse", + "EntitiesInner", "EventLogCollectionResponse", "EventLogResponse", "ExternalLogUrlResponse", @@ -151,6 +151,7 @@ "JobCollectionResponse", "JobResponse", "LastAssetEventResponse", + "LocationInner", "PatchTaskInstanceBody", "PluginCollectionResponse", "PluginImportErrorCollectionResponse", @@ -189,7 +190,6 @@ "TriggererInfoResponse", "UpdateHITLDetailPayload", "ValidationError", - "ValidationErrorLocInner", "Value", "VariableBody", "VariableCollectionResponse", @@ -243,6 +243,10 @@ from airflow_client.client.exceptions import ApiException as ApiException # import models into sdk package +from airflow_client.client.models.actions_inner import ActionsInner as ActionsInner +from airflow_client.client.models.actions_inner1 import ActionsInner1 as ActionsInner1 +from airflow_client.client.models.actions_inner2 import ActionsInner2 as ActionsInner2 +from airflow_client.client.models.actions_inner3 import ActionsInner3 as ActionsInner3 from airflow_client.client.models.app_builder_menu_item_response import AppBuilderMenuItemResponse as AppBuilderMenuItemResponse from airflow_client.client.models.app_builder_view_response import AppBuilderViewResponse as AppBuilderViewResponse from airflow_client.client.models.asset_alias_collection_response import AssetAliasCollectionResponse as AssetAliasCollectionResponse @@ -259,19 +263,14 @@ from airflow_client.client.models.bulk_action_on_existence import BulkActionOnExistence as BulkActionOnExistence from airflow_client.client.models.bulk_action_response import BulkActionResponse as BulkActionResponse from airflow_client.client.models.bulk_body_bulk_task_instance_body import BulkBodyBulkTaskInstanceBody as BulkBodyBulkTaskInstanceBody -from airflow_client.client.models.bulk_body_bulk_task_instance_body_actions_inner import BulkBodyBulkTaskInstanceBodyActionsInner as BulkBodyBulkTaskInstanceBodyActionsInner from airflow_client.client.models.bulk_body_connection_body import BulkBodyConnectionBody as BulkBodyConnectionBody -from airflow_client.client.models.bulk_body_connection_body_actions_inner import BulkBodyConnectionBodyActionsInner as BulkBodyConnectionBodyActionsInner from airflow_client.client.models.bulk_body_pool_body import BulkBodyPoolBody as BulkBodyPoolBody -from airflow_client.client.models.bulk_body_pool_body_actions_inner import BulkBodyPoolBodyActionsInner as BulkBodyPoolBodyActionsInner from airflow_client.client.models.bulk_body_variable_body import BulkBodyVariableBody as BulkBodyVariableBody -from airflow_client.client.models.bulk_body_variable_body_actions_inner import BulkBodyVariableBodyActionsInner as BulkBodyVariableBodyActionsInner from airflow_client.client.models.bulk_create_action_bulk_task_instance_body import BulkCreateActionBulkTaskInstanceBody as BulkCreateActionBulkTaskInstanceBody from airflow_client.client.models.bulk_create_action_connection_body import BulkCreateActionConnectionBody as BulkCreateActionConnectionBody from airflow_client.client.models.bulk_create_action_pool_body import BulkCreateActionPoolBody as BulkCreateActionPoolBody from airflow_client.client.models.bulk_create_action_variable_body import BulkCreateActionVariableBody as BulkCreateActionVariableBody from airflow_client.client.models.bulk_delete_action_bulk_task_instance_body import BulkDeleteActionBulkTaskInstanceBody as BulkDeleteActionBulkTaskInstanceBody -from airflow_client.client.models.bulk_delete_action_bulk_task_instance_body_entities_inner import BulkDeleteActionBulkTaskInstanceBodyEntitiesInner as BulkDeleteActionBulkTaskInstanceBodyEntitiesInner from airflow_client.client.models.bulk_delete_action_connection_body import BulkDeleteActionConnectionBody as BulkDeleteActionConnectionBody from airflow_client.client.models.bulk_delete_action_pool_body import BulkDeleteActionPoolBody as BulkDeleteActionPoolBody from airflow_client.client.models.bulk_delete_action_variable_body import BulkDeleteActionVariableBody as BulkDeleteActionVariableBody @@ -322,6 +321,7 @@ from airflow_client.client.models.detail import Detail as Detail from airflow_client.client.models.dry_run_backfill_collection_response import DryRunBackfillCollectionResponse as DryRunBackfillCollectionResponse from airflow_client.client.models.dry_run_backfill_response import DryRunBackfillResponse as DryRunBackfillResponse +from airflow_client.client.models.entities_inner import EntitiesInner as EntitiesInner from airflow_client.client.models.event_log_collection_response import EventLogCollectionResponse as EventLogCollectionResponse from airflow_client.client.models.event_log_response import EventLogResponse as EventLogResponse from airflow_client.client.models.external_log_url_response import ExternalLogUrlResponse as ExternalLogUrlResponse @@ -341,6 +341,7 @@ from airflow_client.client.models.job_collection_response import JobCollectionResponse as JobCollectionResponse from airflow_client.client.models.job_response import JobResponse as JobResponse from airflow_client.client.models.last_asset_event_response import LastAssetEventResponse as LastAssetEventResponse +from airflow_client.client.models.location_inner import LocationInner as LocationInner from airflow_client.client.models.patch_task_instance_body import PatchTaskInstanceBody as PatchTaskInstanceBody from airflow_client.client.models.plugin_collection_response import PluginCollectionResponse as PluginCollectionResponse from airflow_client.client.models.plugin_import_error_collection_response import PluginImportErrorCollectionResponse as PluginImportErrorCollectionResponse @@ -379,7 +380,6 @@ from airflow_client.client.models.triggerer_info_response import TriggererInfoResponse as TriggererInfoResponse from airflow_client.client.models.update_hitl_detail_payload import UpdateHITLDetailPayload as UpdateHITLDetailPayload from airflow_client.client.models.validation_error import ValidationError as ValidationError -from airflow_client.client.models.validation_error_loc_inner import ValidationErrorLocInner as ValidationErrorLocInner from airflow_client.client.models.value import Value as Value from airflow_client.client.models.variable_body import VariableBody as VariableBody from airflow_client.client.models.variable_collection_response import VariableCollectionResponse as VariableCollectionResponse diff --git a/airflow_client/client/api/asset_api.py b/airflow_client/client/api/asset_api.py index d46fb41d..ea62a748 100644 --- a/airflow_client/client/api/asset_api.py +++ b/airflow_client/client/api/asset_api.py @@ -1,5 +1,3 @@ -# coding: utf-8 - """ Airflow API @@ -11,6 +9,7 @@ Do not edit the class manually. """ # noqa: E501 + import warnings from pydantic import validate_call, Field, StrictFloat, StrictStr, StrictInt from typing import Any, Dict, List, Optional, Tuple, Union @@ -2663,7 +2662,6 @@ def get_asset_queued_events( '200': "QueuedEventCollectionResponse", '401': "HTTPExceptionResponse", '403': "HTTPExceptionResponse", - '404': "HTTPExceptionResponse", '422': "HTTPValidationError", } response_data = self.api_client.call_api( @@ -2738,7 +2736,6 @@ def get_asset_queued_events_with_http_info( '200': "QueuedEventCollectionResponse", '401': "HTTPExceptionResponse", '403': "HTTPExceptionResponse", - '404': "HTTPExceptionResponse", '422': "HTTPValidationError", } response_data = self.api_client.call_api( @@ -2813,7 +2810,6 @@ def get_asset_queued_events_without_preload_content( '200': "QueuedEventCollectionResponse", '401': "HTTPExceptionResponse", '403': "HTTPExceptionResponse", - '404': "HTTPExceptionResponse", '422': "HTTPValidationError", } response_data = self.api_client.call_api( @@ -3640,7 +3636,6 @@ def get_dag_asset_queued_events( '200': "QueuedEventCollectionResponse", '401': "HTTPExceptionResponse", '403': "HTTPExceptionResponse", - '404': "HTTPExceptionResponse", '422': "HTTPValidationError", } response_data = self.api_client.call_api( @@ -3715,7 +3710,6 @@ def get_dag_asset_queued_events_with_http_info( '200': "QueuedEventCollectionResponse", '401': "HTTPExceptionResponse", '403': "HTTPExceptionResponse", - '404': "HTTPExceptionResponse", '422': "HTTPValidationError", } response_data = self.api_client.call_api( @@ -3790,7 +3784,6 @@ def get_dag_asset_queued_events_without_preload_content( '200': "QueuedEventCollectionResponse", '401': "HTTPExceptionResponse", '403': "HTTPExceptionResponse", - '404': "HTTPExceptionResponse", '422': "HTTPValidationError", } response_data = self.api_client.call_api( diff --git a/airflow_client/client/api/backfill_api.py b/airflow_client/client/api/backfill_api.py index d537265d..62a2f37f 100644 --- a/airflow_client/client/api/backfill_api.py +++ b/airflow_client/client/api/backfill_api.py @@ -1,5 +1,3 @@ -# coding: utf-8 - """ Airflow API @@ -11,6 +9,7 @@ Do not edit the class manually. """ # noqa: E501 + import warnings from pydantic import validate_call, Field, StrictFloat, StrictStr, StrictInt from typing import Any, Dict, List, Optional, Tuple, Union diff --git a/airflow_client/client/api/config_api.py b/airflow_client/client/api/config_api.py index c0fe4101..0c245d08 100644 --- a/airflow_client/client/api/config_api.py +++ b/airflow_client/client/api/config_api.py @@ -1,5 +1,3 @@ -# coding: utf-8 - """ Airflow API @@ -11,6 +9,7 @@ Do not edit the class manually. """ # noqa: E501 + import warnings from pydantic import validate_call, Field, StrictFloat, StrictStr, StrictInt from typing import Any, Dict, List, Optional, Tuple, Union diff --git a/airflow_client/client/api/connection_api.py b/airflow_client/client/api/connection_api.py index 285ef928..81ac304c 100644 --- a/airflow_client/client/api/connection_api.py +++ b/airflow_client/client/api/connection_api.py @@ -1,5 +1,3 @@ -# coding: utf-8 - """ Airflow API @@ -11,6 +9,7 @@ Do not edit the class manually. """ # noqa: E501 + import warnings from pydantic import validate_call, Field, StrictFloat, StrictStr, StrictInt from typing import Any, Dict, List, Optional, Tuple, Union diff --git a/airflow_client/client/api/dag_api.py b/airflow_client/client/api/dag_api.py index 46b7a325..f3dd99e8 100644 --- a/airflow_client/client/api/dag_api.py +++ b/airflow_client/client/api/dag_api.py @@ -1,5 +1,3 @@ -# coding: utf-8 - """ Airflow API @@ -11,6 +9,7 @@ Do not edit the class manually. """ # noqa: E501 + import warnings from pydantic import validate_call, Field, StrictFloat, StrictStr, StrictInt from typing import Any, Dict, List, Optional, Tuple, Union diff --git a/airflow_client/client/api/dag_parsing_api.py b/airflow_client/client/api/dag_parsing_api.py index 422d80e8..c2044284 100644 --- a/airflow_client/client/api/dag_parsing_api.py +++ b/airflow_client/client/api/dag_parsing_api.py @@ -1,5 +1,3 @@ -# coding: utf-8 - """ Airflow API @@ -11,6 +9,7 @@ Do not edit the class manually. """ # noqa: E501 + import warnings from pydantic import validate_call, Field, StrictFloat, StrictStr, StrictInt from typing import Any, Dict, List, Optional, Tuple, Union diff --git a/airflow_client/client/api/dag_run_api.py b/airflow_client/client/api/dag_run_api.py index 617f8c01..ee4a852a 100644 --- a/airflow_client/client/api/dag_run_api.py +++ b/airflow_client/client/api/dag_run_api.py @@ -1,5 +1,3 @@ -# coding: utf-8 - """ Airflow API @@ -11,13 +9,14 @@ Do not edit the class manually. """ # noqa: E501 + import warnings from pydantic import validate_call, Field, StrictFloat, StrictStr, StrictInt from typing import Any, Dict, List, Optional, Tuple, Union from typing_extensions import Annotated from datetime import datetime -from pydantic import Field, StrictFloat, StrictInt, StrictStr, field_validator +from pydantic import Field, StrictInt, StrictStr, field_validator from typing import Any, List, Optional, Union from typing_extensions import Annotated from airflow_client.client.models.asset_event_collection_response import AssetEventCollectionResponse @@ -3115,7 +3114,7 @@ def wait_dag_run_until_finished( self, dag_id: StrictStr, dag_run_id: StrictStr, - interval: Annotated[Union[StrictFloat, StrictInt], Field(description="Seconds to wait between dag run state checks")], + interval: Annotated[Union[Annotated[float, Field(strict=True, gt=0.0)], Annotated[int, Field(strict=True, gt=0)]], Field(description="Seconds to wait between dag run state checks")], result: Annotated[Optional[List[StrictStr]], Field(description="Collect result XCom from task. Can be set multiple times.")] = None, _request_timeout: Union[ None, @@ -3198,7 +3197,7 @@ def wait_dag_run_until_finished_with_http_info( self, dag_id: StrictStr, dag_run_id: StrictStr, - interval: Annotated[Union[StrictFloat, StrictInt], Field(description="Seconds to wait between dag run state checks")], + interval: Annotated[Union[Annotated[float, Field(strict=True, gt=0.0)], Annotated[int, Field(strict=True, gt=0)]], Field(description="Seconds to wait between dag run state checks")], result: Annotated[Optional[List[StrictStr]], Field(description="Collect result XCom from task. Can be set multiple times.")] = None, _request_timeout: Union[ None, @@ -3281,7 +3280,7 @@ def wait_dag_run_until_finished_without_preload_content( self, dag_id: StrictStr, dag_run_id: StrictStr, - interval: Annotated[Union[StrictFloat, StrictInt], Field(description="Seconds to wait between dag run state checks")], + interval: Annotated[Union[Annotated[float, Field(strict=True, gt=0.0)], Annotated[int, Field(strict=True, gt=0)]], Field(description="Seconds to wait between dag run state checks")], result: Annotated[Optional[List[StrictStr]], Field(description="Collect result XCom from task. Can be set multiple times.")] = None, _request_timeout: Union[ None, diff --git a/airflow_client/client/api/dag_source_api.py b/airflow_client/client/api/dag_source_api.py index 575e6837..81010e7c 100644 --- a/airflow_client/client/api/dag_source_api.py +++ b/airflow_client/client/api/dag_source_api.py @@ -1,5 +1,3 @@ -# coding: utf-8 - """ Airflow API @@ -11,6 +9,7 @@ Do not edit the class manually. """ # noqa: E501 + import warnings from pydantic import validate_call, Field, StrictFloat, StrictStr, StrictInt from typing import Any, Dict, List, Optional, Tuple, Union diff --git a/airflow_client/client/api/dag_stats_api.py b/airflow_client/client/api/dag_stats_api.py index 979dc1d3..4d40be02 100644 --- a/airflow_client/client/api/dag_stats_api.py +++ b/airflow_client/client/api/dag_stats_api.py @@ -1,5 +1,3 @@ -# coding: utf-8 - """ Airflow API @@ -11,6 +9,7 @@ Do not edit the class manually. """ # noqa: E501 + import warnings from pydantic import validate_call, Field, StrictFloat, StrictStr, StrictInt from typing import Any, Dict, List, Optional, Tuple, Union diff --git a/airflow_client/client/api/dag_version_api.py b/airflow_client/client/api/dag_version_api.py index 67024b22..1f24f017 100644 --- a/airflow_client/client/api/dag_version_api.py +++ b/airflow_client/client/api/dag_version_api.py @@ -1,5 +1,3 @@ -# coding: utf-8 - """ Airflow API @@ -11,6 +9,7 @@ Do not edit the class manually. """ # noqa: E501 + import warnings from pydantic import validate_call, Field, StrictFloat, StrictStr, StrictInt from typing import Any, Dict, List, Optional, Tuple, Union diff --git a/airflow_client/client/api/dag_warning_api.py b/airflow_client/client/api/dag_warning_api.py index 2b0a7d46..f94244ed 100644 --- a/airflow_client/client/api/dag_warning_api.py +++ b/airflow_client/client/api/dag_warning_api.py @@ -1,5 +1,3 @@ -# coding: utf-8 - """ Airflow API @@ -11,6 +9,7 @@ Do not edit the class manually. """ # noqa: E501 + import warnings from pydantic import validate_call, Field, StrictFloat, StrictStr, StrictInt from typing import Any, Dict, List, Optional, Tuple, Union diff --git a/airflow_client/client/api/event_log_api.py b/airflow_client/client/api/event_log_api.py index 9b6ecd19..93083bc3 100644 --- a/airflow_client/client/api/event_log_api.py +++ b/airflow_client/client/api/event_log_api.py @@ -1,5 +1,3 @@ -# coding: utf-8 - """ Airflow API @@ -11,6 +9,7 @@ Do not edit the class manually. """ # noqa: E501 + import warnings from pydantic import validate_call, Field, StrictFloat, StrictStr, StrictInt from typing import Any, Dict, List, Optional, Tuple, Union diff --git a/airflow_client/client/api/experimental_api.py b/airflow_client/client/api/experimental_api.py index cd5410e3..36492252 100644 --- a/airflow_client/client/api/experimental_api.py +++ b/airflow_client/client/api/experimental_api.py @@ -1,5 +1,3 @@ -# coding: utf-8 - """ Airflow API @@ -11,12 +9,13 @@ Do not edit the class manually. """ # noqa: E501 + import warnings from pydantic import validate_call, Field, StrictFloat, StrictStr, StrictInt from typing import Any, Dict, List, Optional, Tuple, Union from typing_extensions import Annotated -from pydantic import Field, StrictFloat, StrictInt, StrictStr +from pydantic import Field, StrictStr from typing import Any, List, Optional, Union from typing_extensions import Annotated @@ -43,7 +42,7 @@ def wait_dag_run_until_finished( self, dag_id: StrictStr, dag_run_id: StrictStr, - interval: Annotated[Union[StrictFloat, StrictInt], Field(description="Seconds to wait between dag run state checks")], + interval: Annotated[Union[Annotated[float, Field(strict=True, gt=0.0)], Annotated[int, Field(strict=True, gt=0)]], Field(description="Seconds to wait between dag run state checks")], result: Annotated[Optional[List[StrictStr]], Field(description="Collect result XCom from task. Can be set multiple times.")] = None, _request_timeout: Union[ None, @@ -126,7 +125,7 @@ def wait_dag_run_until_finished_with_http_info( self, dag_id: StrictStr, dag_run_id: StrictStr, - interval: Annotated[Union[StrictFloat, StrictInt], Field(description="Seconds to wait between dag run state checks")], + interval: Annotated[Union[Annotated[float, Field(strict=True, gt=0.0)], Annotated[int, Field(strict=True, gt=0)]], Field(description="Seconds to wait between dag run state checks")], result: Annotated[Optional[List[StrictStr]], Field(description="Collect result XCom from task. Can be set multiple times.")] = None, _request_timeout: Union[ None, @@ -209,7 +208,7 @@ def wait_dag_run_until_finished_without_preload_content( self, dag_id: StrictStr, dag_run_id: StrictStr, - interval: Annotated[Union[StrictFloat, StrictInt], Field(description="Seconds to wait between dag run state checks")], + interval: Annotated[Union[Annotated[float, Field(strict=True, gt=0.0)], Annotated[int, Field(strict=True, gt=0)]], Field(description="Seconds to wait between dag run state checks")], result: Annotated[Optional[List[StrictStr]], Field(description="Collect result XCom from task. Can be set multiple times.")] = None, _request_timeout: Union[ None, diff --git a/airflow_client/client/api/extra_links_api.py b/airflow_client/client/api/extra_links_api.py index 504f4dbb..e4a88c49 100644 --- a/airflow_client/client/api/extra_links_api.py +++ b/airflow_client/client/api/extra_links_api.py @@ -1,5 +1,3 @@ -# coding: utf-8 - """ Airflow API @@ -11,6 +9,7 @@ Do not edit the class manually. """ # noqa: E501 + import warnings from pydantic import validate_call, Field, StrictFloat, StrictStr, StrictInt from typing import Any, Dict, List, Optional, Tuple, Union diff --git a/airflow_client/client/api/import_error_api.py b/airflow_client/client/api/import_error_api.py index ecbff9b0..9f239e65 100644 --- a/airflow_client/client/api/import_error_api.py +++ b/airflow_client/client/api/import_error_api.py @@ -1,5 +1,3 @@ -# coding: utf-8 - """ Airflow API @@ -11,6 +9,7 @@ Do not edit the class manually. """ # noqa: E501 + import warnings from pydantic import validate_call, Field, StrictFloat, StrictStr, StrictInt from typing import Any, Dict, List, Optional, Tuple, Union diff --git a/airflow_client/client/api/job_api.py b/airflow_client/client/api/job_api.py index 3729fa5f..f18e31c4 100644 --- a/airflow_client/client/api/job_api.py +++ b/airflow_client/client/api/job_api.py @@ -1,5 +1,3 @@ -# coding: utf-8 - """ Airflow API @@ -11,6 +9,7 @@ Do not edit the class manually. """ # noqa: E501 + import warnings from pydantic import validate_call, Field, StrictFloat, StrictStr, StrictInt from typing import Any, Dict, List, Optional, Tuple, Union diff --git a/airflow_client/client/api/login_api.py b/airflow_client/client/api/login_api.py index 21ad0441..7332a209 100644 --- a/airflow_client/client/api/login_api.py +++ b/airflow_client/client/api/login_api.py @@ -1,5 +1,3 @@ -# coding: utf-8 - """ Airflow API @@ -11,6 +9,7 @@ Do not edit the class manually. """ # noqa: E501 + import warnings from pydantic import validate_call, Field, StrictFloat, StrictStr, StrictInt from typing import Any, Dict, List, Optional, Tuple, Union diff --git a/airflow_client/client/api/monitor_api.py b/airflow_client/client/api/monitor_api.py index eab69620..3754124b 100644 --- a/airflow_client/client/api/monitor_api.py +++ b/airflow_client/client/api/monitor_api.py @@ -1,5 +1,3 @@ -# coding: utf-8 - """ Airflow API @@ -11,6 +9,7 @@ Do not edit the class manually. """ # noqa: E501 + import warnings from pydantic import validate_call, Field, StrictFloat, StrictStr, StrictInt from typing import Any, Dict, List, Optional, Tuple, Union diff --git a/airflow_client/client/api/plugin_api.py b/airflow_client/client/api/plugin_api.py index 3f038012..cb5ad571 100644 --- a/airflow_client/client/api/plugin_api.py +++ b/airflow_client/client/api/plugin_api.py @@ -1,5 +1,3 @@ -# coding: utf-8 - """ Airflow API @@ -11,6 +9,7 @@ Do not edit the class manually. """ # noqa: E501 + import warnings from pydantic import validate_call, Field, StrictFloat, StrictStr, StrictInt from typing import Any, Dict, List, Optional, Tuple, Union diff --git a/airflow_client/client/api/pool_api.py b/airflow_client/client/api/pool_api.py index 345a2108..a6f3e556 100644 --- a/airflow_client/client/api/pool_api.py +++ b/airflow_client/client/api/pool_api.py @@ -1,5 +1,3 @@ -# coding: utf-8 - """ Airflow API @@ -11,6 +9,7 @@ Do not edit the class manually. """ # noqa: E501 + import warnings from pydantic import validate_call, Field, StrictFloat, StrictStr, StrictInt from typing import Any, Dict, List, Optional, Tuple, Union diff --git a/airflow_client/client/api/provider_api.py b/airflow_client/client/api/provider_api.py index 50f9b1d0..df49191c 100644 --- a/airflow_client/client/api/provider_api.py +++ b/airflow_client/client/api/provider_api.py @@ -1,5 +1,3 @@ -# coding: utf-8 - """ Airflow API @@ -11,6 +9,7 @@ Do not edit the class manually. """ # noqa: E501 + import warnings from pydantic import validate_call, Field, StrictFloat, StrictStr, StrictInt from typing import Any, Dict, List, Optional, Tuple, Union diff --git a/airflow_client/client/api/task_api.py b/airflow_client/client/api/task_api.py index c0470ca5..811210e1 100644 --- a/airflow_client/client/api/task_api.py +++ b/airflow_client/client/api/task_api.py @@ -1,5 +1,3 @@ -# coding: utf-8 - """ Airflow API @@ -11,6 +9,7 @@ Do not edit the class manually. """ # noqa: E501 + import warnings from pydantic import validate_call, Field, StrictFloat, StrictStr, StrictInt from typing import Any, Dict, List, Optional, Tuple, Union diff --git a/airflow_client/client/api/task_instance_api.py b/airflow_client/client/api/task_instance_api.py index 1d87eb26..2542b34c 100644 --- a/airflow_client/client/api/task_instance_api.py +++ b/airflow_client/client/api/task_instance_api.py @@ -1,5 +1,3 @@ -# coding: utf-8 - """ Airflow API @@ -11,6 +9,7 @@ Do not edit the class manually. """ # noqa: E501 + import warnings from pydantic import validate_call, Field, StrictFloat, StrictStr, StrictInt from typing import Any, Dict, List, Optional, Tuple, Union @@ -697,7 +696,7 @@ def get_external_log_url( dag_id: StrictStr, dag_run_id: StrictStr, task_id: StrictStr, - try_number: StrictInt, + try_number: Annotated[int, Field(strict=True, gt=0)], map_index: Optional[StrictInt] = None, _request_timeout: Union[ None, @@ -785,7 +784,7 @@ def get_external_log_url_with_http_info( dag_id: StrictStr, dag_run_id: StrictStr, task_id: StrictStr, - try_number: StrictInt, + try_number: Annotated[int, Field(strict=True, gt=0)], map_index: Optional[StrictInt] = None, _request_timeout: Union[ None, @@ -873,7 +872,7 @@ def get_external_log_url_without_preload_content( dag_id: StrictStr, dag_run_id: StrictStr, task_id: StrictStr, - try_number: StrictInt, + try_number: Annotated[int, Field(strict=True, gt=0)], map_index: Optional[StrictInt] = None, _request_timeout: Union[ None, diff --git a/airflow_client/client/api/variable_api.py b/airflow_client/client/api/variable_api.py index 1f9eda1c..8bd0e982 100644 --- a/airflow_client/client/api/variable_api.py +++ b/airflow_client/client/api/variable_api.py @@ -1,5 +1,3 @@ -# coding: utf-8 - """ Airflow API @@ -11,6 +9,7 @@ Do not edit the class manually. """ # noqa: E501 + import warnings from pydantic import validate_call, Field, StrictFloat, StrictStr, StrictInt from typing import Any, Dict, List, Optional, Tuple, Union diff --git a/airflow_client/client/api/version_api.py b/airflow_client/client/api/version_api.py index 3e7dc5af..10115324 100644 --- a/airflow_client/client/api/version_api.py +++ b/airflow_client/client/api/version_api.py @@ -1,5 +1,3 @@ -# coding: utf-8 - """ Airflow API @@ -11,6 +9,7 @@ Do not edit the class manually. """ # noqa: E501 + import warnings from pydantic import validate_call, Field, StrictFloat, StrictStr, StrictInt from typing import Any, Dict, List, Optional, Tuple, Union diff --git a/airflow_client/client/api/x_com_api.py b/airflow_client/client/api/x_com_api.py index ebf4c499..fe49e7f2 100644 --- a/airflow_client/client/api/x_com_api.py +++ b/airflow_client/client/api/x_com_api.py @@ -1,5 +1,3 @@ -# coding: utf-8 - """ Airflow API @@ -11,6 +9,7 @@ Do not edit the class manually. """ # noqa: E501 + import warnings from pydantic import validate_call, Field, StrictFloat, StrictStr, StrictInt from typing import Any, Dict, List, Optional, Tuple, Union diff --git a/airflow_client/client/api_client.py b/airflow_client/client/api_client.py index de136cca..715e08e2 100644 --- a/airflow_client/client/api_client.py +++ b/airflow_client/client/api_client.py @@ -1,5 +1,3 @@ -# coding: utf-8 - """ Airflow API @@ -12,6 +10,7 @@ """ # noqa: E501 + import datetime from dateutil.parser import parse from enum import Enum @@ -91,7 +90,7 @@ def __init__( self.default_headers[header_name] = header_value self.cookie = cookie # Set default User-Agent. - self.user_agent = 'OpenAPI-Generator/3.1.6/python' + self.user_agent = 'OpenAPI-Generator/3.1.8/python' self.client_side_validation = configuration.client_side_validation def __enter__(self): @@ -708,7 +707,9 @@ def __deserialize_file(self, response): content_disposition ) assert m is not None, "Unexpected 'content-disposition' header value" - filename = m.group(1) + filename = os.path.basename(m.group(1)) # Strip any directory traversal + if filename in ("", ".", ".."): # fall back to tmp filename + filename = os.path.basename(path) path = os.path.join(os.path.dirname(path), filename) with open(path, "wb") as f: diff --git a/airflow_client/client/configuration.py b/airflow_client/client/configuration.py index 13c9ae3e..7856eb60 100644 --- a/airflow_client/client/configuration.py +++ b/airflow_client/client/configuration.py @@ -1,5 +1,3 @@ -# coding: utf-8 - """ Airflow API @@ -161,7 +159,7 @@ class Configuration: values before. :param ssl_ca_cert: str - the path to a file of concatenated CA certificates in PEM format. - :param retries: Number of retries for API requests. + :param retries: int | urllib3.util.retry.Retry - Retry configuration. :param ca_cert_data: verify the peer using concatenated CA certificate data in PEM (str) or DER (bytes) format. :param cert_file: the path to a client certificate file, for mTLS. @@ -186,7 +184,7 @@ def __init__( server_operation_variables: Optional[Dict[int, ServerVariablesT]]=None, ignore_operation_servers: bool=False, ssl_ca_cert: Optional[str]=None, - retries: Optional[int] = None, + retries: Optional[Union[int, Any]] = None, ca_cert_data: Optional[Union[str, bytes]] = None, cert_file: Optional[str]=None, key_file: Optional[str]=None, @@ -303,7 +301,7 @@ def __init__( """Safe chars for path_param """ self.retries = retries - """Adding retries to override urllib3 default value 3 + """Retry configuration """ # Enable client side validation self.client_side_validation = True @@ -523,7 +521,7 @@ def to_debug_report(self) -> str: "OS: {env}\n"\ "Python Version: {pyversion}\n"\ "Version of the API: 2\n"\ - "SDK Package Version: 3.1.6".\ + "SDK Package Version: 3.1.8".\ format(env=sys.platform, pyversion=sys.version) def get_host_settings(self) -> List[HostSetting]: diff --git a/airflow_client/client/exceptions.py b/airflow_client/client/exceptions.py index 00bb2d3b..3272c9f4 100644 --- a/airflow_client/client/exceptions.py +++ b/airflow_client/client/exceptions.py @@ -1,5 +1,3 @@ -# coding: utf-8 - """ Airflow API @@ -11,6 +9,7 @@ Do not edit the class manually. """ # noqa: E501 + from typing import Any, Optional from typing_extensions import Self diff --git a/airflow_client/client/models/__init__.py b/airflow_client/client/models/__init__.py index c3b6d102..12359fd0 100644 --- a/airflow_client/client/models/__init__.py +++ b/airflow_client/client/models/__init__.py @@ -13,6 +13,10 @@ """ # noqa: E501 # import models into model package +from airflow_client.client.models.actions_inner import ActionsInner +from airflow_client.client.models.actions_inner1 import ActionsInner1 +from airflow_client.client.models.actions_inner2 import ActionsInner2 +from airflow_client.client.models.actions_inner3 import ActionsInner3 from airflow_client.client.models.app_builder_menu_item_response import AppBuilderMenuItemResponse from airflow_client.client.models.app_builder_view_response import AppBuilderViewResponse from airflow_client.client.models.asset_alias_collection_response import AssetAliasCollectionResponse @@ -29,19 +33,14 @@ from airflow_client.client.models.bulk_action_on_existence import BulkActionOnExistence from airflow_client.client.models.bulk_action_response import BulkActionResponse from airflow_client.client.models.bulk_body_bulk_task_instance_body import BulkBodyBulkTaskInstanceBody -from airflow_client.client.models.bulk_body_bulk_task_instance_body_actions_inner import BulkBodyBulkTaskInstanceBodyActionsInner from airflow_client.client.models.bulk_body_connection_body import BulkBodyConnectionBody -from airflow_client.client.models.bulk_body_connection_body_actions_inner import BulkBodyConnectionBodyActionsInner from airflow_client.client.models.bulk_body_pool_body import BulkBodyPoolBody -from airflow_client.client.models.bulk_body_pool_body_actions_inner import BulkBodyPoolBodyActionsInner from airflow_client.client.models.bulk_body_variable_body import BulkBodyVariableBody -from airflow_client.client.models.bulk_body_variable_body_actions_inner import BulkBodyVariableBodyActionsInner from airflow_client.client.models.bulk_create_action_bulk_task_instance_body import BulkCreateActionBulkTaskInstanceBody from airflow_client.client.models.bulk_create_action_connection_body import BulkCreateActionConnectionBody from airflow_client.client.models.bulk_create_action_pool_body import BulkCreateActionPoolBody from airflow_client.client.models.bulk_create_action_variable_body import BulkCreateActionVariableBody from airflow_client.client.models.bulk_delete_action_bulk_task_instance_body import BulkDeleteActionBulkTaskInstanceBody -from airflow_client.client.models.bulk_delete_action_bulk_task_instance_body_entities_inner import BulkDeleteActionBulkTaskInstanceBodyEntitiesInner from airflow_client.client.models.bulk_delete_action_connection_body import BulkDeleteActionConnectionBody from airflow_client.client.models.bulk_delete_action_pool_body import BulkDeleteActionPoolBody from airflow_client.client.models.bulk_delete_action_variable_body import BulkDeleteActionVariableBody @@ -92,6 +91,7 @@ from airflow_client.client.models.detail import Detail from airflow_client.client.models.dry_run_backfill_collection_response import DryRunBackfillCollectionResponse from airflow_client.client.models.dry_run_backfill_response import DryRunBackfillResponse +from airflow_client.client.models.entities_inner import EntitiesInner from airflow_client.client.models.event_log_collection_response import EventLogCollectionResponse from airflow_client.client.models.event_log_response import EventLogResponse from airflow_client.client.models.external_log_url_response import ExternalLogUrlResponse @@ -111,6 +111,7 @@ from airflow_client.client.models.job_collection_response import JobCollectionResponse from airflow_client.client.models.job_response import JobResponse from airflow_client.client.models.last_asset_event_response import LastAssetEventResponse +from airflow_client.client.models.location_inner import LocationInner from airflow_client.client.models.patch_task_instance_body import PatchTaskInstanceBody from airflow_client.client.models.plugin_collection_response import PluginCollectionResponse from airflow_client.client.models.plugin_import_error_collection_response import PluginImportErrorCollectionResponse @@ -149,7 +150,6 @@ from airflow_client.client.models.triggerer_info_response import TriggererInfoResponse from airflow_client.client.models.update_hitl_detail_payload import UpdateHITLDetailPayload from airflow_client.client.models.validation_error import ValidationError -from airflow_client.client.models.validation_error_loc_inner import ValidationErrorLocInner from airflow_client.client.models.value import Value from airflow_client.client.models.variable_body import VariableBody from airflow_client.client.models.variable_collection_response import VariableCollectionResponse diff --git a/airflow_client/client/models/bulk_body_bulk_task_instance_body_actions_inner.py b/airflow_client/client/models/actions_inner.py similarity index 82% rename from airflow_client/client/models/bulk_body_bulk_task_instance_body_actions_inner.py rename to airflow_client/client/models/actions_inner.py index e33168a7..8621ffe7 100644 --- a/airflow_client/client/models/bulk_body_bulk_task_instance_body_actions_inner.py +++ b/airflow_client/client/models/actions_inner.py @@ -24,11 +24,11 @@ from typing import Union, List, Set, Optional, Dict from typing_extensions import Literal, Self -BULKBODYBULKTASKINSTANCEBODYACTIONSINNER_ONE_OF_SCHEMAS = ["BulkCreateActionBulkTaskInstanceBody", "BulkDeleteActionBulkTaskInstanceBody", "BulkUpdateActionBulkTaskInstanceBody"] +ACTIONSINNER_ONE_OF_SCHEMAS = ["BulkCreateActionBulkTaskInstanceBody", "BulkDeleteActionBulkTaskInstanceBody", "BulkUpdateActionBulkTaskInstanceBody"] -class BulkBodyBulkTaskInstanceBodyActionsInner(BaseModel): +class ActionsInner(BaseModel): """ - BulkBodyBulkTaskInstanceBodyActionsInner + ActionsInner """ # data type: BulkCreateActionBulkTaskInstanceBody oneof_schema_1_validator: Optional[BulkCreateActionBulkTaskInstanceBody] = None @@ -57,7 +57,7 @@ def __init__(self, *args, **kwargs) -> None: @field_validator('actual_instance') def actual_instance_must_validate_oneof(cls, v): - instance = BulkBodyBulkTaskInstanceBodyActionsInner.model_construct() + instance = ActionsInner.model_construct() error_messages = [] match = 0 # validate data type: BulkCreateActionBulkTaskInstanceBody @@ -77,10 +77,10 @@ def actual_instance_must_validate_oneof(cls, v): match += 1 if match > 1: # more than 1 match - raise ValueError("Multiple matches found when setting `actual_instance` in BulkBodyBulkTaskInstanceBodyActionsInner with oneOf schemas: BulkCreateActionBulkTaskInstanceBody, BulkDeleteActionBulkTaskInstanceBody, BulkUpdateActionBulkTaskInstanceBody. Details: " + ", ".join(error_messages)) + raise ValueError("Multiple matches found when setting `actual_instance` in ActionsInner with oneOf schemas: BulkCreateActionBulkTaskInstanceBody, BulkDeleteActionBulkTaskInstanceBody, BulkUpdateActionBulkTaskInstanceBody. Details: " + ", ".join(error_messages)) elif match == 0: # no match - raise ValueError("No match found when setting `actual_instance` in BulkBodyBulkTaskInstanceBodyActionsInner with oneOf schemas: BulkCreateActionBulkTaskInstanceBody, BulkDeleteActionBulkTaskInstanceBody, BulkUpdateActionBulkTaskInstanceBody. Details: " + ", ".join(error_messages)) + raise ValueError("No match found when setting `actual_instance` in ActionsInner with oneOf schemas: BulkCreateActionBulkTaskInstanceBody, BulkDeleteActionBulkTaskInstanceBody, BulkUpdateActionBulkTaskInstanceBody. Details: " + ", ".join(error_messages)) else: return v @@ -116,10 +116,10 @@ def from_json(cls, json_str: str) -> Self: if match > 1: # more than 1 match - raise ValueError("Multiple matches found when deserializing the JSON string into BulkBodyBulkTaskInstanceBodyActionsInner with oneOf schemas: BulkCreateActionBulkTaskInstanceBody, BulkDeleteActionBulkTaskInstanceBody, BulkUpdateActionBulkTaskInstanceBody. Details: " + ", ".join(error_messages)) + raise ValueError("Multiple matches found when deserializing the JSON string into ActionsInner with oneOf schemas: BulkCreateActionBulkTaskInstanceBody, BulkDeleteActionBulkTaskInstanceBody, BulkUpdateActionBulkTaskInstanceBody. Details: " + ", ".join(error_messages)) elif match == 0: # no match - raise ValueError("No match found when deserializing the JSON string into BulkBodyBulkTaskInstanceBodyActionsInner with oneOf schemas: BulkCreateActionBulkTaskInstanceBody, BulkDeleteActionBulkTaskInstanceBody, BulkUpdateActionBulkTaskInstanceBody. Details: " + ", ".join(error_messages)) + raise ValueError("No match found when deserializing the JSON string into ActionsInner with oneOf schemas: BulkCreateActionBulkTaskInstanceBody, BulkDeleteActionBulkTaskInstanceBody, BulkUpdateActionBulkTaskInstanceBody. Details: " + ", ".join(error_messages)) else: return instance diff --git a/airflow_client/client/models/bulk_body_connection_body_actions_inner.py b/airflow_client/client/models/actions_inner1.py similarity index 83% rename from airflow_client/client/models/bulk_body_connection_body_actions_inner.py rename to airflow_client/client/models/actions_inner1.py index 5a9ae911..5bb236b3 100644 --- a/airflow_client/client/models/bulk_body_connection_body_actions_inner.py +++ b/airflow_client/client/models/actions_inner1.py @@ -24,11 +24,11 @@ from typing import Union, List, Set, Optional, Dict from typing_extensions import Literal, Self -BULKBODYCONNECTIONBODYACTIONSINNER_ONE_OF_SCHEMAS = ["BulkCreateActionConnectionBody", "BulkDeleteActionConnectionBody", "BulkUpdateActionConnectionBody"] +ACTIONSINNER1_ONE_OF_SCHEMAS = ["BulkCreateActionConnectionBody", "BulkDeleteActionConnectionBody", "BulkUpdateActionConnectionBody"] -class BulkBodyConnectionBodyActionsInner(BaseModel): +class ActionsInner1(BaseModel): """ - BulkBodyConnectionBodyActionsInner + ActionsInner1 """ # data type: BulkCreateActionConnectionBody oneof_schema_1_validator: Optional[BulkCreateActionConnectionBody] = None @@ -57,7 +57,7 @@ def __init__(self, *args, **kwargs) -> None: @field_validator('actual_instance') def actual_instance_must_validate_oneof(cls, v): - instance = BulkBodyConnectionBodyActionsInner.model_construct() + instance = ActionsInner1.model_construct() error_messages = [] match = 0 # validate data type: BulkCreateActionConnectionBody @@ -77,10 +77,10 @@ def actual_instance_must_validate_oneof(cls, v): match += 1 if match > 1: # more than 1 match - raise ValueError("Multiple matches found when setting `actual_instance` in BulkBodyConnectionBodyActionsInner with oneOf schemas: BulkCreateActionConnectionBody, BulkDeleteActionConnectionBody, BulkUpdateActionConnectionBody. Details: " + ", ".join(error_messages)) + raise ValueError("Multiple matches found when setting `actual_instance` in ActionsInner1 with oneOf schemas: BulkCreateActionConnectionBody, BulkDeleteActionConnectionBody, BulkUpdateActionConnectionBody. Details: " + ", ".join(error_messages)) elif match == 0: # no match - raise ValueError("No match found when setting `actual_instance` in BulkBodyConnectionBodyActionsInner with oneOf schemas: BulkCreateActionConnectionBody, BulkDeleteActionConnectionBody, BulkUpdateActionConnectionBody. Details: " + ", ".join(error_messages)) + raise ValueError("No match found when setting `actual_instance` in ActionsInner1 with oneOf schemas: BulkCreateActionConnectionBody, BulkDeleteActionConnectionBody, BulkUpdateActionConnectionBody. Details: " + ", ".join(error_messages)) else: return v @@ -116,10 +116,10 @@ def from_json(cls, json_str: str) -> Self: if match > 1: # more than 1 match - raise ValueError("Multiple matches found when deserializing the JSON string into BulkBodyConnectionBodyActionsInner with oneOf schemas: BulkCreateActionConnectionBody, BulkDeleteActionConnectionBody, BulkUpdateActionConnectionBody. Details: " + ", ".join(error_messages)) + raise ValueError("Multiple matches found when deserializing the JSON string into ActionsInner1 with oneOf schemas: BulkCreateActionConnectionBody, BulkDeleteActionConnectionBody, BulkUpdateActionConnectionBody. Details: " + ", ".join(error_messages)) elif match == 0: # no match - raise ValueError("No match found when deserializing the JSON string into BulkBodyConnectionBodyActionsInner with oneOf schemas: BulkCreateActionConnectionBody, BulkDeleteActionConnectionBody, BulkUpdateActionConnectionBody. Details: " + ", ".join(error_messages)) + raise ValueError("No match found when deserializing the JSON string into ActionsInner1 with oneOf schemas: BulkCreateActionConnectionBody, BulkDeleteActionConnectionBody, BulkUpdateActionConnectionBody. Details: " + ", ".join(error_messages)) else: return instance diff --git a/airflow_client/client/models/bulk_body_pool_body_actions_inner.py b/airflow_client/client/models/actions_inner2.py similarity index 85% rename from airflow_client/client/models/bulk_body_pool_body_actions_inner.py rename to airflow_client/client/models/actions_inner2.py index 6cdad817..d62e1192 100644 --- a/airflow_client/client/models/bulk_body_pool_body_actions_inner.py +++ b/airflow_client/client/models/actions_inner2.py @@ -24,11 +24,11 @@ from typing import Union, List, Set, Optional, Dict from typing_extensions import Literal, Self -BULKBODYPOOLBODYACTIONSINNER_ONE_OF_SCHEMAS = ["BulkCreateActionPoolBody", "BulkDeleteActionPoolBody", "BulkUpdateActionPoolBody"] +ACTIONSINNER2_ONE_OF_SCHEMAS = ["BulkCreateActionPoolBody", "BulkDeleteActionPoolBody", "BulkUpdateActionPoolBody"] -class BulkBodyPoolBodyActionsInner(BaseModel): +class ActionsInner2(BaseModel): """ - BulkBodyPoolBodyActionsInner + ActionsInner2 """ # data type: BulkCreateActionPoolBody oneof_schema_1_validator: Optional[BulkCreateActionPoolBody] = None @@ -57,7 +57,7 @@ def __init__(self, *args, **kwargs) -> None: @field_validator('actual_instance') def actual_instance_must_validate_oneof(cls, v): - instance = BulkBodyPoolBodyActionsInner.model_construct() + instance = ActionsInner2.model_construct() error_messages = [] match = 0 # validate data type: BulkCreateActionPoolBody @@ -77,10 +77,10 @@ def actual_instance_must_validate_oneof(cls, v): match += 1 if match > 1: # more than 1 match - raise ValueError("Multiple matches found when setting `actual_instance` in BulkBodyPoolBodyActionsInner with oneOf schemas: BulkCreateActionPoolBody, BulkDeleteActionPoolBody, BulkUpdateActionPoolBody. Details: " + ", ".join(error_messages)) + raise ValueError("Multiple matches found when setting `actual_instance` in ActionsInner2 with oneOf schemas: BulkCreateActionPoolBody, BulkDeleteActionPoolBody, BulkUpdateActionPoolBody. Details: " + ", ".join(error_messages)) elif match == 0: # no match - raise ValueError("No match found when setting `actual_instance` in BulkBodyPoolBodyActionsInner with oneOf schemas: BulkCreateActionPoolBody, BulkDeleteActionPoolBody, BulkUpdateActionPoolBody. Details: " + ", ".join(error_messages)) + raise ValueError("No match found when setting `actual_instance` in ActionsInner2 with oneOf schemas: BulkCreateActionPoolBody, BulkDeleteActionPoolBody, BulkUpdateActionPoolBody. Details: " + ", ".join(error_messages)) else: return v @@ -116,10 +116,10 @@ def from_json(cls, json_str: str) -> Self: if match > 1: # more than 1 match - raise ValueError("Multiple matches found when deserializing the JSON string into BulkBodyPoolBodyActionsInner with oneOf schemas: BulkCreateActionPoolBody, BulkDeleteActionPoolBody, BulkUpdateActionPoolBody. Details: " + ", ".join(error_messages)) + raise ValueError("Multiple matches found when deserializing the JSON string into ActionsInner2 with oneOf schemas: BulkCreateActionPoolBody, BulkDeleteActionPoolBody, BulkUpdateActionPoolBody. Details: " + ", ".join(error_messages)) elif match == 0: # no match - raise ValueError("No match found when deserializing the JSON string into BulkBodyPoolBodyActionsInner with oneOf schemas: BulkCreateActionPoolBody, BulkDeleteActionPoolBody, BulkUpdateActionPoolBody. Details: " + ", ".join(error_messages)) + raise ValueError("No match found when deserializing the JSON string into ActionsInner2 with oneOf schemas: BulkCreateActionPoolBody, BulkDeleteActionPoolBody, BulkUpdateActionPoolBody. Details: " + ", ".join(error_messages)) else: return instance diff --git a/airflow_client/client/models/bulk_body_variable_body_actions_inner.py b/airflow_client/client/models/actions_inner3.py similarity index 84% rename from airflow_client/client/models/bulk_body_variable_body_actions_inner.py rename to airflow_client/client/models/actions_inner3.py index 3eb958f1..513662f8 100644 --- a/airflow_client/client/models/bulk_body_variable_body_actions_inner.py +++ b/airflow_client/client/models/actions_inner3.py @@ -24,11 +24,11 @@ from typing import Union, List, Set, Optional, Dict from typing_extensions import Literal, Self -BULKBODYVARIABLEBODYACTIONSINNER_ONE_OF_SCHEMAS = ["BulkCreateActionVariableBody", "BulkDeleteActionVariableBody", "BulkUpdateActionVariableBody"] +ACTIONSINNER3_ONE_OF_SCHEMAS = ["BulkCreateActionVariableBody", "BulkDeleteActionVariableBody", "BulkUpdateActionVariableBody"] -class BulkBodyVariableBodyActionsInner(BaseModel): +class ActionsInner3(BaseModel): """ - BulkBodyVariableBodyActionsInner + ActionsInner3 """ # data type: BulkCreateActionVariableBody oneof_schema_1_validator: Optional[BulkCreateActionVariableBody] = None @@ -57,7 +57,7 @@ def __init__(self, *args, **kwargs) -> None: @field_validator('actual_instance') def actual_instance_must_validate_oneof(cls, v): - instance = BulkBodyVariableBodyActionsInner.model_construct() + instance = ActionsInner3.model_construct() error_messages = [] match = 0 # validate data type: BulkCreateActionVariableBody @@ -77,10 +77,10 @@ def actual_instance_must_validate_oneof(cls, v): match += 1 if match > 1: # more than 1 match - raise ValueError("Multiple matches found when setting `actual_instance` in BulkBodyVariableBodyActionsInner with oneOf schemas: BulkCreateActionVariableBody, BulkDeleteActionVariableBody, BulkUpdateActionVariableBody. Details: " + ", ".join(error_messages)) + raise ValueError("Multiple matches found when setting `actual_instance` in ActionsInner3 with oneOf schemas: BulkCreateActionVariableBody, BulkDeleteActionVariableBody, BulkUpdateActionVariableBody. Details: " + ", ".join(error_messages)) elif match == 0: # no match - raise ValueError("No match found when setting `actual_instance` in BulkBodyVariableBodyActionsInner with oneOf schemas: BulkCreateActionVariableBody, BulkDeleteActionVariableBody, BulkUpdateActionVariableBody. Details: " + ", ".join(error_messages)) + raise ValueError("No match found when setting `actual_instance` in ActionsInner3 with oneOf schemas: BulkCreateActionVariableBody, BulkDeleteActionVariableBody, BulkUpdateActionVariableBody. Details: " + ", ".join(error_messages)) else: return v @@ -116,10 +116,10 @@ def from_json(cls, json_str: str) -> Self: if match > 1: # more than 1 match - raise ValueError("Multiple matches found when deserializing the JSON string into BulkBodyVariableBodyActionsInner with oneOf schemas: BulkCreateActionVariableBody, BulkDeleteActionVariableBody, BulkUpdateActionVariableBody. Details: " + ", ".join(error_messages)) + raise ValueError("Multiple matches found when deserializing the JSON string into ActionsInner3 with oneOf schemas: BulkCreateActionVariableBody, BulkDeleteActionVariableBody, BulkUpdateActionVariableBody. Details: " + ", ".join(error_messages)) elif match == 0: # no match - raise ValueError("No match found when deserializing the JSON string into BulkBodyVariableBodyActionsInner with oneOf schemas: BulkCreateActionVariableBody, BulkDeleteActionVariableBody, BulkUpdateActionVariableBody. Details: " + ", ".join(error_messages)) + raise ValueError("No match found when deserializing the JSON string into ActionsInner3 with oneOf schemas: BulkCreateActionVariableBody, BulkDeleteActionVariableBody, BulkUpdateActionVariableBody. Details: " + ", ".join(error_messages)) else: return instance diff --git a/airflow_client/client/models/bulk_body_bulk_task_instance_body.py b/airflow_client/client/models/bulk_body_bulk_task_instance_body.py index 0119517d..ab8b60b9 100644 --- a/airflow_client/client/models/bulk_body_bulk_task_instance_body.py +++ b/airflow_client/client/models/bulk_body_bulk_task_instance_body.py @@ -19,7 +19,7 @@ from pydantic import BaseModel, ConfigDict from typing import Any, ClassVar, Dict, List -from airflow_client.client.models.bulk_body_bulk_task_instance_body_actions_inner import BulkBodyBulkTaskInstanceBodyActionsInner +from airflow_client.client.models.actions_inner import ActionsInner from typing import Optional, Set from typing_extensions import Self @@ -27,7 +27,7 @@ class BulkBodyBulkTaskInstanceBody(BaseModel): """ BulkBodyBulkTaskInstanceBody """ # noqa: E501 - actions: List[BulkBodyBulkTaskInstanceBodyActionsInner] + actions: List[ActionsInner] __properties: ClassVar[List[str]] = ["actions"] model_config = ConfigDict( @@ -88,7 +88,7 @@ def from_dict(cls, obj: Optional[Dict[str, Any]]) -> Optional[Self]: return cls.model_validate(obj) _obj = cls.model_validate({ - "actions": [BulkBodyBulkTaskInstanceBodyActionsInner.from_dict(_item) for _item in obj["actions"]] if obj.get("actions") is not None else None + "actions": [ActionsInner.from_dict(_item) for _item in obj["actions"]] if obj.get("actions") is not None else None }) return _obj diff --git a/airflow_client/client/models/bulk_body_connection_body.py b/airflow_client/client/models/bulk_body_connection_body.py index f55a2e8b..9187afd0 100644 --- a/airflow_client/client/models/bulk_body_connection_body.py +++ b/airflow_client/client/models/bulk_body_connection_body.py @@ -19,7 +19,7 @@ from pydantic import BaseModel, ConfigDict from typing import Any, ClassVar, Dict, List -from airflow_client.client.models.bulk_body_connection_body_actions_inner import BulkBodyConnectionBodyActionsInner +from airflow_client.client.models.actions_inner1 import ActionsInner1 from typing import Optional, Set from typing_extensions import Self @@ -27,7 +27,7 @@ class BulkBodyConnectionBody(BaseModel): """ BulkBodyConnectionBody """ # noqa: E501 - actions: List[BulkBodyConnectionBodyActionsInner] + actions: List[ActionsInner1] __properties: ClassVar[List[str]] = ["actions"] model_config = ConfigDict( @@ -88,7 +88,7 @@ def from_dict(cls, obj: Optional[Dict[str, Any]]) -> Optional[Self]: return cls.model_validate(obj) _obj = cls.model_validate({ - "actions": [BulkBodyConnectionBodyActionsInner.from_dict(_item) for _item in obj["actions"]] if obj.get("actions") is not None else None + "actions": [ActionsInner1.from_dict(_item) for _item in obj["actions"]] if obj.get("actions") is not None else None }) return _obj diff --git a/airflow_client/client/models/bulk_body_pool_body.py b/airflow_client/client/models/bulk_body_pool_body.py index 5229c280..44865103 100644 --- a/airflow_client/client/models/bulk_body_pool_body.py +++ b/airflow_client/client/models/bulk_body_pool_body.py @@ -19,7 +19,7 @@ from pydantic import BaseModel, ConfigDict from typing import Any, ClassVar, Dict, List -from airflow_client.client.models.bulk_body_pool_body_actions_inner import BulkBodyPoolBodyActionsInner +from airflow_client.client.models.actions_inner2 import ActionsInner2 from typing import Optional, Set from typing_extensions import Self @@ -27,7 +27,7 @@ class BulkBodyPoolBody(BaseModel): """ BulkBodyPoolBody """ # noqa: E501 - actions: List[BulkBodyPoolBodyActionsInner] + actions: List[ActionsInner2] __properties: ClassVar[List[str]] = ["actions"] model_config = ConfigDict( @@ -88,7 +88,7 @@ def from_dict(cls, obj: Optional[Dict[str, Any]]) -> Optional[Self]: return cls.model_validate(obj) _obj = cls.model_validate({ - "actions": [BulkBodyPoolBodyActionsInner.from_dict(_item) for _item in obj["actions"]] if obj.get("actions") is not None else None + "actions": [ActionsInner2.from_dict(_item) for _item in obj["actions"]] if obj.get("actions") is not None else None }) return _obj diff --git a/airflow_client/client/models/bulk_body_variable_body.py b/airflow_client/client/models/bulk_body_variable_body.py index 242ef07b..91536969 100644 --- a/airflow_client/client/models/bulk_body_variable_body.py +++ b/airflow_client/client/models/bulk_body_variable_body.py @@ -19,7 +19,7 @@ from pydantic import BaseModel, ConfigDict from typing import Any, ClassVar, Dict, List -from airflow_client.client.models.bulk_body_variable_body_actions_inner import BulkBodyVariableBodyActionsInner +from airflow_client.client.models.actions_inner3 import ActionsInner3 from typing import Optional, Set from typing_extensions import Self @@ -27,7 +27,7 @@ class BulkBodyVariableBody(BaseModel): """ BulkBodyVariableBody """ # noqa: E501 - actions: List[BulkBodyVariableBodyActionsInner] + actions: List[ActionsInner3] __properties: ClassVar[List[str]] = ["actions"] model_config = ConfigDict( @@ -88,7 +88,7 @@ def from_dict(cls, obj: Optional[Dict[str, Any]]) -> Optional[Self]: return cls.model_validate(obj) _obj = cls.model_validate({ - "actions": [BulkBodyVariableBodyActionsInner.from_dict(_item) for _item in obj["actions"]] if obj.get("actions") is not None else None + "actions": [ActionsInner3.from_dict(_item) for _item in obj["actions"]] if obj.get("actions") is not None else None }) return _obj diff --git a/airflow_client/client/models/bulk_delete_action_bulk_task_instance_body.py b/airflow_client/client/models/bulk_delete_action_bulk_task_instance_body.py index de80b8ca..ecc1bfcd 100644 --- a/airflow_client/client/models/bulk_delete_action_bulk_task_instance_body.py +++ b/airflow_client/client/models/bulk_delete_action_bulk_task_instance_body.py @@ -20,7 +20,7 @@ from pydantic import BaseModel, ConfigDict, Field, StrictStr, field_validator from typing import Any, ClassVar, Dict, List, Optional from airflow_client.client.models.bulk_action_not_on_existence import BulkActionNotOnExistence -from airflow_client.client.models.bulk_delete_action_bulk_task_instance_body_entities_inner import BulkDeleteActionBulkTaskInstanceBodyEntitiesInner +from airflow_client.client.models.entities_inner import EntitiesInner from typing import Optional, Set from typing_extensions import Self @@ -30,7 +30,7 @@ class BulkDeleteActionBulkTaskInstanceBody(BaseModel): """ # noqa: E501 action: StrictStr = Field(description="The action to be performed on the entities.") action_on_non_existence: Optional[BulkActionNotOnExistence] = None - entities: List[BulkDeleteActionBulkTaskInstanceBodyEntitiesInner] = Field(description="A list of entity id/key or entity objects to be deleted.") + entities: List[EntitiesInner] = Field(description="A list of entity id/key or entity objects to be deleted.") __properties: ClassVar[List[str]] = ["action", "action_on_non_existence", "entities"] @field_validator('action') @@ -100,7 +100,7 @@ def from_dict(cls, obj: Optional[Dict[str, Any]]) -> Optional[Self]: _obj = cls.model_validate({ "action": obj.get("action"), "action_on_non_existence": obj.get("action_on_non_existence"), - "entities": [BulkDeleteActionBulkTaskInstanceBodyEntitiesInner.from_dict(_item) for _item in obj["entities"]] if obj.get("entities") is not None else None + "entities": [EntitiesInner.from_dict(_item) for _item in obj["entities"]] if obj.get("entities") is not None else None }) return _obj diff --git a/airflow_client/client/models/bulk_delete_action_connection_body.py b/airflow_client/client/models/bulk_delete_action_connection_body.py index 8011f007..587e2ca8 100644 --- a/airflow_client/client/models/bulk_delete_action_connection_body.py +++ b/airflow_client/client/models/bulk_delete_action_connection_body.py @@ -20,7 +20,7 @@ from pydantic import BaseModel, ConfigDict, Field, StrictStr, field_validator from typing import Any, ClassVar, Dict, List, Optional from airflow_client.client.models.bulk_action_not_on_existence import BulkActionNotOnExistence -from airflow_client.client.models.bulk_delete_action_bulk_task_instance_body_entities_inner import BulkDeleteActionBulkTaskInstanceBodyEntitiesInner +from airflow_client.client.models.entities_inner import EntitiesInner from typing import Optional, Set from typing_extensions import Self @@ -30,7 +30,7 @@ class BulkDeleteActionConnectionBody(BaseModel): """ # noqa: E501 action: StrictStr = Field(description="The action to be performed on the entities.") action_on_non_existence: Optional[BulkActionNotOnExistence] = None - entities: List[BulkDeleteActionBulkTaskInstanceBodyEntitiesInner] = Field(description="A list of entity id/key or entity objects to be deleted.") + entities: List[EntitiesInner] = Field(description="A list of entity id/key or entity objects to be deleted.") __properties: ClassVar[List[str]] = ["action", "action_on_non_existence", "entities"] @field_validator('action') @@ -100,7 +100,7 @@ def from_dict(cls, obj: Optional[Dict[str, Any]]) -> Optional[Self]: _obj = cls.model_validate({ "action": obj.get("action"), "action_on_non_existence": obj.get("action_on_non_existence"), - "entities": [BulkDeleteActionBulkTaskInstanceBodyEntitiesInner.from_dict(_item) for _item in obj["entities"]] if obj.get("entities") is not None else None + "entities": [EntitiesInner.from_dict(_item) for _item in obj["entities"]] if obj.get("entities") is not None else None }) return _obj diff --git a/airflow_client/client/models/bulk_delete_action_pool_body.py b/airflow_client/client/models/bulk_delete_action_pool_body.py index 0ed59536..ed2f72c2 100644 --- a/airflow_client/client/models/bulk_delete_action_pool_body.py +++ b/airflow_client/client/models/bulk_delete_action_pool_body.py @@ -20,7 +20,7 @@ from pydantic import BaseModel, ConfigDict, Field, StrictStr, field_validator from typing import Any, ClassVar, Dict, List, Optional from airflow_client.client.models.bulk_action_not_on_existence import BulkActionNotOnExistence -from airflow_client.client.models.bulk_delete_action_bulk_task_instance_body_entities_inner import BulkDeleteActionBulkTaskInstanceBodyEntitiesInner +from airflow_client.client.models.entities_inner import EntitiesInner from typing import Optional, Set from typing_extensions import Self @@ -30,7 +30,7 @@ class BulkDeleteActionPoolBody(BaseModel): """ # noqa: E501 action: StrictStr = Field(description="The action to be performed on the entities.") action_on_non_existence: Optional[BulkActionNotOnExistence] = None - entities: List[BulkDeleteActionBulkTaskInstanceBodyEntitiesInner] = Field(description="A list of entity id/key or entity objects to be deleted.") + entities: List[EntitiesInner] = Field(description="A list of entity id/key or entity objects to be deleted.") __properties: ClassVar[List[str]] = ["action", "action_on_non_existence", "entities"] @field_validator('action') @@ -100,7 +100,7 @@ def from_dict(cls, obj: Optional[Dict[str, Any]]) -> Optional[Self]: _obj = cls.model_validate({ "action": obj.get("action"), "action_on_non_existence": obj.get("action_on_non_existence"), - "entities": [BulkDeleteActionBulkTaskInstanceBodyEntitiesInner.from_dict(_item) for _item in obj["entities"]] if obj.get("entities") is not None else None + "entities": [EntitiesInner.from_dict(_item) for _item in obj["entities"]] if obj.get("entities") is not None else None }) return _obj diff --git a/airflow_client/client/models/bulk_delete_action_variable_body.py b/airflow_client/client/models/bulk_delete_action_variable_body.py index e7c3503c..85e080a5 100644 --- a/airflow_client/client/models/bulk_delete_action_variable_body.py +++ b/airflow_client/client/models/bulk_delete_action_variable_body.py @@ -20,7 +20,7 @@ from pydantic import BaseModel, ConfigDict, Field, StrictStr, field_validator from typing import Any, ClassVar, Dict, List, Optional from airflow_client.client.models.bulk_action_not_on_existence import BulkActionNotOnExistence -from airflow_client.client.models.bulk_delete_action_bulk_task_instance_body_entities_inner import BulkDeleteActionBulkTaskInstanceBodyEntitiesInner +from airflow_client.client.models.entities_inner import EntitiesInner from typing import Optional, Set from typing_extensions import Self @@ -30,7 +30,7 @@ class BulkDeleteActionVariableBody(BaseModel): """ # noqa: E501 action: StrictStr = Field(description="The action to be performed on the entities.") action_on_non_existence: Optional[BulkActionNotOnExistence] = None - entities: List[BulkDeleteActionBulkTaskInstanceBodyEntitiesInner] = Field(description="A list of entity id/key or entity objects to be deleted.") + entities: List[EntitiesInner] = Field(description="A list of entity id/key or entity objects to be deleted.") __properties: ClassVar[List[str]] = ["action", "action_on_non_existence", "entities"] @field_validator('action') @@ -100,7 +100,7 @@ def from_dict(cls, obj: Optional[Dict[str, Any]]) -> Optional[Self]: _obj = cls.model_validate({ "action": obj.get("action"), "action_on_non_existence": obj.get("action_on_non_existence"), - "entities": [BulkDeleteActionBulkTaskInstanceBodyEntitiesInner.from_dict(_item) for _item in obj["entities"]] if obj.get("entities") is not None else None + "entities": [EntitiesInner.from_dict(_item) for _item in obj["entities"]] if obj.get("entities") is not None else None }) return _obj diff --git a/airflow_client/client/models/bulk_delete_action_bulk_task_instance_body_entities_inner.py b/airflow_client/client/models/entities_inner.py similarity index 88% rename from airflow_client/client/models/bulk_delete_action_bulk_task_instance_body_entities_inner.py rename to airflow_client/client/models/entities_inner.py index f68f6db9..0aaaa6e5 100644 --- a/airflow_client/client/models/bulk_delete_action_bulk_task_instance_body_entities_inner.py +++ b/airflow_client/client/models/entities_inner.py @@ -24,11 +24,11 @@ from typing_extensions import Literal, Self from pydantic import Field -BULKDELETEACTIONBULKTASKINSTANCEBODYENTITIESINNER_ANY_OF_SCHEMAS = ["BulkTaskInstanceBody", "str"] +ENTITIESINNER_ANY_OF_SCHEMAS = ["BulkTaskInstanceBody", "str"] -class BulkDeleteActionBulkTaskInstanceBodyEntitiesInner(BaseModel): +class EntitiesInner(BaseModel): """ - BulkDeleteActionBulkTaskInstanceBodyEntitiesInner + EntitiesInner """ # data type: str @@ -58,7 +58,7 @@ def __init__(self, *args, **kwargs) -> None: @field_validator('actual_instance') def actual_instance_must_validate_anyof(cls, v): - instance = BulkDeleteActionBulkTaskInstanceBodyEntitiesInner.model_construct() + instance = EntitiesInner.model_construct() error_messages = [] # validate data type: str try: @@ -74,7 +74,7 @@ def actual_instance_must_validate_anyof(cls, v): if error_messages: # no match - raise ValueError("No match found when setting the actual_instance in BulkDeleteActionBulkTaskInstanceBodyEntitiesInner with anyOf schemas: BulkTaskInstanceBody, str. Details: " + ", ".join(error_messages)) + raise ValueError("No match found when setting the actual_instance in EntitiesInner with anyOf schemas: BulkTaskInstanceBody, str. Details: " + ", ".join(error_messages)) else: return v @@ -105,7 +105,7 @@ def from_json(cls, json_str: str) -> Self: if error_messages: # no match - raise ValueError("No match found when deserializing the JSON string into BulkDeleteActionBulkTaskInstanceBodyEntitiesInner with anyOf schemas: BulkTaskInstanceBody, str. Details: " + ", ".join(error_messages)) + raise ValueError("No match found when deserializing the JSON string into EntitiesInner with anyOf schemas: BulkTaskInstanceBody, str. Details: " + ", ".join(error_messages)) else: return instance diff --git a/airflow_client/client/models/validation_error_loc_inner.py b/airflow_client/client/models/location_inner.py similarity index 91% rename from airflow_client/client/models/validation_error_loc_inner.py rename to airflow_client/client/models/location_inner.py index e51550f2..70ef3047 100644 --- a/airflow_client/client/models/validation_error_loc_inner.py +++ b/airflow_client/client/models/location_inner.py @@ -23,11 +23,11 @@ from typing_extensions import Literal, Self from pydantic import Field -VALIDATIONERRORLOCINNER_ANY_OF_SCHEMAS = ["int", "str"] +LOCATIONINNER_ANY_OF_SCHEMAS = ["int", "str"] -class ValidationErrorLocInner(BaseModel): +class LocationInner(BaseModel): """ - ValidationErrorLocInner + LocationInner """ # data type: str @@ -57,7 +57,7 @@ def __init__(self, *args, **kwargs) -> None: @field_validator('actual_instance') def actual_instance_must_validate_anyof(cls, v): - instance = ValidationErrorLocInner.model_construct() + instance = LocationInner.model_construct() error_messages = [] # validate data type: str try: @@ -73,7 +73,7 @@ def actual_instance_must_validate_anyof(cls, v): error_messages.append(str(e)) if error_messages: # no match - raise ValueError("No match found when setting the actual_instance in ValidationErrorLocInner with anyOf schemas: int, str. Details: " + ", ".join(error_messages)) + raise ValueError("No match found when setting the actual_instance in LocationInner with anyOf schemas: int, str. Details: " + ", ".join(error_messages)) else: return v @@ -107,7 +107,7 @@ def from_json(cls, json_str: str) -> Self: if error_messages: # no match - raise ValueError("No match found when deserializing the JSON string into ValidationErrorLocInner with anyOf schemas: int, str. Details: " + ", ".join(error_messages)) + raise ValueError("No match found when deserializing the JSON string into LocationInner with anyOf schemas: int, str. Details: " + ", ".join(error_messages)) else: return instance diff --git a/airflow_client/client/models/pool_body.py b/airflow_client/client/models/pool_body.py index 148a855a..bf248496 100644 --- a/airflow_client/client/models/pool_body.py +++ b/airflow_client/client/models/pool_body.py @@ -17,7 +17,7 @@ import re # noqa: F401 import json -from pydantic import BaseModel, ConfigDict, Field, StrictBool, StrictInt, StrictStr +from pydantic import BaseModel, ConfigDict, Field, StrictBool, StrictStr from typing import Any, ClassVar, Dict, List, Optional from typing_extensions import Annotated from typing import Optional, Set @@ -30,7 +30,7 @@ class PoolBody(BaseModel): description: Optional[StrictStr] = None include_deferred: Optional[StrictBool] = False name: Annotated[str, Field(strict=True, max_length=256)] - slots: StrictInt + slots: Annotated[int, Field(strict=True, ge=-1)] = Field(description="Number of slots. Use -1 for unlimited.") __properties: ClassVar[List[str]] = ["description", "include_deferred", "name", "slots"] model_config = ConfigDict( diff --git a/airflow_client/client/models/pool_patch_body.py b/airflow_client/client/models/pool_patch_body.py index 278be6f5..4e92e1eb 100644 --- a/airflow_client/client/models/pool_patch_body.py +++ b/airflow_client/client/models/pool_patch_body.py @@ -17,8 +17,9 @@ import re # noqa: F401 import json -from pydantic import BaseModel, ConfigDict, StrictBool, StrictInt, StrictStr +from pydantic import BaseModel, ConfigDict, Field, StrictBool, StrictStr from typing import Any, ClassVar, Dict, List, Optional +from typing_extensions import Annotated from typing import Optional, Set from typing_extensions import Self @@ -29,7 +30,7 @@ class PoolPatchBody(BaseModel): description: Optional[StrictStr] = None include_deferred: Optional[StrictBool] = None pool: Optional[StrictStr] = None - slots: Optional[StrictInt] = None + slots: Optional[Annotated[int, Field(strict=True, ge=-1)]] = Field(default=None, description="Number of slots. Use -1 for unlimited.") __properties: ClassVar[List[str]] = ["description", "include_deferred", "pool", "slots"] model_config = ConfigDict( diff --git a/airflow_client/client/models/pool_response.py b/airflow_client/client/models/pool_response.py index 4f995b65..ea8fe6c8 100644 --- a/airflow_client/client/models/pool_response.py +++ b/airflow_client/client/models/pool_response.py @@ -17,8 +17,9 @@ import re # noqa: F401 import json -from pydantic import BaseModel, ConfigDict, StrictBool, StrictInt, StrictStr +from pydantic import BaseModel, ConfigDict, Field, StrictBool, StrictInt, StrictStr from typing import Any, ClassVar, Dict, List, Optional +from typing_extensions import Annotated from typing import Optional, Set from typing_extensions import Self @@ -35,7 +36,7 @@ class PoolResponse(BaseModel): queued_slots: StrictInt running_slots: StrictInt scheduled_slots: StrictInt - slots: StrictInt + slots: Annotated[int, Field(strict=True, ge=-1)] = Field(description="Number of slots. Use -1 for unlimited.") __properties: ClassVar[List[str]] = ["deferred_slots", "description", "include_deferred", "name", "occupied_slots", "open_slots", "queued_slots", "running_slots", "scheduled_slots", "slots"] model_config = ConfigDict( diff --git a/airflow_client/client/models/validation_error.py b/airflow_client/client/models/validation_error.py index 476e7e60..4799d69b 100644 --- a/airflow_client/client/models/validation_error.py +++ b/airflow_client/client/models/validation_error.py @@ -19,7 +19,7 @@ from pydantic import BaseModel, ConfigDict, StrictStr from typing import Any, ClassVar, Dict, List -from airflow_client.client.models.validation_error_loc_inner import ValidationErrorLocInner +from airflow_client.client.models.location_inner import LocationInner from typing import Optional, Set from typing_extensions import Self @@ -27,7 +27,7 @@ class ValidationError(BaseModel): """ ValidationError """ # noqa: E501 - loc: List[ValidationErrorLocInner] + loc: List[LocationInner] msg: StrictStr type: StrictStr __properties: ClassVar[List[str]] = ["loc", "msg", "type"] @@ -90,7 +90,7 @@ def from_dict(cls, obj: Optional[Dict[str, Any]]) -> Optional[Self]: return cls.model_validate(obj) _obj = cls.model_validate({ - "loc": [ValidationErrorLocInner.from_dict(_item) for _item in obj["loc"]] if obj.get("loc") is not None else None, + "loc": [LocationInner.from_dict(_item) for _item in obj["loc"]] if obj.get("loc") is not None else None, "msg": obj.get("msg"), "type": obj.get("type") }) diff --git a/airflow_client/client/models/x_com_response.py b/airflow_client/client/models/x_com_response.py index 7c846bfb..1e4c2f39 100644 --- a/airflow_client/client/models/x_com_response.py +++ b/airflow_client/client/models/x_com_response.py @@ -32,11 +32,12 @@ class XComResponse(BaseModel): key: StrictStr logical_date: Optional[datetime] = None map_index: StrictInt + run_after: datetime run_id: StrictStr task_display_name: StrictStr task_id: StrictStr timestamp: datetime - __properties: ClassVar[List[str]] = ["dag_display_name", "dag_id", "key", "logical_date", "map_index", "run_id", "task_display_name", "task_id", "timestamp"] + __properties: ClassVar[List[str]] = ["dag_display_name", "dag_id", "key", "logical_date", "map_index", "run_after", "run_id", "task_display_name", "task_id", "timestamp"] model_config = ConfigDict( populate_by_name=True, @@ -94,6 +95,7 @@ def from_dict(cls, obj: Optional[Dict[str, Any]]) -> Optional[Self]: "key": obj.get("key"), "logical_date": obj.get("logical_date"), "map_index": obj.get("map_index"), + "run_after": obj.get("run_after"), "run_id": obj.get("run_id"), "task_display_name": obj.get("task_display_name"), "task_id": obj.get("task_id"), diff --git a/airflow_client/client/models/x_com_response_native.py b/airflow_client/client/models/x_com_response_native.py index 948da66a..17a0276f 100644 --- a/airflow_client/client/models/x_com_response_native.py +++ b/airflow_client/client/models/x_com_response_native.py @@ -32,12 +32,13 @@ class XComResponseNative(BaseModel): key: StrictStr logical_date: Optional[datetime] = None map_index: StrictInt + run_after: datetime run_id: StrictStr task_display_name: StrictStr task_id: StrictStr timestamp: datetime value: Optional[Any] - __properties: ClassVar[List[str]] = ["dag_display_name", "dag_id", "key", "logical_date", "map_index", "run_id", "task_display_name", "task_id", "timestamp", "value"] + __properties: ClassVar[List[str]] = ["dag_display_name", "dag_id", "key", "logical_date", "map_index", "run_after", "run_id", "task_display_name", "task_id", "timestamp", "value"] model_config = ConfigDict( populate_by_name=True, @@ -100,6 +101,7 @@ def from_dict(cls, obj: Optional[Dict[str, Any]]) -> Optional[Self]: "key": obj.get("key"), "logical_date": obj.get("logical_date"), "map_index": obj.get("map_index"), + "run_after": obj.get("run_after"), "run_id": obj.get("run_id"), "task_display_name": obj.get("task_display_name"), "task_id": obj.get("task_id"), diff --git a/airflow_client/client/models/x_com_response_string.py b/airflow_client/client/models/x_com_response_string.py index aa426f13..daf40504 100644 --- a/airflow_client/client/models/x_com_response_string.py +++ b/airflow_client/client/models/x_com_response_string.py @@ -32,12 +32,13 @@ class XComResponseString(BaseModel): key: StrictStr logical_date: Optional[datetime] = None map_index: StrictInt + run_after: datetime run_id: StrictStr task_display_name: StrictStr task_id: StrictStr timestamp: datetime value: Optional[StrictStr] = None - __properties: ClassVar[List[str]] = ["dag_display_name", "dag_id", "key", "logical_date", "map_index", "run_id", "task_display_name", "task_id", "timestamp", "value"] + __properties: ClassVar[List[str]] = ["dag_display_name", "dag_id", "key", "logical_date", "map_index", "run_after", "run_id", "task_display_name", "task_id", "timestamp", "value"] model_config = ConfigDict( populate_by_name=True, @@ -95,6 +96,7 @@ def from_dict(cls, obj: Optional[Dict[str, Any]]) -> Optional[Self]: "key": obj.get("key"), "logical_date": obj.get("logical_date"), "map_index": obj.get("map_index"), + "run_after": obj.get("run_after"), "run_id": obj.get("run_id"), "task_display_name": obj.get("task_display_name"), "task_id": obj.get("task_id"), diff --git a/docs/ActionsInner.md b/docs/ActionsInner.md new file mode 100644 index 00000000..f46b7400 --- /dev/null +++ b/docs/ActionsInner.md @@ -0,0 +1,32 @@ +# ActionsInner + + +## Properties + +Name | Type | Description | Notes +------------ | ------------- | ------------- | ------------- +**action** | **str** | The action to be performed on the entities. | +**action_on_existence** | [**BulkActionOnExistence**](BulkActionOnExistence.md) | | [optional] +**entities** | [**List[EntitiesInner]**](EntitiesInner.md) | A list of entity id/key or entity objects to be deleted. | +**action_on_non_existence** | [**BulkActionNotOnExistence**](BulkActionNotOnExistence.md) | | [optional] + +## Example + +```python +from airflow_client.client.models.actions_inner import ActionsInner + +# TODO update the JSON string below +json = "{}" +# create an instance of ActionsInner from a JSON string +actions_inner_instance = ActionsInner.from_json(json) +# print the JSON string representation of the object +print(ActionsInner.to_json()) + +# convert the object into a dict +actions_inner_dict = actions_inner_instance.to_dict() +# create an instance of ActionsInner from a dict +actions_inner_from_dict = ActionsInner.from_dict(actions_inner_dict) +``` +[[Back to Model list]](../README.md#documentation-for-models) [[Back to API list]](../README.md#documentation-for-api-endpoints) [[Back to README]](../README.md) + + diff --git a/docs/ActionsInner1.md b/docs/ActionsInner1.md new file mode 100644 index 00000000..ba49c6d1 --- /dev/null +++ b/docs/ActionsInner1.md @@ -0,0 +1,32 @@ +# ActionsInner1 + + +## Properties + +Name | Type | Description | Notes +------------ | ------------- | ------------- | ------------- +**action** | **str** | The action to be performed on the entities. | +**action_on_existence** | [**BulkActionOnExistence**](BulkActionOnExistence.md) | | [optional] +**entities** | [**List[EntitiesInner]**](EntitiesInner.md) | A list of entity id/key or entity objects to be deleted. | +**action_on_non_existence** | [**BulkActionNotOnExistence**](BulkActionNotOnExistence.md) | | [optional] + +## Example + +```python +from airflow_client.client.models.actions_inner1 import ActionsInner1 + +# TODO update the JSON string below +json = "{}" +# create an instance of ActionsInner1 from a JSON string +actions_inner1_instance = ActionsInner1.from_json(json) +# print the JSON string representation of the object +print(ActionsInner1.to_json()) + +# convert the object into a dict +actions_inner1_dict = actions_inner1_instance.to_dict() +# create an instance of ActionsInner1 from a dict +actions_inner1_from_dict = ActionsInner1.from_dict(actions_inner1_dict) +``` +[[Back to Model list]](../README.md#documentation-for-models) [[Back to API list]](../README.md#documentation-for-api-endpoints) [[Back to README]](../README.md) + + diff --git a/docs/ActionsInner2.md b/docs/ActionsInner2.md new file mode 100644 index 00000000..927e823a --- /dev/null +++ b/docs/ActionsInner2.md @@ -0,0 +1,32 @@ +# ActionsInner2 + + +## Properties + +Name | Type | Description | Notes +------------ | ------------- | ------------- | ------------- +**action** | **str** | The action to be performed on the entities. | +**action_on_existence** | [**BulkActionOnExistence**](BulkActionOnExistence.md) | | [optional] +**entities** | [**List[EntitiesInner]**](EntitiesInner.md) | A list of entity id/key or entity objects to be deleted. | +**action_on_non_existence** | [**BulkActionNotOnExistence**](BulkActionNotOnExistence.md) | | [optional] + +## Example + +```python +from airflow_client.client.models.actions_inner2 import ActionsInner2 + +# TODO update the JSON string below +json = "{}" +# create an instance of ActionsInner2 from a JSON string +actions_inner2_instance = ActionsInner2.from_json(json) +# print the JSON string representation of the object +print(ActionsInner2.to_json()) + +# convert the object into a dict +actions_inner2_dict = actions_inner2_instance.to_dict() +# create an instance of ActionsInner2 from a dict +actions_inner2_from_dict = ActionsInner2.from_dict(actions_inner2_dict) +``` +[[Back to Model list]](../README.md#documentation-for-models) [[Back to API list]](../README.md#documentation-for-api-endpoints) [[Back to README]](../README.md) + + diff --git a/docs/ActionsInner3.md b/docs/ActionsInner3.md new file mode 100644 index 00000000..9f448416 --- /dev/null +++ b/docs/ActionsInner3.md @@ -0,0 +1,32 @@ +# ActionsInner3 + + +## Properties + +Name | Type | Description | Notes +------------ | ------------- | ------------- | ------------- +**action** | **str** | The action to be performed on the entities. | +**action_on_existence** | [**BulkActionOnExistence**](BulkActionOnExistence.md) | | [optional] +**entities** | [**List[EntitiesInner]**](EntitiesInner.md) | A list of entity id/key or entity objects to be deleted. | +**action_on_non_existence** | [**BulkActionNotOnExistence**](BulkActionNotOnExistence.md) | | [optional] + +## Example + +```python +from airflow_client.client.models.actions_inner3 import ActionsInner3 + +# TODO update the JSON string below +json = "{}" +# create an instance of ActionsInner3 from a JSON string +actions_inner3_instance = ActionsInner3.from_json(json) +# print the JSON string representation of the object +print(ActionsInner3.to_json()) + +# convert the object into a dict +actions_inner3_dict = actions_inner3_instance.to_dict() +# create an instance of ActionsInner3 from a dict +actions_inner3_from_dict = ActionsInner3.from_dict(actions_inner3_dict) +``` +[[Back to Model list]](../README.md#documentation-for-models) [[Back to API list]](../README.md#documentation-for-api-endpoints) [[Back to README]](../README.md) + + diff --git a/docs/AssetApi.md b/docs/AssetApi.md index e35baaec..24b063f3 100644 --- a/docs/AssetApi.md +++ b/docs/AssetApi.md @@ -808,7 +808,6 @@ Name | Type | Description | Notes **200** | Successful Response | - | **401** | Unauthorized | - | **403** | Forbidden | - | -**404** | Not Found | - | **422** | Validation Error | - | [[Back to top]](#) [[Back to API list]](../README.md#documentation-for-api-endpoints) [[Back to Model list]](../README.md#documentation-for-models) [[Back to README]](../README.md) @@ -1081,7 +1080,6 @@ Name | Type | Description | Notes **200** | Successful Response | - | **401** | Unauthorized | - | **403** | Forbidden | - | -**404** | Not Found | - | **422** | Validation Error | - | [[Back to top]](#) [[Back to API list]](../README.md#documentation-for-api-endpoints) [[Back to Model list]](../README.md#documentation-for-models) [[Back to README]](../README.md) diff --git a/docs/BulkBodyBulkTaskInstanceBody.md b/docs/BulkBodyBulkTaskInstanceBody.md index bcc390d4..d2f45219 100644 --- a/docs/BulkBodyBulkTaskInstanceBody.md +++ b/docs/BulkBodyBulkTaskInstanceBody.md @@ -5,7 +5,7 @@ Name | Type | Description | Notes ------------ | ------------- | ------------- | ------------- -**actions** | [**List[BulkBodyBulkTaskInstanceBodyActionsInner]**](BulkBodyBulkTaskInstanceBodyActionsInner.md) | | +**actions** | [**List[ActionsInner]**](ActionsInner.md) | | ## Example diff --git a/docs/BulkBodyBulkTaskInstanceBodyActionsInner.md b/docs/BulkBodyBulkTaskInstanceBodyActionsInner.md deleted file mode 100644 index 522d990a..00000000 --- a/docs/BulkBodyBulkTaskInstanceBodyActionsInner.md +++ /dev/null @@ -1,32 +0,0 @@ -# BulkBodyBulkTaskInstanceBodyActionsInner - - -## Properties - -Name | Type | Description | Notes ------------- | ------------- | ------------- | ------------- -**action** | **str** | The action to be performed on the entities. | -**action_on_existence** | [**BulkActionOnExistence**](BulkActionOnExistence.md) | | [optional] -**entities** | [**List[BulkDeleteActionBulkTaskInstanceBodyEntitiesInner]**](BulkDeleteActionBulkTaskInstanceBodyEntitiesInner.md) | A list of entity id/key or entity objects to be deleted. | -**action_on_non_existence** | [**BulkActionNotOnExistence**](BulkActionNotOnExistence.md) | | [optional] - -## Example - -```python -from airflow_client.client.models.bulk_body_bulk_task_instance_body_actions_inner import BulkBodyBulkTaskInstanceBodyActionsInner - -# TODO update the JSON string below -json = "{}" -# create an instance of BulkBodyBulkTaskInstanceBodyActionsInner from a JSON string -bulk_body_bulk_task_instance_body_actions_inner_instance = BulkBodyBulkTaskInstanceBodyActionsInner.from_json(json) -# print the JSON string representation of the object -print(BulkBodyBulkTaskInstanceBodyActionsInner.to_json()) - -# convert the object into a dict -bulk_body_bulk_task_instance_body_actions_inner_dict = bulk_body_bulk_task_instance_body_actions_inner_instance.to_dict() -# create an instance of BulkBodyBulkTaskInstanceBodyActionsInner from a dict -bulk_body_bulk_task_instance_body_actions_inner_from_dict = BulkBodyBulkTaskInstanceBodyActionsInner.from_dict(bulk_body_bulk_task_instance_body_actions_inner_dict) -``` -[[Back to Model list]](../README.md#documentation-for-models) [[Back to API list]](../README.md#documentation-for-api-endpoints) [[Back to README]](../README.md) - - diff --git a/docs/BulkBodyConnectionBody.md b/docs/BulkBodyConnectionBody.md index 74895bfe..982815ff 100644 --- a/docs/BulkBodyConnectionBody.md +++ b/docs/BulkBodyConnectionBody.md @@ -5,7 +5,7 @@ Name | Type | Description | Notes ------------ | ------------- | ------------- | ------------- -**actions** | [**List[BulkBodyConnectionBodyActionsInner]**](BulkBodyConnectionBodyActionsInner.md) | | +**actions** | [**List[ActionsInner1]**](ActionsInner1.md) | | ## Example diff --git a/docs/BulkBodyConnectionBodyActionsInner.md b/docs/BulkBodyConnectionBodyActionsInner.md deleted file mode 100644 index c0b2cbac..00000000 --- a/docs/BulkBodyConnectionBodyActionsInner.md +++ /dev/null @@ -1,32 +0,0 @@ -# BulkBodyConnectionBodyActionsInner - - -## Properties - -Name | Type | Description | Notes ------------- | ------------- | ------------- | ------------- -**action** | **str** | The action to be performed on the entities. | -**action_on_existence** | [**BulkActionOnExistence**](BulkActionOnExistence.md) | | [optional] -**entities** | [**List[BulkDeleteActionBulkTaskInstanceBodyEntitiesInner]**](BulkDeleteActionBulkTaskInstanceBodyEntitiesInner.md) | A list of entity id/key or entity objects to be deleted. | -**action_on_non_existence** | [**BulkActionNotOnExistence**](BulkActionNotOnExistence.md) | | [optional] - -## Example - -```python -from airflow_client.client.models.bulk_body_connection_body_actions_inner import BulkBodyConnectionBodyActionsInner - -# TODO update the JSON string below -json = "{}" -# create an instance of BulkBodyConnectionBodyActionsInner from a JSON string -bulk_body_connection_body_actions_inner_instance = BulkBodyConnectionBodyActionsInner.from_json(json) -# print the JSON string representation of the object -print(BulkBodyConnectionBodyActionsInner.to_json()) - -# convert the object into a dict -bulk_body_connection_body_actions_inner_dict = bulk_body_connection_body_actions_inner_instance.to_dict() -# create an instance of BulkBodyConnectionBodyActionsInner from a dict -bulk_body_connection_body_actions_inner_from_dict = BulkBodyConnectionBodyActionsInner.from_dict(bulk_body_connection_body_actions_inner_dict) -``` -[[Back to Model list]](../README.md#documentation-for-models) [[Back to API list]](../README.md#documentation-for-api-endpoints) [[Back to README]](../README.md) - - diff --git a/docs/BulkBodyPoolBody.md b/docs/BulkBodyPoolBody.md index 12580889..bc47b85d 100644 --- a/docs/BulkBodyPoolBody.md +++ b/docs/BulkBodyPoolBody.md @@ -5,7 +5,7 @@ Name | Type | Description | Notes ------------ | ------------- | ------------- | ------------- -**actions** | [**List[BulkBodyPoolBodyActionsInner]**](BulkBodyPoolBodyActionsInner.md) | | +**actions** | [**List[ActionsInner2]**](ActionsInner2.md) | | ## Example diff --git a/docs/BulkBodyPoolBodyActionsInner.md b/docs/BulkBodyPoolBodyActionsInner.md deleted file mode 100644 index 82597b71..00000000 --- a/docs/BulkBodyPoolBodyActionsInner.md +++ /dev/null @@ -1,32 +0,0 @@ -# BulkBodyPoolBodyActionsInner - - -## Properties - -Name | Type | Description | Notes ------------- | ------------- | ------------- | ------------- -**action** | **str** | The action to be performed on the entities. | -**action_on_existence** | [**BulkActionOnExistence**](BulkActionOnExistence.md) | | [optional] -**entities** | [**List[BulkDeleteActionBulkTaskInstanceBodyEntitiesInner]**](BulkDeleteActionBulkTaskInstanceBodyEntitiesInner.md) | A list of entity id/key or entity objects to be deleted. | -**action_on_non_existence** | [**BulkActionNotOnExistence**](BulkActionNotOnExistence.md) | | [optional] - -## Example - -```python -from airflow_client.client.models.bulk_body_pool_body_actions_inner import BulkBodyPoolBodyActionsInner - -# TODO update the JSON string below -json = "{}" -# create an instance of BulkBodyPoolBodyActionsInner from a JSON string -bulk_body_pool_body_actions_inner_instance = BulkBodyPoolBodyActionsInner.from_json(json) -# print the JSON string representation of the object -print(BulkBodyPoolBodyActionsInner.to_json()) - -# convert the object into a dict -bulk_body_pool_body_actions_inner_dict = bulk_body_pool_body_actions_inner_instance.to_dict() -# create an instance of BulkBodyPoolBodyActionsInner from a dict -bulk_body_pool_body_actions_inner_from_dict = BulkBodyPoolBodyActionsInner.from_dict(bulk_body_pool_body_actions_inner_dict) -``` -[[Back to Model list]](../README.md#documentation-for-models) [[Back to API list]](../README.md#documentation-for-api-endpoints) [[Back to README]](../README.md) - - diff --git a/docs/BulkBodyVariableBody.md b/docs/BulkBodyVariableBody.md index 525d4518..e8df1a89 100644 --- a/docs/BulkBodyVariableBody.md +++ b/docs/BulkBodyVariableBody.md @@ -5,7 +5,7 @@ Name | Type | Description | Notes ------------ | ------------- | ------------- | ------------- -**actions** | [**List[BulkBodyVariableBodyActionsInner]**](BulkBodyVariableBodyActionsInner.md) | | +**actions** | [**List[ActionsInner3]**](ActionsInner3.md) | | ## Example diff --git a/docs/BulkBodyVariableBodyActionsInner.md b/docs/BulkBodyVariableBodyActionsInner.md deleted file mode 100644 index 10cf393c..00000000 --- a/docs/BulkBodyVariableBodyActionsInner.md +++ /dev/null @@ -1,32 +0,0 @@ -# BulkBodyVariableBodyActionsInner - - -## Properties - -Name | Type | Description | Notes ------------- | ------------- | ------------- | ------------- -**action** | **str** | The action to be performed on the entities. | -**action_on_existence** | [**BulkActionOnExistence**](BulkActionOnExistence.md) | | [optional] -**entities** | [**List[BulkDeleteActionBulkTaskInstanceBodyEntitiesInner]**](BulkDeleteActionBulkTaskInstanceBodyEntitiesInner.md) | A list of entity id/key or entity objects to be deleted. | -**action_on_non_existence** | [**BulkActionNotOnExistence**](BulkActionNotOnExistence.md) | | [optional] - -## Example - -```python -from airflow_client.client.models.bulk_body_variable_body_actions_inner import BulkBodyVariableBodyActionsInner - -# TODO update the JSON string below -json = "{}" -# create an instance of BulkBodyVariableBodyActionsInner from a JSON string -bulk_body_variable_body_actions_inner_instance = BulkBodyVariableBodyActionsInner.from_json(json) -# print the JSON string representation of the object -print(BulkBodyVariableBodyActionsInner.to_json()) - -# convert the object into a dict -bulk_body_variable_body_actions_inner_dict = bulk_body_variable_body_actions_inner_instance.to_dict() -# create an instance of BulkBodyVariableBodyActionsInner from a dict -bulk_body_variable_body_actions_inner_from_dict = BulkBodyVariableBodyActionsInner.from_dict(bulk_body_variable_body_actions_inner_dict) -``` -[[Back to Model list]](../README.md#documentation-for-models) [[Back to API list]](../README.md#documentation-for-api-endpoints) [[Back to README]](../README.md) - - diff --git a/docs/BulkDeleteActionBulkTaskInstanceBody.md b/docs/BulkDeleteActionBulkTaskInstanceBody.md index 5a757fb8..6aed3c24 100644 --- a/docs/BulkDeleteActionBulkTaskInstanceBody.md +++ b/docs/BulkDeleteActionBulkTaskInstanceBody.md @@ -7,7 +7,7 @@ Name | Type | Description | Notes ------------ | ------------- | ------------- | ------------- **action** | **str** | The action to be performed on the entities. | **action_on_non_existence** | [**BulkActionNotOnExistence**](BulkActionNotOnExistence.md) | | [optional] -**entities** | [**List[BulkDeleteActionBulkTaskInstanceBodyEntitiesInner]**](BulkDeleteActionBulkTaskInstanceBodyEntitiesInner.md) | A list of entity id/key or entity objects to be deleted. | +**entities** | [**List[EntitiesInner]**](EntitiesInner.md) | A list of entity id/key or entity objects to be deleted. | ## Example diff --git a/docs/BulkDeleteActionBulkTaskInstanceBodyEntitiesInner.md b/docs/BulkDeleteActionBulkTaskInstanceBodyEntitiesInner.md deleted file mode 100644 index c98c117f..00000000 --- a/docs/BulkDeleteActionBulkTaskInstanceBodyEntitiesInner.md +++ /dev/null @@ -1,36 +0,0 @@ -# BulkDeleteActionBulkTaskInstanceBodyEntitiesInner - - -## Properties - -Name | Type | Description | Notes ------------- | ------------- | ------------- | ------------- -**include_downstream** | **bool** | | [optional] [default to False] -**include_future** | **bool** | | [optional] [default to False] -**include_past** | **bool** | | [optional] [default to False] -**include_upstream** | **bool** | | [optional] [default to False] -**map_index** | **int** | | [optional] -**new_state** | [**TaskInstanceState**](TaskInstanceState.md) | | [optional] -**note** | **str** | | [optional] -**task_id** | **str** | | - -## Example - -```python -from airflow_client.client.models.bulk_delete_action_bulk_task_instance_body_entities_inner import BulkDeleteActionBulkTaskInstanceBodyEntitiesInner - -# TODO update the JSON string below -json = "{}" -# create an instance of BulkDeleteActionBulkTaskInstanceBodyEntitiesInner from a JSON string -bulk_delete_action_bulk_task_instance_body_entities_inner_instance = BulkDeleteActionBulkTaskInstanceBodyEntitiesInner.from_json(json) -# print the JSON string representation of the object -print(BulkDeleteActionBulkTaskInstanceBodyEntitiesInner.to_json()) - -# convert the object into a dict -bulk_delete_action_bulk_task_instance_body_entities_inner_dict = bulk_delete_action_bulk_task_instance_body_entities_inner_instance.to_dict() -# create an instance of BulkDeleteActionBulkTaskInstanceBodyEntitiesInner from a dict -bulk_delete_action_bulk_task_instance_body_entities_inner_from_dict = BulkDeleteActionBulkTaskInstanceBodyEntitiesInner.from_dict(bulk_delete_action_bulk_task_instance_body_entities_inner_dict) -``` -[[Back to Model list]](../README.md#documentation-for-models) [[Back to API list]](../README.md#documentation-for-api-endpoints) [[Back to README]](../README.md) - - diff --git a/docs/BulkDeleteActionConnectionBody.md b/docs/BulkDeleteActionConnectionBody.md index 852bf61c..df1ca0a5 100644 --- a/docs/BulkDeleteActionConnectionBody.md +++ b/docs/BulkDeleteActionConnectionBody.md @@ -7,7 +7,7 @@ Name | Type | Description | Notes ------------ | ------------- | ------------- | ------------- **action** | **str** | The action to be performed on the entities. | **action_on_non_existence** | [**BulkActionNotOnExistence**](BulkActionNotOnExistence.md) | | [optional] -**entities** | [**List[BulkDeleteActionBulkTaskInstanceBodyEntitiesInner]**](BulkDeleteActionBulkTaskInstanceBodyEntitiesInner.md) | A list of entity id/key or entity objects to be deleted. | +**entities** | [**List[EntitiesInner]**](EntitiesInner.md) | A list of entity id/key or entity objects to be deleted. | ## Example diff --git a/docs/BulkDeleteActionPoolBody.md b/docs/BulkDeleteActionPoolBody.md index 1837f3cb..3cada058 100644 --- a/docs/BulkDeleteActionPoolBody.md +++ b/docs/BulkDeleteActionPoolBody.md @@ -7,7 +7,7 @@ Name | Type | Description | Notes ------------ | ------------- | ------------- | ------------- **action** | **str** | The action to be performed on the entities. | **action_on_non_existence** | [**BulkActionNotOnExistence**](BulkActionNotOnExistence.md) | | [optional] -**entities** | [**List[BulkDeleteActionBulkTaskInstanceBodyEntitiesInner]**](BulkDeleteActionBulkTaskInstanceBodyEntitiesInner.md) | A list of entity id/key or entity objects to be deleted. | +**entities** | [**List[EntitiesInner]**](EntitiesInner.md) | A list of entity id/key or entity objects to be deleted. | ## Example diff --git a/docs/BulkDeleteActionVariableBody.md b/docs/BulkDeleteActionVariableBody.md index 83d901d6..33539851 100644 --- a/docs/BulkDeleteActionVariableBody.md +++ b/docs/BulkDeleteActionVariableBody.md @@ -7,7 +7,7 @@ Name | Type | Description | Notes ------------ | ------------- | ------------- | ------------- **action** | **str** | The action to be performed on the entities. | **action_on_non_existence** | [**BulkActionNotOnExistence**](BulkActionNotOnExistence.md) | | [optional] -**entities** | [**List[BulkDeleteActionBulkTaskInstanceBodyEntitiesInner]**](BulkDeleteActionBulkTaskInstanceBodyEntitiesInner.md) | A list of entity id/key or entity objects to be deleted. | +**entities** | [**List[EntitiesInner]**](EntitiesInner.md) | A list of entity id/key or entity objects to be deleted. | ## Example diff --git a/docs/EntitiesInner.md b/docs/EntitiesInner.md new file mode 100644 index 00000000..3bee189e --- /dev/null +++ b/docs/EntitiesInner.md @@ -0,0 +1,36 @@ +# EntitiesInner + + +## Properties + +Name | Type | Description | Notes +------------ | ------------- | ------------- | ------------- +**include_downstream** | **bool** | | [optional] [default to False] +**include_future** | **bool** | | [optional] [default to False] +**include_past** | **bool** | | [optional] [default to False] +**include_upstream** | **bool** | | [optional] [default to False] +**map_index** | **int** | | [optional] +**new_state** | [**TaskInstanceState**](TaskInstanceState.md) | | [optional] +**note** | **str** | | [optional] +**task_id** | **str** | | + +## Example + +```python +from airflow_client.client.models.entities_inner import EntitiesInner + +# TODO update the JSON string below +json = "{}" +# create an instance of EntitiesInner from a JSON string +entities_inner_instance = EntitiesInner.from_json(json) +# print the JSON string representation of the object +print(EntitiesInner.to_json()) + +# convert the object into a dict +entities_inner_dict = entities_inner_instance.to_dict() +# create an instance of EntitiesInner from a dict +entities_inner_from_dict = EntitiesInner.from_dict(entities_inner_dict) +``` +[[Back to Model list]](../README.md#documentation-for-models) [[Back to API list]](../README.md#documentation-for-api-endpoints) [[Back to README]](../README.md) + + diff --git a/docs/LocationInner.md b/docs/LocationInner.md new file mode 100644 index 00000000..4355f5ed --- /dev/null +++ b/docs/LocationInner.md @@ -0,0 +1,28 @@ +# LocationInner + + +## Properties + +Name | Type | Description | Notes +------------ | ------------- | ------------- | ------------- + +## Example + +```python +from airflow_client.client.models.location_inner import LocationInner + +# TODO update the JSON string below +json = "{}" +# create an instance of LocationInner from a JSON string +location_inner_instance = LocationInner.from_json(json) +# print the JSON string representation of the object +print(LocationInner.to_json()) + +# convert the object into a dict +location_inner_dict = location_inner_instance.to_dict() +# create an instance of LocationInner from a dict +location_inner_from_dict = LocationInner.from_dict(location_inner_dict) +``` +[[Back to Model list]](../README.md#documentation-for-models) [[Back to API list]](../README.md#documentation-for-api-endpoints) [[Back to README]](../README.md) + + diff --git a/docs/PoolBody.md b/docs/PoolBody.md index 6e1aa3be..987507c2 100644 --- a/docs/PoolBody.md +++ b/docs/PoolBody.md @@ -9,7 +9,7 @@ Name | Type | Description | Notes **description** | **str** | | [optional] **include_deferred** | **bool** | | [optional] [default to False] **name** | **str** | | -**slots** | **int** | | +**slots** | **int** | Number of slots. Use -1 for unlimited. | ## Example diff --git a/docs/PoolPatchBody.md b/docs/PoolPatchBody.md index 3fbd7e08..4eed2d62 100644 --- a/docs/PoolPatchBody.md +++ b/docs/PoolPatchBody.md @@ -9,7 +9,7 @@ Name | Type | Description | Notes **description** | **str** | | [optional] **include_deferred** | **bool** | | [optional] **pool** | **str** | | [optional] -**slots** | **int** | | [optional] +**slots** | **int** | Number of slots. Use -1 for unlimited. | [optional] ## Example diff --git a/docs/PoolResponse.md b/docs/PoolResponse.md index 569ff6e4..f1c5988e 100644 --- a/docs/PoolResponse.md +++ b/docs/PoolResponse.md @@ -15,7 +15,7 @@ Name | Type | Description | Notes **queued_slots** | **int** | | **running_slots** | **int** | | **scheduled_slots** | **int** | | -**slots** | **int** | | +**slots** | **int** | Number of slots. Use -1 for unlimited. | ## Example diff --git a/docs/ResponseGetXcomEntry.md b/docs/ResponseGetXcomEntry.md index 9db7390a..b3a8d645 100644 --- a/docs/ResponseGetXcomEntry.md +++ b/docs/ResponseGetXcomEntry.md @@ -10,6 +10,7 @@ Name | Type | Description | Notes **key** | **str** | | **logical_date** | **datetime** | | [optional] **map_index** | **int** | | +**run_after** | **datetime** | | **run_id** | **str** | | **task_display_name** | **str** | | **task_id** | **str** | | diff --git a/docs/ValidationError.md b/docs/ValidationError.md index 9935600b..9edabcf7 100644 --- a/docs/ValidationError.md +++ b/docs/ValidationError.md @@ -5,7 +5,7 @@ Name | Type | Description | Notes ------------ | ------------- | ------------- | ------------- -**loc** | [**List[ValidationErrorLocInner]**](ValidationErrorLocInner.md) | | +**loc** | [**List[LocationInner]**](LocationInner.md) | | **msg** | **str** | | **type** | **str** | | diff --git a/docs/ValidationErrorLocInner.md b/docs/ValidationErrorLocInner.md deleted file mode 100644 index cfb36187..00000000 --- a/docs/ValidationErrorLocInner.md +++ /dev/null @@ -1,28 +0,0 @@ -# ValidationErrorLocInner - - -## Properties - -Name | Type | Description | Notes ------------- | ------------- | ------------- | ------------- - -## Example - -```python -from airflow_client.client.models.validation_error_loc_inner import ValidationErrorLocInner - -# TODO update the JSON string below -json = "{}" -# create an instance of ValidationErrorLocInner from a JSON string -validation_error_loc_inner_instance = ValidationErrorLocInner.from_json(json) -# print the JSON string representation of the object -print(ValidationErrorLocInner.to_json()) - -# convert the object into a dict -validation_error_loc_inner_dict = validation_error_loc_inner_instance.to_dict() -# create an instance of ValidationErrorLocInner from a dict -validation_error_loc_inner_from_dict = ValidationErrorLocInner.from_dict(validation_error_loc_inner_dict) -``` -[[Back to Model list]](../README.md#documentation-for-models) [[Back to API list]](../README.md#documentation-for-api-endpoints) [[Back to README]](../README.md) - - diff --git a/docs/XComResponse.md b/docs/XComResponse.md index fb495d9c..c1ba251c 100644 --- a/docs/XComResponse.md +++ b/docs/XComResponse.md @@ -11,6 +11,7 @@ Name | Type | Description | Notes **key** | **str** | | **logical_date** | **datetime** | | [optional] **map_index** | **int** | | +**run_after** | **datetime** | | **run_id** | **str** | | **task_display_name** | **str** | | **task_id** | **str** | | diff --git a/docs/XComResponseNative.md b/docs/XComResponseNative.md index ca4d4ddf..3d795f33 100644 --- a/docs/XComResponseNative.md +++ b/docs/XComResponseNative.md @@ -11,6 +11,7 @@ Name | Type | Description | Notes **key** | **str** | | **logical_date** | **datetime** | | [optional] **map_index** | **int** | | +**run_after** | **datetime** | | **run_id** | **str** | | **task_display_name** | **str** | | **task_id** | **str** | | diff --git a/docs/XComResponseString.md b/docs/XComResponseString.md index d83dff44..ea3d916b 100644 --- a/docs/XComResponseString.md +++ b/docs/XComResponseString.md @@ -11,6 +11,7 @@ Name | Type | Description | Notes **key** | **str** | | **logical_date** | **datetime** | | [optional] **map_index** | **int** | | +**run_after** | **datetime** | | **run_id** | **str** | | **task_display_name** | **str** | | **task_id** | **str** | | diff --git a/pyproject.toml b/pyproject.toml index 35e28149..c4d5dfde 100644 --- a/pyproject.toml +++ b/pyproject.toml @@ -16,7 +16,14 @@ # under the License. [build-system] -requires = ["hatchling==1.27.0"] +requires = [ + "hatchling==1.29.0", + "packaging==26.0", + "pathspec==1.0.4", + "pluggy==1.6.0", + "tomli==2.4.0; python_version < '3.11'", + "trove-classifiers==2026.1.14.14", +] build-backend = "hatchling.build" [project] @@ -45,6 +52,7 @@ classifiers = [ "Programming Language :: Python :: 3.10", "Programming Language :: Python :: 3.11", "Programming Language :: Python :: 3.12", + "Programming Language :: Python :: 3.13", "Topic :: System :: Monitoring", ] diff --git a/spec/v2.yaml b/spec/v2.yaml index 66c6fae1..96a4d516 100644 --- a/spec/v2.yaml +++ b/spec/v2.yaml @@ -2535,6 +2535,8 @@ components: title: Name type: string slots: + description: Number of slots. Use -1 for unlimited. + minimum: -1.0 title: Slots type: integer required: @@ -2572,6 +2574,8 @@ components: nullable: true type: string slots: + description: Number of slots. Use -1 for unlimited. + minimum: -1.0 nullable: true type: integer title: PoolPatchBody @@ -2607,6 +2611,8 @@ components: title: Scheduled Slots type: integer slots: + description: Number of slots. Use -1 for unlimited. + minimum: -1.0 title: Slots type: integer required: @@ -3650,6 +3656,10 @@ components: map_index: title: Map Index type: integer + run_after: + format: date-time + title: Run After + type: string run_id: title: Run Id type: string @@ -3672,6 +3682,7 @@ components: - run_id - dag_display_name - task_display_name + - run_after title: XComResponse type: object XComResponseNative: @@ -3693,6 +3704,10 @@ components: map_index: title: Map Index type: integer + run_after: + format: date-time + title: Run After + type: string run_id: title: Run Id type: string @@ -3717,6 +3732,7 @@ components: - run_id - dag_display_name - task_display_name + - run_after - value title: XComResponseNative type: object @@ -3739,6 +3755,10 @@ components: map_index: title: Map Index type: integer + run_after: + format: date-time + title: Run After + type: string run_id: title: Run Id type: string @@ -3764,6 +3784,7 @@ components: - run_id - dag_display_name - task_display_name + - run_after title: XComResponseString type: object XComUpdateBody: @@ -4404,12 +4425,6 @@ paths: schema: $ref: '#/components/schemas/HTTPExceptionResponse' description: Forbidden - '404': - content: - application/json: - schema: - $ref: '#/components/schemas/HTTPExceptionResponse' - description: Not Found '422': content: application/json: @@ -6328,12 +6343,6 @@ paths: schema: $ref: '#/components/schemas/HTTPExceptionResponse' description: Forbidden - '404': - content: - application/json: - schema: - $ref: '#/components/schemas/HTTPExceptionResponse' - description: Not Found '422': content: application/json: diff --git a/test/test_bulk_body_pool_body_actions_inner.py b/test/test_actions_inner.py similarity index 67% rename from test/test_bulk_body_pool_body_actions_inner.py rename to test/test_actions_inner.py index fdbde404..35cfb631 100644 --- a/test/test_bulk_body_pool_body_actions_inner.py +++ b/test/test_actions_inner.py @@ -14,10 +14,10 @@ import unittest -from airflow_client.client.models.bulk_body_pool_body_actions_inner import BulkBodyPoolBodyActionsInner +from airflow_client.client.models.actions_inner import ActionsInner -class TestBulkBodyPoolBodyActionsInner(unittest.TestCase): - """BulkBodyPoolBodyActionsInner unit test stubs""" +class TestActionsInner(unittest.TestCase): + """ActionsInner unit test stubs""" def setUp(self): pass @@ -25,16 +25,16 @@ def setUp(self): def tearDown(self): pass - def make_instance(self, include_optional) -> BulkBodyPoolBodyActionsInner: - """Test BulkBodyPoolBodyActionsInner + def make_instance(self, include_optional) -> ActionsInner: + """Test ActionsInner include_optional is a boolean, when False only required params are included, when True both required and optional params are included """ - # uncomment below to create an instance of `BulkBodyPoolBodyActionsInner` + # uncomment below to create an instance of `ActionsInner` """ - model = BulkBodyPoolBodyActionsInner() + model = ActionsInner() if include_optional: - return BulkBodyPoolBodyActionsInner( + return ActionsInner( action = 'delete', action_on_existence = 'fail', entities = [ @@ -43,7 +43,7 @@ def make_instance(self, include_optional) -> BulkBodyPoolBodyActionsInner: action_on_non_existence = 'fail' ) else: - return BulkBodyPoolBodyActionsInner( + return ActionsInner( action = 'delete', entities = [ null @@ -51,8 +51,8 @@ def make_instance(self, include_optional) -> BulkBodyPoolBodyActionsInner: ) """ - def testBulkBodyPoolBodyActionsInner(self): - """Test BulkBodyPoolBodyActionsInner""" + def testActionsInner(self): + """Test ActionsInner""" # inst_req_only = self.make_instance(include_optional=False) # inst_req_and_optional = self.make_instance(include_optional=True) diff --git a/test/test_bulk_body_variable_body_actions_inner.py b/test/test_actions_inner1.py similarity index 65% rename from test/test_bulk_body_variable_body_actions_inner.py rename to test/test_actions_inner1.py index b061074b..f6e3f62b 100644 --- a/test/test_bulk_body_variable_body_actions_inner.py +++ b/test/test_actions_inner1.py @@ -14,10 +14,10 @@ import unittest -from airflow_client.client.models.bulk_body_variable_body_actions_inner import BulkBodyVariableBodyActionsInner +from airflow_client.client.models.actions_inner1 import ActionsInner1 -class TestBulkBodyVariableBodyActionsInner(unittest.TestCase): - """BulkBodyVariableBodyActionsInner unit test stubs""" +class TestActionsInner1(unittest.TestCase): + """ActionsInner1 unit test stubs""" def setUp(self): pass @@ -25,16 +25,16 @@ def setUp(self): def tearDown(self): pass - def make_instance(self, include_optional) -> BulkBodyVariableBodyActionsInner: - """Test BulkBodyVariableBodyActionsInner + def make_instance(self, include_optional) -> ActionsInner1: + """Test ActionsInner1 include_optional is a boolean, when False only required params are included, when True both required and optional params are included """ - # uncomment below to create an instance of `BulkBodyVariableBodyActionsInner` + # uncomment below to create an instance of `ActionsInner1` """ - model = BulkBodyVariableBodyActionsInner() + model = ActionsInner1() if include_optional: - return BulkBodyVariableBodyActionsInner( + return ActionsInner1( action = 'delete', action_on_existence = 'fail', entities = [ @@ -43,7 +43,7 @@ def make_instance(self, include_optional) -> BulkBodyVariableBodyActionsInner: action_on_non_existence = 'fail' ) else: - return BulkBodyVariableBodyActionsInner( + return ActionsInner1( action = 'delete', entities = [ null @@ -51,8 +51,8 @@ def make_instance(self, include_optional) -> BulkBodyVariableBodyActionsInner: ) """ - def testBulkBodyVariableBodyActionsInner(self): - """Test BulkBodyVariableBodyActionsInner""" + def testActionsInner1(self): + """Test ActionsInner1""" # inst_req_only = self.make_instance(include_optional=False) # inst_req_and_optional = self.make_instance(include_optional=True) diff --git a/test/test_bulk_body_connection_body_actions_inner.py b/test/test_actions_inner2.py similarity index 65% rename from test/test_bulk_body_connection_body_actions_inner.py rename to test/test_actions_inner2.py index 9cb0d2c7..1c382f42 100644 --- a/test/test_bulk_body_connection_body_actions_inner.py +++ b/test/test_actions_inner2.py @@ -14,10 +14,10 @@ import unittest -from airflow_client.client.models.bulk_body_connection_body_actions_inner import BulkBodyConnectionBodyActionsInner +from airflow_client.client.models.actions_inner2 import ActionsInner2 -class TestBulkBodyConnectionBodyActionsInner(unittest.TestCase): - """BulkBodyConnectionBodyActionsInner unit test stubs""" +class TestActionsInner2(unittest.TestCase): + """ActionsInner2 unit test stubs""" def setUp(self): pass @@ -25,16 +25,16 @@ def setUp(self): def tearDown(self): pass - def make_instance(self, include_optional) -> BulkBodyConnectionBodyActionsInner: - """Test BulkBodyConnectionBodyActionsInner + def make_instance(self, include_optional) -> ActionsInner2: + """Test ActionsInner2 include_optional is a boolean, when False only required params are included, when True both required and optional params are included """ - # uncomment below to create an instance of `BulkBodyConnectionBodyActionsInner` + # uncomment below to create an instance of `ActionsInner2` """ - model = BulkBodyConnectionBodyActionsInner() + model = ActionsInner2() if include_optional: - return BulkBodyConnectionBodyActionsInner( + return ActionsInner2( action = 'delete', action_on_existence = 'fail', entities = [ @@ -43,7 +43,7 @@ def make_instance(self, include_optional) -> BulkBodyConnectionBodyActionsInner: action_on_non_existence = 'fail' ) else: - return BulkBodyConnectionBodyActionsInner( + return ActionsInner2( action = 'delete', entities = [ null @@ -51,8 +51,8 @@ def make_instance(self, include_optional) -> BulkBodyConnectionBodyActionsInner: ) """ - def testBulkBodyConnectionBodyActionsInner(self): - """Test BulkBodyConnectionBodyActionsInner""" + def testActionsInner2(self): + """Test ActionsInner2""" # inst_req_only = self.make_instance(include_optional=False) # inst_req_and_optional = self.make_instance(include_optional=True) diff --git a/test/test_bulk_body_bulk_task_instance_body_actions_inner.py b/test/test_actions_inner3.py similarity index 63% rename from test/test_bulk_body_bulk_task_instance_body_actions_inner.py rename to test/test_actions_inner3.py index ed1b902d..2b7112c4 100644 --- a/test/test_bulk_body_bulk_task_instance_body_actions_inner.py +++ b/test/test_actions_inner3.py @@ -14,10 +14,10 @@ import unittest -from airflow_client.client.models.bulk_body_bulk_task_instance_body_actions_inner import BulkBodyBulkTaskInstanceBodyActionsInner +from airflow_client.client.models.actions_inner3 import ActionsInner3 -class TestBulkBodyBulkTaskInstanceBodyActionsInner(unittest.TestCase): - """BulkBodyBulkTaskInstanceBodyActionsInner unit test stubs""" +class TestActionsInner3(unittest.TestCase): + """ActionsInner3 unit test stubs""" def setUp(self): pass @@ -25,16 +25,16 @@ def setUp(self): def tearDown(self): pass - def make_instance(self, include_optional) -> BulkBodyBulkTaskInstanceBodyActionsInner: - """Test BulkBodyBulkTaskInstanceBodyActionsInner + def make_instance(self, include_optional) -> ActionsInner3: + """Test ActionsInner3 include_optional is a boolean, when False only required params are included, when True both required and optional params are included """ - # uncomment below to create an instance of `BulkBodyBulkTaskInstanceBodyActionsInner` + # uncomment below to create an instance of `ActionsInner3` """ - model = BulkBodyBulkTaskInstanceBodyActionsInner() + model = ActionsInner3() if include_optional: - return BulkBodyBulkTaskInstanceBodyActionsInner( + return ActionsInner3( action = 'delete', action_on_existence = 'fail', entities = [ @@ -43,7 +43,7 @@ def make_instance(self, include_optional) -> BulkBodyBulkTaskInstanceBodyActions action_on_non_existence = 'fail' ) else: - return BulkBodyBulkTaskInstanceBodyActionsInner( + return ActionsInner3( action = 'delete', entities = [ null @@ -51,8 +51,8 @@ def make_instance(self, include_optional) -> BulkBodyBulkTaskInstanceBodyActions ) """ - def testBulkBodyBulkTaskInstanceBodyActionsInner(self): - """Test BulkBodyBulkTaskInstanceBodyActionsInner""" + def testActionsInner3(self): + """Test ActionsInner3""" # inst_req_only = self.make_instance(include_optional=False) # inst_req_and_optional = self.make_instance(include_optional=True) diff --git a/test/test_bulk_create_action_pool_body.py b/test/test_bulk_create_action_pool_body.py index 36250680..c4df10b5 100644 --- a/test/test_bulk_create_action_pool_body.py +++ b/test/test_bulk_create_action_pool_body.py @@ -42,7 +42,7 @@ def make_instance(self, include_optional) -> BulkCreateActionPoolBody: description = '', include_deferred = True, name = '', - slots = 56, ) + slots = -1.0, ) ] ) else: @@ -53,7 +53,7 @@ def make_instance(self, include_optional) -> BulkCreateActionPoolBody: description = '', include_deferred = True, name = '', - slots = 56, ) + slots = -1.0, ) ], ) """ diff --git a/test/test_bulk_update_action_pool_body.py b/test/test_bulk_update_action_pool_body.py index 35e9dc51..9b17dc37 100644 --- a/test/test_bulk_update_action_pool_body.py +++ b/test/test_bulk_update_action_pool_body.py @@ -42,7 +42,7 @@ def make_instance(self, include_optional) -> BulkUpdateActionPoolBody: description = '', include_deferred = True, name = '', - slots = 56, ) + slots = -1.0, ) ] ) else: @@ -53,7 +53,7 @@ def make_instance(self, include_optional) -> BulkUpdateActionPoolBody: description = '', include_deferred = True, name = '', - slots = 56, ) + slots = -1.0, ) ], ) """ diff --git a/test/test_bulk_delete_action_bulk_task_instance_body_entities_inner.py b/test/test_entities_inner.py similarity index 60% rename from test/test_bulk_delete_action_bulk_task_instance_body_entities_inner.py rename to test/test_entities_inner.py index d0eae691..af1201fd 100644 --- a/test/test_bulk_delete_action_bulk_task_instance_body_entities_inner.py +++ b/test/test_entities_inner.py @@ -14,10 +14,10 @@ import unittest -from airflow_client.client.models.bulk_delete_action_bulk_task_instance_body_entities_inner import BulkDeleteActionBulkTaskInstanceBodyEntitiesInner +from airflow_client.client.models.entities_inner import EntitiesInner -class TestBulkDeleteActionBulkTaskInstanceBodyEntitiesInner(unittest.TestCase): - """BulkDeleteActionBulkTaskInstanceBodyEntitiesInner unit test stubs""" +class TestEntitiesInner(unittest.TestCase): + """EntitiesInner unit test stubs""" def setUp(self): pass @@ -25,16 +25,16 @@ def setUp(self): def tearDown(self): pass - def make_instance(self, include_optional) -> BulkDeleteActionBulkTaskInstanceBodyEntitiesInner: - """Test BulkDeleteActionBulkTaskInstanceBodyEntitiesInner + def make_instance(self, include_optional) -> EntitiesInner: + """Test EntitiesInner include_optional is a boolean, when False only required params are included, when True both required and optional params are included """ - # uncomment below to create an instance of `BulkDeleteActionBulkTaskInstanceBodyEntitiesInner` + # uncomment below to create an instance of `EntitiesInner` """ - model = BulkDeleteActionBulkTaskInstanceBodyEntitiesInner() + model = EntitiesInner() if include_optional: - return BulkDeleteActionBulkTaskInstanceBodyEntitiesInner( + return EntitiesInner( include_downstream = True, include_future = True, include_past = True, @@ -45,13 +45,13 @@ def make_instance(self, include_optional) -> BulkDeleteActionBulkTaskInstanceBod task_id = '' ) else: - return BulkDeleteActionBulkTaskInstanceBodyEntitiesInner( + return EntitiesInner( task_id = '', ) """ - def testBulkDeleteActionBulkTaskInstanceBodyEntitiesInner(self): - """Test BulkDeleteActionBulkTaskInstanceBodyEntitiesInner""" + def testEntitiesInner(self): + """Test EntitiesInner""" # inst_req_only = self.make_instance(include_optional=False) # inst_req_and_optional = self.make_instance(include_optional=True) diff --git a/test/test_validation_error_loc_inner.py b/test/test_location_inner.py similarity index 63% rename from test/test_validation_error_loc_inner.py rename to test/test_location_inner.py index b1dfd16a..3b4db01b 100644 --- a/test/test_validation_error_loc_inner.py +++ b/test/test_location_inner.py @@ -14,10 +14,10 @@ import unittest -from airflow_client.client.models.validation_error_loc_inner import ValidationErrorLocInner +from airflow_client.client.models.location_inner import LocationInner -class TestValidationErrorLocInner(unittest.TestCase): - """ValidationErrorLocInner unit test stubs""" +class TestLocationInner(unittest.TestCase): + """LocationInner unit test stubs""" def setUp(self): pass @@ -25,24 +25,24 @@ def setUp(self): def tearDown(self): pass - def make_instance(self, include_optional) -> ValidationErrorLocInner: - """Test ValidationErrorLocInner + def make_instance(self, include_optional) -> LocationInner: + """Test LocationInner include_optional is a boolean, when False only required params are included, when True both required and optional params are included """ - # uncomment below to create an instance of `ValidationErrorLocInner` + # uncomment below to create an instance of `LocationInner` """ - model = ValidationErrorLocInner() + model = LocationInner() if include_optional: - return ValidationErrorLocInner( + return LocationInner( ) else: - return ValidationErrorLocInner( + return LocationInner( ) """ - def testValidationErrorLocInner(self): - """Test ValidationErrorLocInner""" + def testLocationInner(self): + """Test LocationInner""" # inst_req_only = self.make_instance(include_optional=False) # inst_req_and_optional = self.make_instance(include_optional=True) diff --git a/test/test_pool_body.py b/test/test_pool_body.py index da9b7ec8..f343c44e 100644 --- a/test/test_pool_body.py +++ b/test/test_pool_body.py @@ -38,12 +38,12 @@ def make_instance(self, include_optional) -> PoolBody: description = '', include_deferred = True, name = '', - slots = 56 + slots = -1.0 ) else: return PoolBody( name = '', - slots = 56, + slots = -1.0, ) """ diff --git a/test/test_pool_collection_response.py b/test/test_pool_collection_response.py index 7210b832..7195b426 100644 --- a/test/test_pool_collection_response.py +++ b/test/test_pool_collection_response.py @@ -46,7 +46,7 @@ def make_instance(self, include_optional) -> PoolCollectionResponse: queued_slots = 56, running_slots = 56, scheduled_slots = 56, - slots = 56, ) + slots = -1.0, ) ], total_entries = 56 ) @@ -63,7 +63,7 @@ def make_instance(self, include_optional) -> PoolCollectionResponse: queued_slots = 56, running_slots = 56, scheduled_slots = 56, - slots = 56, ) + slots = -1.0, ) ], total_entries = 56, ) diff --git a/test/test_pool_patch_body.py b/test/test_pool_patch_body.py index d0fa987f..6cf664c7 100644 --- a/test/test_pool_patch_body.py +++ b/test/test_pool_patch_body.py @@ -38,7 +38,7 @@ def make_instance(self, include_optional) -> PoolPatchBody: description = '', include_deferred = True, pool = '', - slots = 56 + slots = -1.0 ) else: return PoolPatchBody( diff --git a/test/test_pool_response.py b/test/test_pool_response.py index fdf3da7a..8cc47f2b 100644 --- a/test/test_pool_response.py +++ b/test/test_pool_response.py @@ -44,7 +44,7 @@ def make_instance(self, include_optional) -> PoolResponse: queued_slots = 56, running_slots = 56, scheduled_slots = 56, - slots = 56 + slots = -1.0 ) else: return PoolResponse( @@ -56,7 +56,7 @@ def make_instance(self, include_optional) -> PoolResponse: queued_slots = 56, running_slots = 56, scheduled_slots = 56, - slots = 56, + slots = -1.0, ) """ diff --git a/test/test_response_get_xcom_entry.py b/test/test_response_get_xcom_entry.py index 817cb108..fd79ab16 100644 --- a/test/test_response_get_xcom_entry.py +++ b/test/test_response_get_xcom_entry.py @@ -40,6 +40,7 @@ def make_instance(self, include_optional) -> ResponseGetXcomEntry: key = '', logical_date = datetime.datetime.strptime('2013-10-20 19:20:30.00', '%Y-%m-%d %H:%M:%S.%f'), map_index = 56, + run_after = datetime.datetime.strptime('2013-10-20 19:20:30.00', '%Y-%m-%d %H:%M:%S.%f'), run_id = '', task_display_name = '', task_id = '', @@ -52,6 +53,7 @@ def make_instance(self, include_optional) -> ResponseGetXcomEntry: dag_id = '', key = '', map_index = 56, + run_after = datetime.datetime.strptime('2013-10-20 19:20:30.00', '%Y-%m-%d %H:%M:%S.%f'), run_id = '', task_display_name = '', task_id = '', diff --git a/test/test_x_com_collection_response.py b/test/test_x_com_collection_response.py index dec14605..eefe4899 100644 --- a/test/test_x_com_collection_response.py +++ b/test/test_x_com_collection_response.py @@ -43,6 +43,7 @@ def make_instance(self, include_optional) -> XComCollectionResponse: key = '', logical_date = datetime.datetime.strptime('2013-10-20 19:20:30.00', '%Y-%m-%d %H:%M:%S.%f'), map_index = 56, + run_after = datetime.datetime.strptime('2013-10-20 19:20:30.00', '%Y-%m-%d %H:%M:%S.%f'), run_id = '', task_display_name = '', task_id = '', @@ -59,6 +60,7 @@ def make_instance(self, include_optional) -> XComCollectionResponse: key = '', logical_date = datetime.datetime.strptime('2013-10-20 19:20:30.00', '%Y-%m-%d %H:%M:%S.%f'), map_index = 56, + run_after = datetime.datetime.strptime('2013-10-20 19:20:30.00', '%Y-%m-%d %H:%M:%S.%f'), run_id = '', task_display_name = '', task_id = '', diff --git a/test/test_x_com_response.py b/test/test_x_com_response.py index 01c967d3..ce7e2a7e 100644 --- a/test/test_x_com_response.py +++ b/test/test_x_com_response.py @@ -40,6 +40,7 @@ def make_instance(self, include_optional) -> XComResponse: key = '', logical_date = datetime.datetime.strptime('2013-10-20 19:20:30.00', '%Y-%m-%d %H:%M:%S.%f'), map_index = 56, + run_after = datetime.datetime.strptime('2013-10-20 19:20:30.00', '%Y-%m-%d %H:%M:%S.%f'), run_id = '', task_display_name = '', task_id = '', @@ -51,6 +52,7 @@ def make_instance(self, include_optional) -> XComResponse: dag_id = '', key = '', map_index = 56, + run_after = datetime.datetime.strptime('2013-10-20 19:20:30.00', '%Y-%m-%d %H:%M:%S.%f'), run_id = '', task_display_name = '', task_id = '', diff --git a/test/test_x_com_response_native.py b/test/test_x_com_response_native.py index 8c202e85..e50f4c1c 100644 --- a/test/test_x_com_response_native.py +++ b/test/test_x_com_response_native.py @@ -40,6 +40,7 @@ def make_instance(self, include_optional) -> XComResponseNative: key = '', logical_date = datetime.datetime.strptime('2013-10-20 19:20:30.00', '%Y-%m-%d %H:%M:%S.%f'), map_index = 56, + run_after = datetime.datetime.strptime('2013-10-20 19:20:30.00', '%Y-%m-%d %H:%M:%S.%f'), run_id = '', task_display_name = '', task_id = '', @@ -52,6 +53,7 @@ def make_instance(self, include_optional) -> XComResponseNative: dag_id = '', key = '', map_index = 56, + run_after = datetime.datetime.strptime('2013-10-20 19:20:30.00', '%Y-%m-%d %H:%M:%S.%f'), run_id = '', task_display_name = '', task_id = '', diff --git a/test/test_x_com_response_string.py b/test/test_x_com_response_string.py index 850a746d..4aed0361 100644 --- a/test/test_x_com_response_string.py +++ b/test/test_x_com_response_string.py @@ -40,6 +40,7 @@ def make_instance(self, include_optional) -> XComResponseString: key = '', logical_date = datetime.datetime.strptime('2013-10-20 19:20:30.00', '%Y-%m-%d %H:%M:%S.%f'), map_index = 56, + run_after = datetime.datetime.strptime('2013-10-20 19:20:30.00', '%Y-%m-%d %H:%M:%S.%f'), run_id = '', task_display_name = '', task_id = '', @@ -52,6 +53,7 @@ def make_instance(self, include_optional) -> XComResponseString: dag_id = '', key = '', map_index = 56, + run_after = datetime.datetime.strptime('2013-10-20 19:20:30.00', '%Y-%m-%d %H:%M:%S.%f'), run_id = '', task_display_name = '', task_id = '', diff --git a/version.txt b/version.txt index 9cec7165..c848fb9c 100644 --- a/version.txt +++ b/version.txt @@ -1 +1 @@ -3.1.6 +3.1.8 From f67b7fb0317c18d5c619f8bb0de989d5700bc946 Mon Sep 17 00:00:00 2001 From: vatsrahul1001 Date: Wed, 25 Mar 2026 20:02:05 +0530 Subject: [PATCH 2/2] update to python3.10 in ci --- .github/workflows/ci.yml | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/.github/workflows/ci.yml b/.github/workflows/ci.yml index 06840719..995b7158 100644 --- a/.github/workflows/ci.yml +++ b/.github/workflows/ci.yml @@ -15,7 +15,7 @@ jobs: - name: Set up Python uses: actions/setup-python@v5 with: - python-version: 3.9 + python-version: "3.10" cache: 'pip' - name: Install hatch run: |