Update Python Client to 3.1.8rc1 (#148)
* Update Python Client to 3.1.8rc1
* update to python3.10 in ci
diff --git a/.github/workflows/ci.yml b/.github/workflows/ci.yml
index 0684071..995b715 100644
--- a/.github/workflows/ci.yml
+++ b/.github/workflows/ci.yml
@@ -15,7 +15,7 @@
- name: Set up Python
uses: actions/setup-python@v5
with:
- python-version: 3.9
+ python-version: "3.10"
cache: 'pip'
- name: Install hatch
run: |
diff --git a/CHANGELOG.md b/CHANGELOG.md
index b5e9aa8..8ea0d3d 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 d3bc15d..c2913a4 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 d46fb41..ea62a74 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 @@
'200': "QueuedEventCollectionResponse",
'401': "HTTPExceptionResponse",
'403': "HTTPExceptionResponse",
- '404': "HTTPExceptionResponse",
'422': "HTTPValidationError",
}
response_data = self.api_client.call_api(
@@ -2738,7 +2736,6 @@
'200': "QueuedEventCollectionResponse",
'401': "HTTPExceptionResponse",
'403': "HTTPExceptionResponse",
- '404': "HTTPExceptionResponse",
'422': "HTTPValidationError",
}
response_data = self.api_client.call_api(
@@ -2813,7 +2810,6 @@
'200': "QueuedEventCollectionResponse",
'401': "HTTPExceptionResponse",
'403': "HTTPExceptionResponse",
- '404': "HTTPExceptionResponse",
'422': "HTTPValidationError",
}
response_data = self.api_client.call_api(
@@ -3640,7 +3636,6 @@
'200': "QueuedEventCollectionResponse",
'401': "HTTPExceptionResponse",
'403': "HTTPExceptionResponse",
- '404': "HTTPExceptionResponse",
'422': "HTTPValidationError",
}
response_data = self.api_client.call_api(
@@ -3715,7 +3710,6 @@
'200': "QueuedEventCollectionResponse",
'401': "HTTPExceptionResponse",
'403': "HTTPExceptionResponse",
- '404': "HTTPExceptionResponse",
'422': "HTTPValidationError",
}
response_data = self.api_client.call_api(
@@ -3790,7 +3784,6 @@
'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 d537265..62a2f37 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 c0fe410..0c245d0 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 285ef92..81ac304 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 46b7a32..f3dd99e 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 422d80e..c204428 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 617f8c0..ee4a852 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 @@
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 @@
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 @@
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 575e683..81010e7 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 979dc1d..4d40be0 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 67024b2..1f24f01 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 2b0a7d4..f94244e 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 9b6ecd1..93083bc 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 cd5410e..3649225 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 @@
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 @@
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 @@
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 504f4db..e4a88c4 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 ecbff9b..9f239e6 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 3729fa5..f18e31c 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 21ad044..7332a20 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 eab6962..3754124 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 3f03801..cb5ad57 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 345a210..a6f3e55 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 50f9b1d..df49191 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 c0470ca..811210e 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 1d87eb2..2542b34 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 @@
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 @@
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 @@
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 1f9eda1..8bd0e98 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 3e7dc5a..1011532 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 ebf4c49..fe49e7f 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 de136cc..715e08e 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 @@
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 @@
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 13c9ae3..7856eb6 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 @@
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 @@
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 @@
"""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 @@
"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 00bb2d3..3272c9f 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 c3b6d10..12359fd 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 e33168a..8621ffe 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 @@
@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 @@
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 @@
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 5a9ae91..5bb236b 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 @@
@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 @@
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 @@
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 84%
rename from airflow_client/client/models/bulk_body_pool_body_actions_inner.py
rename to airflow_client/client/models/actions_inner2.py
index 6cdad81..d62e119 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 @@
@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 @@
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 @@
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 83%
rename from airflow_client/client/models/bulk_body_variable_body_actions_inner.py
rename to airflow_client/client/models/actions_inner3.py
index 3eb958f..513662f 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 @@
@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 @@
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 @@
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 0119517..ab8b60b 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 @@
"""
BulkBodyBulkTaskInstanceBody
""" # noqa: E501
- actions: List[BulkBodyBulkTaskInstanceBodyActionsInner]
+ actions: List[ActionsInner]
__properties: ClassVar[List[str]] = ["actions"]
model_config = ConfigDict(
@@ -88,7 +88,7 @@
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 f55a2e8..9187afd 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 @@
"""
BulkBodyConnectionBody
""" # noqa: E501
- actions: List[BulkBodyConnectionBodyActionsInner]
+ actions: List[ActionsInner1]
__properties: ClassVar[List[str]] = ["actions"]
model_config = ConfigDict(
@@ -88,7 +88,7 @@
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 5229c28..4486510 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 @@
"""
BulkBodyPoolBody
""" # noqa: E501
- actions: List[BulkBodyPoolBodyActionsInner]
+ actions: List[ActionsInner2]
__properties: ClassVar[List[str]] = ["actions"]
model_config = ConfigDict(
@@ -88,7 +88,7 @@
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 242ef07..9153696 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 @@
"""
BulkBodyVariableBody
""" # noqa: E501
- actions: List[BulkBodyVariableBodyActionsInner]
+ actions: List[ActionsInner3]
__properties: ClassVar[List[str]] = ["actions"]
model_config = ConfigDict(
@@ -88,7 +88,7 @@
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 de80b8c..ecc1bfc 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 @@
""" # 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 @@
_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 8011f00..587e2ca 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 @@
""" # 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 @@
_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 0ed5953..ed2f72c 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 @@
""" # 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 @@
_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 e7c3503..85e080a 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 @@
""" # 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 @@
_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 f68f6db..0aaaa6e 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 @@
@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 @@
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 @@
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 e51550f..70ef304 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 @@
@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 @@
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 @@
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 148a855..bf24849 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 @@
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 278be6f..4e92e1e 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 @@
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 4f995b6..ea8fe6c 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 @@
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 476e7e6..4799d69 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 @@
"""
ValidationError
""" # noqa: E501
- loc: List[ValidationErrorLocInner]
+ loc: List[LocationInner]
msg: StrictStr
type: StrictStr
__properties: ClassVar[List[str]] = ["loc", "msg", "type"]
@@ -90,7 +90,7 @@
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 7c846bf..1e4c2f3 100644
--- a/airflow_client/client/models/x_com_response.py
+++ b/airflow_client/client/models/x_com_response.py
@@ -32,11 +32,12 @@
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 @@
"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 948da66..17a0276 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 @@
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 @@
"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 aa426f1..daf4050 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 @@
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 @@
"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 0000000..f46b740
--- /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 0000000..ba49c6d
--- /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 0000000..927e823
--- /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 0000000..9f44841
--- /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 e35baae..24b063f 100644
--- a/docs/AssetApi.md
+++ b/docs/AssetApi.md
@@ -808,7 +808,6 @@
**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 @@
**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 bcc390d..d2f4521 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 522d990..0000000
--- 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 74895bf..982815f 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 c0b2cba..0000000
--- 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 1258088..bc47b85 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 82597b7..0000000
--- 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 525d451..e8df1a8 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 10cf393..0000000
--- 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 5a757fb..6aed3c2 100644
--- a/docs/BulkDeleteActionBulkTaskInstanceBody.md
+++ b/docs/BulkDeleteActionBulkTaskInstanceBody.md
@@ -7,7 +7,7 @@
------------ | ------------- | ------------- | -------------
**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 c98c117..0000000
--- 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 852bf61..df1ca0a 100644
--- a/docs/BulkDeleteActionConnectionBody.md
+++ b/docs/BulkDeleteActionConnectionBody.md
@@ -7,7 +7,7 @@
------------ | ------------- | ------------- | -------------
**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 1837f3c..3cada05 100644
--- a/docs/BulkDeleteActionPoolBody.md
+++ b/docs/BulkDeleteActionPoolBody.md
@@ -7,7 +7,7 @@
------------ | ------------- | ------------- | -------------
**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 83d901d..3353985 100644
--- a/docs/BulkDeleteActionVariableBody.md
+++ b/docs/BulkDeleteActionVariableBody.md
@@ -7,7 +7,7 @@
------------ | ------------- | ------------- | -------------
**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 0000000..3bee189
--- /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 0000000..4355f5e
--- /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 6e1aa3b..987507c 100644
--- a/docs/PoolBody.md
+++ b/docs/PoolBody.md
@@ -9,7 +9,7 @@
**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 3fbd7e0..4eed2d6 100644
--- a/docs/PoolPatchBody.md
+++ b/docs/PoolPatchBody.md
@@ -9,7 +9,7 @@
**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 569ff6e..f1c5988 100644
--- a/docs/PoolResponse.md
+++ b/docs/PoolResponse.md
@@ -15,7 +15,7 @@
**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 9db7390..b3a8d64 100644
--- a/docs/ResponseGetXcomEntry.md
+++ b/docs/ResponseGetXcomEntry.md
@@ -10,6 +10,7 @@
**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 9935600..9edabcf 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 cfb3618..0000000
--- 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 fb495d9..c1ba251 100644
--- a/docs/XComResponse.md
+++ b/docs/XComResponse.md
@@ -11,6 +11,7 @@
**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 ca4d4dd..3d795f3 100644
--- a/docs/XComResponseNative.md
+++ b/docs/XComResponseNative.md
@@ -11,6 +11,7 @@
**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 d83dff4..ea3d916 100644
--- a/docs/XComResponseString.md
+++ b/docs/XComResponseString.md
@@ -11,6 +11,7 @@
**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 35e2814..c4d5dfd 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 @@
"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 66c6fae..96a4d51 100644
--- a/spec/v2.yaml
+++ b/spec/v2.yaml
@@ -2535,6 +2535,8 @@
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 @@
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 @@
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 @@
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 @@
- run_id
- dag_display_name
- task_display_name
+ - run_after
title: XComResponse
type: object
XComResponseNative:
@@ -3693,6 +3704,10 @@
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 @@
- run_id
- dag_display_name
- task_display_name
+ - run_after
- value
title: XComResponseNative
type: object
@@ -3739,6 +3755,10 @@
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 @@
- run_id
- dag_display_name
- task_display_name
+ - run_after
title: XComResponseString
type: object
XComUpdateBody:
@@ -4404,12 +4425,6 @@
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 @@
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%
copy from test/test_bulk_body_pool_body_actions_inner.py
copy to test/test_actions_inner.py
index fdbde40..35cfb63 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 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 @@
action_on_non_existence = 'fail'
)
else:
- return BulkBodyPoolBodyActionsInner(
+ return ActionsInner(
action = 'delete',
entities = [
null
@@ -51,8 +51,8 @@
)
"""
- 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_pool_body_actions_inner.py b/test/test_actions_inner1.py
similarity index 67%
rename from test/test_bulk_body_pool_body_actions_inner.py
rename to test/test_actions_inner1.py
index fdbde40..f6e3f62 100644
--- a/test/test_bulk_body_pool_body_actions_inner.py
+++ b/test/test_actions_inner1.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_inner1 import ActionsInner1
-class TestBulkBodyPoolBodyActionsInner(unittest.TestCase):
- """BulkBodyPoolBodyActionsInner unit test stubs"""
+class TestActionsInner1(unittest.TestCase):
+ """ActionsInner1 unit test stubs"""
def setUp(self):
pass
@@ -25,16 +25,16 @@
def tearDown(self):
pass
- def make_instance(self, include_optional) -> BulkBodyPoolBodyActionsInner:
- """Test BulkBodyPoolBodyActionsInner
+ 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 `BulkBodyPoolBodyActionsInner`
+ # uncomment below to create an instance of `ActionsInner1`
"""
- model = BulkBodyPoolBodyActionsInner()
+ model = ActionsInner1()
if include_optional:
- return BulkBodyPoolBodyActionsInner(
+ return ActionsInner1(
action = 'delete',
action_on_existence = 'fail',
entities = [
@@ -43,7 +43,7 @@
action_on_non_existence = 'fail'
)
else:
- return BulkBodyPoolBodyActionsInner(
+ return ActionsInner1(
action = 'delete',
entities = [
null
@@ -51,8 +51,8 @@
)
"""
- def testBulkBodyPoolBodyActionsInner(self):
- """Test BulkBodyPoolBodyActionsInner"""
+ 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_pool_body_actions_inner.py b/test/test_actions_inner2.py
similarity index 67%
copy from test/test_bulk_body_pool_body_actions_inner.py
copy to test/test_actions_inner2.py
index fdbde40..1c382f4 100644
--- a/test/test_bulk_body_pool_body_actions_inner.py
+++ b/test/test_actions_inner2.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_inner2 import ActionsInner2
-class TestBulkBodyPoolBodyActionsInner(unittest.TestCase):
- """BulkBodyPoolBodyActionsInner unit test stubs"""
+class TestActionsInner2(unittest.TestCase):
+ """ActionsInner2 unit test stubs"""
def setUp(self):
pass
@@ -25,16 +25,16 @@
def tearDown(self):
pass
- def make_instance(self, include_optional) -> BulkBodyPoolBodyActionsInner:
- """Test BulkBodyPoolBodyActionsInner
+ 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 `BulkBodyPoolBodyActionsInner`
+ # uncomment below to create an instance of `ActionsInner2`
"""
- model = BulkBodyPoolBodyActionsInner()
+ model = ActionsInner2()
if include_optional:
- return BulkBodyPoolBodyActionsInner(
+ return ActionsInner2(
action = 'delete',
action_on_existence = 'fail',
entities = [
@@ -43,7 +43,7 @@
action_on_non_existence = 'fail'
)
else:
- return BulkBodyPoolBodyActionsInner(
+ return ActionsInner2(
action = 'delete',
entities = [
null
@@ -51,8 +51,8 @@
)
"""
- def testBulkBodyPoolBodyActionsInner(self):
- """Test BulkBodyPoolBodyActionsInner"""
+ 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_pool_body_actions_inner.py b/test/test_actions_inner3.py
similarity index 67%
copy from test/test_bulk_body_pool_body_actions_inner.py
copy to test/test_actions_inner3.py
index fdbde40..2b7112c 100644
--- a/test/test_bulk_body_pool_body_actions_inner.py
+++ b/test/test_actions_inner3.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_inner3 import ActionsInner3
-class TestBulkBodyPoolBodyActionsInner(unittest.TestCase):
- """BulkBodyPoolBodyActionsInner unit test stubs"""
+class TestActionsInner3(unittest.TestCase):
+ """ActionsInner3 unit test stubs"""
def setUp(self):
pass
@@ -25,16 +25,16 @@
def tearDown(self):
pass
- def make_instance(self, include_optional) -> BulkBodyPoolBodyActionsInner:
- """Test BulkBodyPoolBodyActionsInner
+ 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 `BulkBodyPoolBodyActionsInner`
+ # uncomment below to create an instance of `ActionsInner3`
"""
- model = BulkBodyPoolBodyActionsInner()
+ model = ActionsInner3()
if include_optional:
- return BulkBodyPoolBodyActionsInner(
+ return ActionsInner3(
action = 'delete',
action_on_existence = 'fail',
entities = [
@@ -43,7 +43,7 @@
action_on_non_existence = 'fail'
)
else:
- return BulkBodyPoolBodyActionsInner(
+ return ActionsInner3(
action = 'delete',
entities = [
null
@@ -51,8 +51,8 @@
)
"""
- def testBulkBodyPoolBodyActionsInner(self):
- """Test BulkBodyPoolBodyActionsInner"""
+ 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_body_bulk_task_instance_body_actions_inner.py b/test/test_bulk_body_bulk_task_instance_body_actions_inner.py
deleted file mode 100644
index ed1b902..0000000
--- a/test/test_bulk_body_bulk_task_instance_body_actions_inner.py
+++ /dev/null
@@ -1,60 +0,0 @@
-# coding: utf-8
-
-"""
- Airflow API
-
- Airflow API. All endpoints located under ``/api/v2`` can be used safely, are stable and backward compatible. Endpoints located under ``/ui`` are dedicated to the UI and are subject to breaking change depending on the need of the frontend. Users should not rely on those but use the public ones instead.
-
- The version of the OpenAPI document: 2
- Generated by OpenAPI Generator (https://openapi-generator.tech)
-
- Do not edit the class manually.
-""" # noqa: E501
-
-
-import unittest
-
-from airflow_client.client.models.bulk_body_bulk_task_instance_body_actions_inner import BulkBodyBulkTaskInstanceBodyActionsInner
-
-class TestBulkBodyBulkTaskInstanceBodyActionsInner(unittest.TestCase):
- """BulkBodyBulkTaskInstanceBodyActionsInner unit test stubs"""
-
- def setUp(self):
- pass
-
- def tearDown(self):
- pass
-
- def make_instance(self, include_optional) -> BulkBodyBulkTaskInstanceBodyActionsInner:
- """Test BulkBodyBulkTaskInstanceBodyActionsInner
- 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`
- """
- model = BulkBodyBulkTaskInstanceBodyActionsInner()
- if include_optional:
- return BulkBodyBulkTaskInstanceBodyActionsInner(
- action = 'delete',
- action_on_existence = 'fail',
- entities = [
- null
- ],
- action_on_non_existence = 'fail'
- )
- else:
- return BulkBodyBulkTaskInstanceBodyActionsInner(
- action = 'delete',
- entities = [
- null
- ],
- )
- """
-
- def testBulkBodyBulkTaskInstanceBodyActionsInner(self):
- """Test BulkBodyBulkTaskInstanceBodyActionsInner"""
- # inst_req_only = self.make_instance(include_optional=False)
- # inst_req_and_optional = self.make_instance(include_optional=True)
-
-if __name__ == '__main__':
- unittest.main()
diff --git a/test/test_bulk_body_connection_body_actions_inner.py b/test/test_bulk_body_connection_body_actions_inner.py
deleted file mode 100644
index 9cb0d2c..0000000
--- a/test/test_bulk_body_connection_body_actions_inner.py
+++ /dev/null
@@ -1,60 +0,0 @@
-# coding: utf-8
-
-"""
- Airflow API
-
- Airflow API. All endpoints located under ``/api/v2`` can be used safely, are stable and backward compatible. Endpoints located under ``/ui`` are dedicated to the UI and are subject to breaking change depending on the need of the frontend. Users should not rely on those but use the public ones instead.
-
- The version of the OpenAPI document: 2
- Generated by OpenAPI Generator (https://openapi-generator.tech)
-
- Do not edit the class manually.
-""" # noqa: E501
-
-
-import unittest
-
-from airflow_client.client.models.bulk_body_connection_body_actions_inner import BulkBodyConnectionBodyActionsInner
-
-class TestBulkBodyConnectionBodyActionsInner(unittest.TestCase):
- """BulkBodyConnectionBodyActionsInner unit test stubs"""
-
- def setUp(self):
- pass
-
- def tearDown(self):
- pass
-
- def make_instance(self, include_optional) -> BulkBodyConnectionBodyActionsInner:
- """Test BulkBodyConnectionBodyActionsInner
- 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`
- """
- model = BulkBodyConnectionBodyActionsInner()
- if include_optional:
- return BulkBodyConnectionBodyActionsInner(
- action = 'delete',
- action_on_existence = 'fail',
- entities = [
- null
- ],
- action_on_non_existence = 'fail'
- )
- else:
- return BulkBodyConnectionBodyActionsInner(
- action = 'delete',
- entities = [
- null
- ],
- )
- """
-
- def testBulkBodyConnectionBodyActionsInner(self):
- """Test BulkBodyConnectionBodyActionsInner"""
- # inst_req_only = self.make_instance(include_optional=False)
- # inst_req_and_optional = self.make_instance(include_optional=True)
-
-if __name__ == '__main__':
- unittest.main()
diff --git a/test/test_bulk_body_variable_body_actions_inner.py b/test/test_bulk_body_variable_body_actions_inner.py
deleted file mode 100644
index b061074..0000000
--- a/test/test_bulk_body_variable_body_actions_inner.py
+++ /dev/null
@@ -1,60 +0,0 @@
-# coding: utf-8
-
-"""
- Airflow API
-
- Airflow API. All endpoints located under ``/api/v2`` can be used safely, are stable and backward compatible. Endpoints located under ``/ui`` are dedicated to the UI and are subject to breaking change depending on the need of the frontend. Users should not rely on those but use the public ones instead.
-
- The version of the OpenAPI document: 2
- Generated by OpenAPI Generator (https://openapi-generator.tech)
-
- Do not edit the class manually.
-""" # noqa: E501
-
-
-import unittest
-
-from airflow_client.client.models.bulk_body_variable_body_actions_inner import BulkBodyVariableBodyActionsInner
-
-class TestBulkBodyVariableBodyActionsInner(unittest.TestCase):
- """BulkBodyVariableBodyActionsInner unit test stubs"""
-
- def setUp(self):
- pass
-
- def tearDown(self):
- pass
-
- def make_instance(self, include_optional) -> BulkBodyVariableBodyActionsInner:
- """Test BulkBodyVariableBodyActionsInner
- 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`
- """
- model = BulkBodyVariableBodyActionsInner()
- if include_optional:
- return BulkBodyVariableBodyActionsInner(
- action = 'delete',
- action_on_existence = 'fail',
- entities = [
- null
- ],
- action_on_non_existence = 'fail'
- )
- else:
- return BulkBodyVariableBodyActionsInner(
- action = 'delete',
- entities = [
- null
- ],
- )
- """
-
- def testBulkBodyVariableBodyActionsInner(self):
- """Test BulkBodyVariableBodyActionsInner"""
- # inst_req_only = self.make_instance(include_optional=False)
- # inst_req_and_optional = self.make_instance(include_optional=True)
-
-if __name__ == '__main__':
- unittest.main()
diff --git a/test/test_bulk_create_action_pool_body.py b/test/test_bulk_create_action_pool_body.py
index 3625068..c4df10b 100644
--- a/test/test_bulk_create_action_pool_body.py
+++ b/test/test_bulk_create_action_pool_body.py
@@ -42,7 +42,7 @@
description = '',
include_deferred = True,
name = '',
- slots = 56, )
+ slots = -1.0, )
]
)
else:
@@ -53,7 +53,7 @@
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 35e9dc5..9b17dc3 100644
--- a/test/test_bulk_update_action_pool_body.py
+++ b/test/test_bulk_update_action_pool_body.py
@@ -42,7 +42,7 @@
description = '',
include_deferred = True,
name = '',
- slots = 56, )
+ slots = -1.0, )
]
)
else:
@@ -53,7 +53,7 @@
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 d0eae69..af1201f 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 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 @@
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 b1dfd16..3b4db01 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 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 da9b7ec..f343c44 100644
--- a/test/test_pool_body.py
+++ b/test/test_pool_body.py
@@ -38,12 +38,12 @@
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 7210b83..7195b42 100644
--- a/test/test_pool_collection_response.py
+++ b/test/test_pool_collection_response.py
@@ -46,7 +46,7 @@
queued_slots = 56,
running_slots = 56,
scheduled_slots = 56,
- slots = 56, )
+ slots = -1.0, )
],
total_entries = 56
)
@@ -63,7 +63,7 @@
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 d0fa987..6cf664c 100644
--- a/test/test_pool_patch_body.py
+++ b/test/test_pool_patch_body.py
@@ -38,7 +38,7 @@
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 fdf3da7..8cc47f2 100644
--- a/test/test_pool_response.py
+++ b/test/test_pool_response.py
@@ -44,7 +44,7 @@
queued_slots = 56,
running_slots = 56,
scheduled_slots = 56,
- slots = 56
+ slots = -1.0
)
else:
return PoolResponse(
@@ -56,7 +56,7 @@
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 817cb10..fd79ab1 100644
--- a/test/test_response_get_xcom_entry.py
+++ b/test/test_response_get_xcom_entry.py
@@ -40,6 +40,7 @@
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 @@
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 dec1460..eefe489 100644
--- a/test/test_x_com_collection_response.py
+++ b/test/test_x_com_collection_response.py
@@ -43,6 +43,7 @@
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 @@
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 01c967d..ce7e2a7 100644
--- a/test/test_x_com_response.py
+++ b/test/test_x_com_response.py
@@ -40,6 +40,7 @@
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 @@
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 8c202e8..e50f4c1 100644
--- a/test/test_x_com_response_native.py
+++ b/test/test_x_com_response_native.py
@@ -40,6 +40,7 @@
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 @@
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 850a746..4aed036 100644
--- a/test/test_x_com_response_string.py
+++ b/test/test_x_com_response_string.py
@@ -40,6 +40,7 @@
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 @@
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 9cec716..c848fb9 100644
--- a/version.txt
+++ b/version.txt
@@ -1 +1 @@
-3.1.6
+3.1.8
