Updates for 3.0.0rc2 (#129)
releasing from v3-0-test this time from Airflow repo. The main change is `Pydantic` limit change.
diff --git a/.gitignore b/.gitignore
index 92534b9..0ea1e51 100644
--- a/.gitignore
+++ b/.gitignore
@@ -1,6 +1,7 @@
/dist
/tmp
/v1.yaml
+/v2.yaml
/.coverage
/apache_airflow_client.egg-info/
/.idea
diff --git a/airflow_client/client/__init__.py b/airflow_client/client/__init__.py
index 60bb94a..70f1a24 100644
--- a/airflow_client/client/__init__.py
+++ b/airflow_client/client/__init__.py
@@ -131,7 +131,6 @@
from airflow_client.client.models.dry_run_backfill_response import DryRunBackfillResponse
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
from airflow_client.client.models.extra_link_collection_response import ExtraLinkCollectionResponse
from airflow_client.client.models.fast_api_app_response import FastAPIAppResponse
from airflow_client.client.models.fast_api_root_middleware_response import FastAPIRootMiddlewareResponse
@@ -142,11 +141,8 @@
from airflow_client.client.models.import_error_response import ImportErrorResponse
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.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
-from airflow_client.client.models.plugin_import_error_response import PluginImportErrorResponse
from airflow_client.client.models.plugin_response import PluginResponse
from airflow_client.client.models.pool_body import PoolBody
from airflow_client.client.models.pool_collection_response import PoolCollectionResponse
diff --git a/airflow_client/client/api/asset_api.py b/airflow_client/client/api/asset_api.py
index 680b730..a367486 100644
--- a/airflow_client/client/api/asset_api.py
+++ b/airflow_client/client/api/asset_api.py
@@ -1773,7 +1773,7 @@
self,
limit: Optional[Annotated[int, Field(strict=True, ge=0)]] = None,
offset: Optional[Annotated[int, Field(strict=True, ge=0)]] = None,
- name_pattern: Annotated[Optional[StrictStr], Field(description="SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). Regular expressions are **not** supported.")] = None,
+ name_pattern: Optional[StrictStr] = None,
order_by: Optional[StrictStr] = None,
_request_timeout: Union[
None,
@@ -1796,7 +1796,7 @@
:type limit: int
:param offset:
:type offset: int
- :param name_pattern: SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). Regular expressions are **not** supported.
+ :param name_pattern:
:type name_pattern: str
:param order_by:
:type order_by: str
@@ -1856,7 +1856,7 @@
self,
limit: Optional[Annotated[int, Field(strict=True, ge=0)]] = None,
offset: Optional[Annotated[int, Field(strict=True, ge=0)]] = None,
- name_pattern: Annotated[Optional[StrictStr], Field(description="SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). Regular expressions are **not** supported.")] = None,
+ name_pattern: Optional[StrictStr] = None,
order_by: Optional[StrictStr] = None,
_request_timeout: Union[
None,
@@ -1879,7 +1879,7 @@
:type limit: int
:param offset:
:type offset: int
- :param name_pattern: SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). Regular expressions are **not** supported.
+ :param name_pattern:
:type name_pattern: str
:param order_by:
:type order_by: str
@@ -1939,7 +1939,7 @@
self,
limit: Optional[Annotated[int, Field(strict=True, ge=0)]] = None,
offset: Optional[Annotated[int, Field(strict=True, ge=0)]] = None,
- name_pattern: Annotated[Optional[StrictStr], Field(description="SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). Regular expressions are **not** supported.")] = None,
+ name_pattern: Optional[StrictStr] = None,
order_by: Optional[StrictStr] = None,
_request_timeout: Union[
None,
@@ -1962,7 +1962,7 @@
:type limit: int
:param offset:
:type offset: int
- :param name_pattern: SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). Regular expressions are **not** supported.
+ :param name_pattern:
:type name_pattern: str
:param order_by:
:type order_by: str
@@ -2835,8 +2835,8 @@
self,
limit: Optional[Annotated[int, Field(strict=True, ge=0)]] = None,
offset: Optional[Annotated[int, Field(strict=True, ge=0)]] = None,
- name_pattern: Annotated[Optional[StrictStr], Field(description="SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). Regular expressions are **not** supported.")] = None,
- uri_pattern: Annotated[Optional[StrictStr], Field(description="SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). Regular expressions are **not** supported.")] = None,
+ name_pattern: Optional[StrictStr] = None,
+ uri_pattern: Optional[StrictStr] = None,
dag_ids: Optional[List[StrictStr]] = None,
only_active: Optional[StrictBool] = None,
order_by: Optional[StrictStr] = None,
@@ -2861,9 +2861,9 @@
:type limit: int
:param offset:
:type offset: int
- :param name_pattern: SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). Regular expressions are **not** supported.
+ :param name_pattern:
:type name_pattern: str
- :param uri_pattern: SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). Regular expressions are **not** supported.
+ :param uri_pattern:
:type uri_pattern: str
:param dag_ids:
:type dag_ids: List[str]
@@ -2930,8 +2930,8 @@
self,
limit: Optional[Annotated[int, Field(strict=True, ge=0)]] = None,
offset: Optional[Annotated[int, Field(strict=True, ge=0)]] = None,
- name_pattern: Annotated[Optional[StrictStr], Field(description="SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). Regular expressions are **not** supported.")] = None,
- uri_pattern: Annotated[Optional[StrictStr], Field(description="SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). Regular expressions are **not** supported.")] = None,
+ name_pattern: Optional[StrictStr] = None,
+ uri_pattern: Optional[StrictStr] = None,
dag_ids: Optional[List[StrictStr]] = None,
only_active: Optional[StrictBool] = None,
order_by: Optional[StrictStr] = None,
@@ -2956,9 +2956,9 @@
:type limit: int
:param offset:
:type offset: int
- :param name_pattern: SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). Regular expressions are **not** supported.
+ :param name_pattern:
:type name_pattern: str
- :param uri_pattern: SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). Regular expressions are **not** supported.
+ :param uri_pattern:
:type uri_pattern: str
:param dag_ids:
:type dag_ids: List[str]
@@ -3025,8 +3025,8 @@
self,
limit: Optional[Annotated[int, Field(strict=True, ge=0)]] = None,
offset: Optional[Annotated[int, Field(strict=True, ge=0)]] = None,
- name_pattern: Annotated[Optional[StrictStr], Field(description="SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). Regular expressions are **not** supported.")] = None,
- uri_pattern: Annotated[Optional[StrictStr], Field(description="SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). Regular expressions are **not** supported.")] = None,
+ name_pattern: Optional[StrictStr] = None,
+ uri_pattern: Optional[StrictStr] = None,
dag_ids: Optional[List[StrictStr]] = None,
only_active: Optional[StrictBool] = None,
order_by: Optional[StrictStr] = None,
@@ -3051,9 +3051,9 @@
:type limit: int
:param offset:
:type offset: int
- :param name_pattern: SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). Regular expressions are **not** supported.
+ :param name_pattern:
:type name_pattern: str
- :param uri_pattern: SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). Regular expressions are **not** supported.
+ :param uri_pattern:
:type uri_pattern: str
:param dag_ids:
:type dag_ids: List[str]
diff --git a/airflow_client/client/api/connection_api.py b/airflow_client/client/api/connection_api.py
index 1864d1a..bdbb7a1 100644
--- a/airflow_client/client/api/connection_api.py
+++ b/airflow_client/client/api/connection_api.py
@@ -1131,7 +1131,7 @@
limit: Optional[Annotated[int, Field(strict=True, ge=0)]] = None,
offset: Optional[Annotated[int, Field(strict=True, ge=0)]] = None,
order_by: Optional[StrictStr] = None,
- connection_id_pattern: Annotated[Optional[StrictStr], Field(description="SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). Regular expressions are **not** supported.")] = None,
+ connection_id_pattern: Optional[StrictStr] = None,
_request_timeout: Union[
None,
Annotated[StrictFloat, Field(gt=0)],
@@ -1155,7 +1155,7 @@
:type offset: int
:param order_by:
:type order_by: str
- :param connection_id_pattern: SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). Regular expressions are **not** supported.
+ :param connection_id_pattern:
:type connection_id_pattern: str
:param _request_timeout: timeout setting for this request. If one
number provided, it will be total request
@@ -1214,7 +1214,7 @@
limit: Optional[Annotated[int, Field(strict=True, ge=0)]] = None,
offset: Optional[Annotated[int, Field(strict=True, ge=0)]] = None,
order_by: Optional[StrictStr] = None,
- connection_id_pattern: Annotated[Optional[StrictStr], Field(description="SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). Regular expressions are **not** supported.")] = None,
+ connection_id_pattern: Optional[StrictStr] = None,
_request_timeout: Union[
None,
Annotated[StrictFloat, Field(gt=0)],
@@ -1238,7 +1238,7 @@
:type offset: int
:param order_by:
:type order_by: str
- :param connection_id_pattern: SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). Regular expressions are **not** supported.
+ :param connection_id_pattern:
:type connection_id_pattern: str
:param _request_timeout: timeout setting for this request. If one
number provided, it will be total request
@@ -1297,7 +1297,7 @@
limit: Optional[Annotated[int, Field(strict=True, ge=0)]] = None,
offset: Optional[Annotated[int, Field(strict=True, ge=0)]] = None,
order_by: Optional[StrictStr] = None,
- connection_id_pattern: Annotated[Optional[StrictStr], Field(description="SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). Regular expressions are **not** supported.")] = None,
+ connection_id_pattern: Optional[StrictStr] = None,
_request_timeout: Union[
None,
Annotated[StrictFloat, Field(gt=0)],
@@ -1321,7 +1321,7 @@
:type offset: int
:param order_by:
:type order_by: str
- :param connection_id_pattern: SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). Regular expressions are **not** supported.
+ :param connection_id_pattern:
:type connection_id_pattern: str
:param _request_timeout: timeout setting for this request. If one
number provided, it will be total request
diff --git a/airflow_client/client/api/dag_api.py b/airflow_client/client/api/dag_api.py
index f403876..d8b3bed 100644
--- a/airflow_client/client/api/dag_api.py
+++ b/airflow_client/client/api/dag_api.py
@@ -879,7 +879,7 @@
limit: Optional[Annotated[int, Field(strict=True, ge=0)]] = None,
offset: Optional[Annotated[int, Field(strict=True, ge=0)]] = None,
order_by: Optional[StrictStr] = None,
- tag_name_pattern: Annotated[Optional[StrictStr], Field(description="SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). Regular expressions are **not** supported.")] = None,
+ tag_name_pattern: Optional[StrictStr] = None,
_request_timeout: Union[
None,
Annotated[StrictFloat, Field(gt=0)],
@@ -903,7 +903,7 @@
:type offset: int
:param order_by:
:type order_by: str
- :param tag_name_pattern: SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). Regular expressions are **not** supported.
+ :param tag_name_pattern:
:type tag_name_pattern: str
:param _request_timeout: timeout setting for this request. If one
number provided, it will be total request
@@ -961,7 +961,7 @@
limit: Optional[Annotated[int, Field(strict=True, ge=0)]] = None,
offset: Optional[Annotated[int, Field(strict=True, ge=0)]] = None,
order_by: Optional[StrictStr] = None,
- tag_name_pattern: Annotated[Optional[StrictStr], Field(description="SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). Regular expressions are **not** supported.")] = None,
+ tag_name_pattern: Optional[StrictStr] = None,
_request_timeout: Union[
None,
Annotated[StrictFloat, Field(gt=0)],
@@ -985,7 +985,7 @@
:type offset: int
:param order_by:
:type order_by: str
- :param tag_name_pattern: SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). Regular expressions are **not** supported.
+ :param tag_name_pattern:
:type tag_name_pattern: str
:param _request_timeout: timeout setting for this request. If one
number provided, it will be total request
@@ -1043,7 +1043,7 @@
limit: Optional[Annotated[int, Field(strict=True, ge=0)]] = None,
offset: Optional[Annotated[int, Field(strict=True, ge=0)]] = None,
order_by: Optional[StrictStr] = None,
- tag_name_pattern: Annotated[Optional[StrictStr], Field(description="SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). Regular expressions are **not** supported.")] = None,
+ tag_name_pattern: Optional[StrictStr] = None,
_request_timeout: Union[
None,
Annotated[StrictFloat, Field(gt=0)],
@@ -1067,7 +1067,7 @@
:type offset: int
:param order_by:
:type order_by: str
- :param tag_name_pattern: SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). Regular expressions are **not** supported.
+ :param tag_name_pattern:
:type tag_name_pattern: str
:param _request_timeout: timeout setting for this request. If one
number provided, it will be total request
@@ -1204,8 +1204,8 @@
tags: Optional[List[StrictStr]] = None,
tags_match_mode: Optional[StrictStr] = None,
owners: Optional[List[StrictStr]] = None,
- dag_id_pattern: Annotated[Optional[StrictStr], Field(description="SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). Regular expressions are **not** supported.")] = None,
- dag_display_name_pattern: Annotated[Optional[StrictStr], Field(description="SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). Regular expressions are **not** supported.")] = None,
+ dag_id_pattern: Optional[StrictStr] = None,
+ dag_display_name_pattern: Optional[StrictStr] = None,
exclude_stale: Optional[StrictBool] = None,
paused: Optional[StrictBool] = None,
last_dag_run_state: Optional[DagRunState] = None,
@@ -1242,9 +1242,9 @@
:type tags_match_mode: str
:param owners:
:type owners: List[str]
- :param dag_id_pattern: SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). Regular expressions are **not** supported.
+ :param dag_id_pattern:
:type dag_id_pattern: str
- :param dag_display_name_pattern: SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). Regular expressions are **not** supported.
+ :param dag_display_name_pattern:
:type dag_display_name_pattern: str
:param exclude_stale:
:type exclude_stale: bool
@@ -1334,8 +1334,8 @@
tags: Optional[List[StrictStr]] = None,
tags_match_mode: Optional[StrictStr] = None,
owners: Optional[List[StrictStr]] = None,
- dag_id_pattern: Annotated[Optional[StrictStr], Field(description="SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). Regular expressions are **not** supported.")] = None,
- dag_display_name_pattern: Annotated[Optional[StrictStr], Field(description="SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). Regular expressions are **not** supported.")] = None,
+ dag_id_pattern: Optional[StrictStr] = None,
+ dag_display_name_pattern: Optional[StrictStr] = None,
exclude_stale: Optional[StrictBool] = None,
paused: Optional[StrictBool] = None,
last_dag_run_state: Optional[DagRunState] = None,
@@ -1372,9 +1372,9 @@
:type tags_match_mode: str
:param owners:
:type owners: List[str]
- :param dag_id_pattern: SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). Regular expressions are **not** supported.
+ :param dag_id_pattern:
:type dag_id_pattern: str
- :param dag_display_name_pattern: SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). Regular expressions are **not** supported.
+ :param dag_display_name_pattern:
:type dag_display_name_pattern: str
:param exclude_stale:
:type exclude_stale: bool
@@ -1464,8 +1464,8 @@
tags: Optional[List[StrictStr]] = None,
tags_match_mode: Optional[StrictStr] = None,
owners: Optional[List[StrictStr]] = None,
- dag_id_pattern: Annotated[Optional[StrictStr], Field(description="SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). Regular expressions are **not** supported.")] = None,
- dag_display_name_pattern: Annotated[Optional[StrictStr], Field(description="SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). Regular expressions are **not** supported.")] = None,
+ dag_id_pattern: Optional[StrictStr] = None,
+ dag_display_name_pattern: Optional[StrictStr] = None,
exclude_stale: Optional[StrictBool] = None,
paused: Optional[StrictBool] = None,
last_dag_run_state: Optional[DagRunState] = None,
@@ -1502,9 +1502,9 @@
:type tags_match_mode: str
:param owners:
:type owners: List[str]
- :param dag_id_pattern: SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). Regular expressions are **not** supported.
+ :param dag_id_pattern:
:type dag_id_pattern: str
- :param dag_display_name_pattern: SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). Regular expressions are **not** supported.
+ :param dag_display_name_pattern:
:type dag_display_name_pattern: str
:param exclude_stale:
:type exclude_stale: bool
@@ -2094,7 +2094,7 @@
tags: Optional[List[StrictStr]] = None,
tags_match_mode: Optional[StrictStr] = None,
owners: Optional[List[StrictStr]] = None,
- dag_id_pattern: Annotated[Optional[StrictStr], Field(description="SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). Regular expressions are **not** supported.")] = None,
+ dag_id_pattern: Optional[StrictStr] = None,
exclude_stale: Optional[StrictBool] = None,
paused: Optional[StrictBool] = None,
last_dag_run_state: Optional[DagRunState] = None,
@@ -2129,7 +2129,7 @@
:type tags_match_mode: str
:param owners:
:type owners: List[str]
- :param dag_id_pattern: SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). Regular expressions are **not** supported.
+ :param dag_id_pattern:
:type dag_id_pattern: str
:param exclude_stale:
:type exclude_stale: bool
@@ -2206,7 +2206,7 @@
tags: Optional[List[StrictStr]] = None,
tags_match_mode: Optional[StrictStr] = None,
owners: Optional[List[StrictStr]] = None,
- dag_id_pattern: Annotated[Optional[StrictStr], Field(description="SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). Regular expressions are **not** supported.")] = None,
+ dag_id_pattern: Optional[StrictStr] = None,
exclude_stale: Optional[StrictBool] = None,
paused: Optional[StrictBool] = None,
last_dag_run_state: Optional[DagRunState] = None,
@@ -2241,7 +2241,7 @@
:type tags_match_mode: str
:param owners:
:type owners: List[str]
- :param dag_id_pattern: SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). Regular expressions are **not** supported.
+ :param dag_id_pattern:
:type dag_id_pattern: str
:param exclude_stale:
:type exclude_stale: bool
@@ -2318,7 +2318,7 @@
tags: Optional[List[StrictStr]] = None,
tags_match_mode: Optional[StrictStr] = None,
owners: Optional[List[StrictStr]] = None,
- dag_id_pattern: Annotated[Optional[StrictStr], Field(description="SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). Regular expressions are **not** supported.")] = None,
+ dag_id_pattern: Optional[StrictStr] = None,
exclude_stale: Optional[StrictBool] = None,
paused: Optional[StrictBool] = None,
last_dag_run_state: Optional[DagRunState] = None,
@@ -2353,7 +2353,7 @@
:type tags_match_mode: str
:param owners:
:type owners: List[str]
- :param dag_id_pattern: SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). Regular expressions are **not** supported.
+ :param dag_id_pattern:
:type dag_id_pattern: str
:param exclude_stale:
:type exclude_stale: bool
diff --git a/airflow_client/client/api/plugin_api.py b/airflow_client/client/api/plugin_api.py
index 13fe97d..b577a24 100644
--- a/airflow_client/client/api/plugin_api.py
+++ b/airflow_client/client/api/plugin_api.py
@@ -20,7 +20,6 @@
from typing import Optional
from typing_extensions import Annotated
from airflow_client.client.models.plugin_collection_response import PluginCollectionResponse
-from airflow_client.client.models.plugin_import_error_collection_response import PluginImportErrorCollectionResponse
from airflow_client.client.api_client import ApiClient, RequestSerialized
from airflow_client.client.api_response import ApiResponse
@@ -324,252 +323,3 @@
)
-
-
- @validate_call
- def import_errors(
- self,
- _request_timeout: Union[
- None,
- Annotated[StrictFloat, Field(gt=0)],
- Tuple[
- Annotated[StrictFloat, Field(gt=0)],
- Annotated[StrictFloat, Field(gt=0)]
- ]
- ] = None,
- _request_auth: Optional[Dict[StrictStr, Any]] = None,
- _content_type: Optional[StrictStr] = None,
- _headers: Optional[Dict[StrictStr, Any]] = None,
- _host_index: Annotated[StrictInt, Field(ge=0, le=0)] = 0,
- ) -> PluginImportErrorCollectionResponse:
- """Import Errors
-
-
- :param _request_timeout: timeout setting for this request. If one
- number provided, it will be total request
- timeout. It can also be a pair (tuple) of
- (connection, read) timeouts.
- :type _request_timeout: int, tuple(int, int), optional
- :param _request_auth: set to override the auth_settings for an a single
- request; this effectively ignores the
- authentication in the spec for a single request.
- :type _request_auth: dict, optional
- :param _content_type: force content-type for the request.
- :type _content_type: str, Optional
- :param _headers: set to override the headers for a single
- request; this effectively ignores the headers
- in the spec for a single request.
- :type _headers: dict, optional
- :param _host_index: set to override the host_index for a single
- request; this effectively ignores the host_index
- in the spec for a single request.
- :type _host_index: int, optional
- :return: Returns the result object.
- """ # noqa: E501
-
- _param = self._import_errors_serialize(
- _request_auth=_request_auth,
- _content_type=_content_type,
- _headers=_headers,
- _host_index=_host_index
- )
-
- _response_types_map: Dict[str, Optional[str]] = {
- '200': "PluginImportErrorCollectionResponse",
- '401': "HTTPExceptionResponse",
- '403': "HTTPExceptionResponse",
- }
- response_data = self.api_client.call_api(
- *_param,
- _request_timeout=_request_timeout
- )
- response_data.read()
- return self.api_client.response_deserialize(
- response_data=response_data,
- response_types_map=_response_types_map,
- ).data
-
-
- @validate_call
- def import_errors_with_http_info(
- self,
- _request_timeout: Union[
- None,
- Annotated[StrictFloat, Field(gt=0)],
- Tuple[
- Annotated[StrictFloat, Field(gt=0)],
- Annotated[StrictFloat, Field(gt=0)]
- ]
- ] = None,
- _request_auth: Optional[Dict[StrictStr, Any]] = None,
- _content_type: Optional[StrictStr] = None,
- _headers: Optional[Dict[StrictStr, Any]] = None,
- _host_index: Annotated[StrictInt, Field(ge=0, le=0)] = 0,
- ) -> ApiResponse[PluginImportErrorCollectionResponse]:
- """Import Errors
-
-
- :param _request_timeout: timeout setting for this request. If one
- number provided, it will be total request
- timeout. It can also be a pair (tuple) of
- (connection, read) timeouts.
- :type _request_timeout: int, tuple(int, int), optional
- :param _request_auth: set to override the auth_settings for an a single
- request; this effectively ignores the
- authentication in the spec for a single request.
- :type _request_auth: dict, optional
- :param _content_type: force content-type for the request.
- :type _content_type: str, Optional
- :param _headers: set to override the headers for a single
- request; this effectively ignores the headers
- in the spec for a single request.
- :type _headers: dict, optional
- :param _host_index: set to override the host_index for a single
- request; this effectively ignores the host_index
- in the spec for a single request.
- :type _host_index: int, optional
- :return: Returns the result object.
- """ # noqa: E501
-
- _param = self._import_errors_serialize(
- _request_auth=_request_auth,
- _content_type=_content_type,
- _headers=_headers,
- _host_index=_host_index
- )
-
- _response_types_map: Dict[str, Optional[str]] = {
- '200': "PluginImportErrorCollectionResponse",
- '401': "HTTPExceptionResponse",
- '403': "HTTPExceptionResponse",
- }
- response_data = self.api_client.call_api(
- *_param,
- _request_timeout=_request_timeout
- )
- response_data.read()
- return self.api_client.response_deserialize(
- response_data=response_data,
- response_types_map=_response_types_map,
- )
-
-
- @validate_call
- def import_errors_without_preload_content(
- self,
- _request_timeout: Union[
- None,
- Annotated[StrictFloat, Field(gt=0)],
- Tuple[
- Annotated[StrictFloat, Field(gt=0)],
- Annotated[StrictFloat, Field(gt=0)]
- ]
- ] = None,
- _request_auth: Optional[Dict[StrictStr, Any]] = None,
- _content_type: Optional[StrictStr] = None,
- _headers: Optional[Dict[StrictStr, Any]] = None,
- _host_index: Annotated[StrictInt, Field(ge=0, le=0)] = 0,
- ) -> RESTResponseType:
- """Import Errors
-
-
- :param _request_timeout: timeout setting for this request. If one
- number provided, it will be total request
- timeout. It can also be a pair (tuple) of
- (connection, read) timeouts.
- :type _request_timeout: int, tuple(int, int), optional
- :param _request_auth: set to override the auth_settings for an a single
- request; this effectively ignores the
- authentication in the spec for a single request.
- :type _request_auth: dict, optional
- :param _content_type: force content-type for the request.
- :type _content_type: str, Optional
- :param _headers: set to override the headers for a single
- request; this effectively ignores the headers
- in the spec for a single request.
- :type _headers: dict, optional
- :param _host_index: set to override the host_index for a single
- request; this effectively ignores the host_index
- in the spec for a single request.
- :type _host_index: int, optional
- :return: Returns the result object.
- """ # noqa: E501
-
- _param = self._import_errors_serialize(
- _request_auth=_request_auth,
- _content_type=_content_type,
- _headers=_headers,
- _host_index=_host_index
- )
-
- _response_types_map: Dict[str, Optional[str]] = {
- '200': "PluginImportErrorCollectionResponse",
- '401': "HTTPExceptionResponse",
- '403': "HTTPExceptionResponse",
- }
- response_data = self.api_client.call_api(
- *_param,
- _request_timeout=_request_timeout
- )
- return response_data.response
-
-
- def _import_errors_serialize(
- self,
- _request_auth,
- _content_type,
- _headers,
- _host_index,
- ) -> RequestSerialized:
-
- _host = None
-
- _collection_formats: Dict[str, str] = {
- }
-
- _path_params: Dict[str, str] = {}
- _query_params: List[Tuple[str, str]] = []
- _header_params: Dict[str, Optional[str]] = _headers or {}
- _form_params: List[Tuple[str, str]] = []
- _files: Dict[
- str, Union[str, bytes, List[str], List[bytes], List[Tuple[str, bytes]]]
- ] = {}
- _body_params: Optional[bytes] = None
-
- # process the path parameters
- # process the query parameters
- # process the header parameters
- # process the form parameters
- # process the body parameter
-
-
- # set the HTTP header `Accept`
- if 'Accept' not in _header_params:
- _header_params['Accept'] = self.api_client.select_header_accept(
- [
- 'application/json'
- ]
- )
-
-
- # authentication setting
- _auth_settings: List[str] = [
- 'OAuth2PasswordBearer'
- ]
-
- return self.api_client.param_serialize(
- method='GET',
- resource_path='/api/v2/plugins/importErrors',
- path_params=_path_params,
- query_params=_query_params,
- header_params=_header_params,
- body=_body_params,
- post_params=_form_params,
- files=_files,
- auth_settings=_auth_settings,
- collection_formats=_collection_formats,
- _host=_host,
- _request_auth=_request_auth
- )
-
-
diff --git a/airflow_client/client/api/pool_api.py b/airflow_client/client/api/pool_api.py
index ebdcc7c..be2909d 100644
--- a/airflow_client/client/api/pool_api.py
+++ b/airflow_client/client/api/pool_api.py
@@ -882,7 +882,7 @@
limit: Optional[Annotated[int, Field(strict=True, ge=0)]] = None,
offset: Optional[Annotated[int, Field(strict=True, ge=0)]] = None,
order_by: Optional[StrictStr] = None,
- pool_name_pattern: Annotated[Optional[StrictStr], Field(description="SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). Regular expressions are **not** supported.")] = None,
+ pool_name_pattern: Optional[StrictStr] = None,
_request_timeout: Union[
None,
Annotated[StrictFloat, Field(gt=0)],
@@ -906,7 +906,7 @@
:type offset: int
:param order_by:
:type order_by: str
- :param pool_name_pattern: SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). Regular expressions are **not** supported.
+ :param pool_name_pattern:
:type pool_name_pattern: str
:param _request_timeout: timeout setting for this request. If one
number provided, it will be total request
@@ -965,7 +965,7 @@
limit: Optional[Annotated[int, Field(strict=True, ge=0)]] = None,
offset: Optional[Annotated[int, Field(strict=True, ge=0)]] = None,
order_by: Optional[StrictStr] = None,
- pool_name_pattern: Annotated[Optional[StrictStr], Field(description="SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). Regular expressions are **not** supported.")] = None,
+ pool_name_pattern: Optional[StrictStr] = None,
_request_timeout: Union[
None,
Annotated[StrictFloat, Field(gt=0)],
@@ -989,7 +989,7 @@
:type offset: int
:param order_by:
:type order_by: str
- :param pool_name_pattern: SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). Regular expressions are **not** supported.
+ :param pool_name_pattern:
:type pool_name_pattern: str
:param _request_timeout: timeout setting for this request. If one
number provided, it will be total request
@@ -1048,7 +1048,7 @@
limit: Optional[Annotated[int, Field(strict=True, ge=0)]] = None,
offset: Optional[Annotated[int, Field(strict=True, ge=0)]] = None,
order_by: Optional[StrictStr] = None,
- pool_name_pattern: Annotated[Optional[StrictStr], Field(description="SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). Regular expressions are **not** supported.")] = None,
+ pool_name_pattern: Optional[StrictStr] = None,
_request_timeout: Union[
None,
Annotated[StrictFloat, Field(gt=0)],
@@ -1072,7 +1072,7 @@
:type offset: int
:param order_by:
:type order_by: str
- :param pool_name_pattern: SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). Regular expressions are **not** supported.
+ :param pool_name_pattern:
:type pool_name_pattern: str
:param _request_timeout: timeout setting for this request. If one
number provided, it will be total request
diff --git a/airflow_client/client/api/task_instance_api.py b/airflow_client/client/api/task_instance_api.py
index c863f35..11d4ac1 100644
--- a/airflow_client/client/api/task_instance_api.py
+++ b/airflow_client/client/api/task_instance_api.py
@@ -18,10 +18,9 @@
from datetime import datetime
from pydantic import Field, StrictBool, StrictFloat, StrictInt, StrictStr, field_validator
-from typing import Any, List, Optional, Union
+from typing import List, Optional, Union
from typing_extensions import Annotated
from airflow_client.client.models.clear_task_instances_body import ClearTaskInstancesBody
-from airflow_client.client.models.external_log_url_response import ExternalLogUrlResponse
from airflow_client.client.models.extra_link_collection_response import ExtraLinkCollectionResponse
from airflow_client.client.models.patch_task_instance_body import PatchTaskInstanceBody
from airflow_client.client.models.task_dependency_collection_response import TaskDependencyCollectionResponse
@@ -51,664 +50,6 @@
@validate_call
- def delete_task_instance(
- self,
- dag_id: StrictStr,
- dag_run_id: StrictStr,
- task_id: StrictStr,
- map_index: Optional[StrictInt] = None,
- _request_timeout: Union[
- None,
- Annotated[StrictFloat, Field(gt=0)],
- Tuple[
- Annotated[StrictFloat, Field(gt=0)],
- Annotated[StrictFloat, Field(gt=0)]
- ]
- ] = None,
- _request_auth: Optional[Dict[StrictStr, Any]] = None,
- _content_type: Optional[StrictStr] = None,
- _headers: Optional[Dict[StrictStr, Any]] = None,
- _host_index: Annotated[StrictInt, Field(ge=0, le=0)] = 0,
- ) -> object:
- """Delete Task Instance
-
- Delete a task instance.
-
- :param dag_id: (required)
- :type dag_id: str
- :param dag_run_id: (required)
- :type dag_run_id: str
- :param task_id: (required)
- :type task_id: str
- :param map_index:
- :type map_index: int
- :param _request_timeout: timeout setting for this request. If one
- number provided, it will be total request
- timeout. It can also be a pair (tuple) of
- (connection, read) timeouts.
- :type _request_timeout: int, tuple(int, int), optional
- :param _request_auth: set to override the auth_settings for an a single
- request; this effectively ignores the
- authentication in the spec for a single request.
- :type _request_auth: dict, optional
- :param _content_type: force content-type for the request.
- :type _content_type: str, Optional
- :param _headers: set to override the headers for a single
- request; this effectively ignores the headers
- in the spec for a single request.
- :type _headers: dict, optional
- :param _host_index: set to override the host_index for a single
- request; this effectively ignores the host_index
- in the spec for a single request.
- :type _host_index: int, optional
- :return: Returns the result object.
- """ # noqa: E501
-
- _param = self._delete_task_instance_serialize(
- dag_id=dag_id,
- dag_run_id=dag_run_id,
- task_id=task_id,
- map_index=map_index,
- _request_auth=_request_auth,
- _content_type=_content_type,
- _headers=_headers,
- _host_index=_host_index
- )
-
- _response_types_map: Dict[str, Optional[str]] = {
- '200': "object",
- '401': "HTTPExceptionResponse",
- '403': "HTTPExceptionResponse",
- '404': "HTTPExceptionResponse",
- '422': "HTTPValidationError",
- }
- response_data = self.api_client.call_api(
- *_param,
- _request_timeout=_request_timeout
- )
- response_data.read()
- return self.api_client.response_deserialize(
- response_data=response_data,
- response_types_map=_response_types_map,
- ).data
-
-
- @validate_call
- def delete_task_instance_with_http_info(
- self,
- dag_id: StrictStr,
- dag_run_id: StrictStr,
- task_id: StrictStr,
- map_index: Optional[StrictInt] = None,
- _request_timeout: Union[
- None,
- Annotated[StrictFloat, Field(gt=0)],
- Tuple[
- Annotated[StrictFloat, Field(gt=0)],
- Annotated[StrictFloat, Field(gt=0)]
- ]
- ] = None,
- _request_auth: Optional[Dict[StrictStr, Any]] = None,
- _content_type: Optional[StrictStr] = None,
- _headers: Optional[Dict[StrictStr, Any]] = None,
- _host_index: Annotated[StrictInt, Field(ge=0, le=0)] = 0,
- ) -> ApiResponse[object]:
- """Delete Task Instance
-
- Delete a task instance.
-
- :param dag_id: (required)
- :type dag_id: str
- :param dag_run_id: (required)
- :type dag_run_id: str
- :param task_id: (required)
- :type task_id: str
- :param map_index:
- :type map_index: int
- :param _request_timeout: timeout setting for this request. If one
- number provided, it will be total request
- timeout. It can also be a pair (tuple) of
- (connection, read) timeouts.
- :type _request_timeout: int, tuple(int, int), optional
- :param _request_auth: set to override the auth_settings for an a single
- request; this effectively ignores the
- authentication in the spec for a single request.
- :type _request_auth: dict, optional
- :param _content_type: force content-type for the request.
- :type _content_type: str, Optional
- :param _headers: set to override the headers for a single
- request; this effectively ignores the headers
- in the spec for a single request.
- :type _headers: dict, optional
- :param _host_index: set to override the host_index for a single
- request; this effectively ignores the host_index
- in the spec for a single request.
- :type _host_index: int, optional
- :return: Returns the result object.
- """ # noqa: E501
-
- _param = self._delete_task_instance_serialize(
- dag_id=dag_id,
- dag_run_id=dag_run_id,
- task_id=task_id,
- map_index=map_index,
- _request_auth=_request_auth,
- _content_type=_content_type,
- _headers=_headers,
- _host_index=_host_index
- )
-
- _response_types_map: Dict[str, Optional[str]] = {
- '200': "object",
- '401': "HTTPExceptionResponse",
- '403': "HTTPExceptionResponse",
- '404': "HTTPExceptionResponse",
- '422': "HTTPValidationError",
- }
- response_data = self.api_client.call_api(
- *_param,
- _request_timeout=_request_timeout
- )
- response_data.read()
- return self.api_client.response_deserialize(
- response_data=response_data,
- response_types_map=_response_types_map,
- )
-
-
- @validate_call
- def delete_task_instance_without_preload_content(
- self,
- dag_id: StrictStr,
- dag_run_id: StrictStr,
- task_id: StrictStr,
- map_index: Optional[StrictInt] = None,
- _request_timeout: Union[
- None,
- Annotated[StrictFloat, Field(gt=0)],
- Tuple[
- Annotated[StrictFloat, Field(gt=0)],
- Annotated[StrictFloat, Field(gt=0)]
- ]
- ] = None,
- _request_auth: Optional[Dict[StrictStr, Any]] = None,
- _content_type: Optional[StrictStr] = None,
- _headers: Optional[Dict[StrictStr, Any]] = None,
- _host_index: Annotated[StrictInt, Field(ge=0, le=0)] = 0,
- ) -> RESTResponseType:
- """Delete Task Instance
-
- Delete a task instance.
-
- :param dag_id: (required)
- :type dag_id: str
- :param dag_run_id: (required)
- :type dag_run_id: str
- :param task_id: (required)
- :type task_id: str
- :param map_index:
- :type map_index: int
- :param _request_timeout: timeout setting for this request. If one
- number provided, it will be total request
- timeout. It can also be a pair (tuple) of
- (connection, read) timeouts.
- :type _request_timeout: int, tuple(int, int), optional
- :param _request_auth: set to override the auth_settings for an a single
- request; this effectively ignores the
- authentication in the spec for a single request.
- :type _request_auth: dict, optional
- :param _content_type: force content-type for the request.
- :type _content_type: str, Optional
- :param _headers: set to override the headers for a single
- request; this effectively ignores the headers
- in the spec for a single request.
- :type _headers: dict, optional
- :param _host_index: set to override the host_index for a single
- request; this effectively ignores the host_index
- in the spec for a single request.
- :type _host_index: int, optional
- :return: Returns the result object.
- """ # noqa: E501
-
- _param = self._delete_task_instance_serialize(
- dag_id=dag_id,
- dag_run_id=dag_run_id,
- task_id=task_id,
- map_index=map_index,
- _request_auth=_request_auth,
- _content_type=_content_type,
- _headers=_headers,
- _host_index=_host_index
- )
-
- _response_types_map: Dict[str, Optional[str]] = {
- '200': "object",
- '401': "HTTPExceptionResponse",
- '403': "HTTPExceptionResponse",
- '404': "HTTPExceptionResponse",
- '422': "HTTPValidationError",
- }
- response_data = self.api_client.call_api(
- *_param,
- _request_timeout=_request_timeout
- )
- return response_data.response
-
-
- def _delete_task_instance_serialize(
- self,
- dag_id,
- dag_run_id,
- task_id,
- map_index,
- _request_auth,
- _content_type,
- _headers,
- _host_index,
- ) -> RequestSerialized:
-
- _host = None
-
- _collection_formats: Dict[str, str] = {
- }
-
- _path_params: Dict[str, str] = {}
- _query_params: List[Tuple[str, str]] = []
- _header_params: Dict[str, Optional[str]] = _headers or {}
- _form_params: List[Tuple[str, str]] = []
- _files: Dict[
- str, Union[str, bytes, List[str], List[bytes], List[Tuple[str, bytes]]]
- ] = {}
- _body_params: Optional[bytes] = None
-
- # process the path parameters
- if dag_id is not None:
- _path_params['dag_id'] = dag_id
- if dag_run_id is not None:
- _path_params['dag_run_id'] = dag_run_id
- if task_id is not None:
- _path_params['task_id'] = task_id
- # process the query parameters
- if map_index is not None:
-
- _query_params.append(('map_index', map_index))
-
- # process the header parameters
- # process the form parameters
- # process the body parameter
-
-
- # set the HTTP header `Accept`
- if 'Accept' not in _header_params:
- _header_params['Accept'] = self.api_client.select_header_accept(
- [
- 'application/json'
- ]
- )
-
-
- # authentication setting
- _auth_settings: List[str] = [
- 'OAuth2PasswordBearer'
- ]
-
- return self.api_client.param_serialize(
- method='DELETE',
- resource_path='/api/v2/dags/{dag_id}/dagRuns/{dag_run_id}/taskInstances/{task_id}',
- path_params=_path_params,
- query_params=_query_params,
- header_params=_header_params,
- body=_body_params,
- post_params=_form_params,
- files=_files,
- auth_settings=_auth_settings,
- collection_formats=_collection_formats,
- _host=_host,
- _request_auth=_request_auth
- )
-
-
-
-
- @validate_call
- def get_external_log_url(
- self,
- dag_id: StrictStr,
- dag_run_id: StrictStr,
- task_id: StrictStr,
- try_number: StrictInt,
- map_index: Optional[StrictInt] = None,
- _request_timeout: Union[
- None,
- Annotated[StrictFloat, Field(gt=0)],
- Tuple[
- Annotated[StrictFloat, Field(gt=0)],
- Annotated[StrictFloat, Field(gt=0)]
- ]
- ] = None,
- _request_auth: Optional[Dict[StrictStr, Any]] = None,
- _content_type: Optional[StrictStr] = None,
- _headers: Optional[Dict[StrictStr, Any]] = None,
- _host_index: Annotated[StrictInt, Field(ge=0, le=0)] = 0,
- ) -> ExternalLogUrlResponse:
- """Get External Log Url
-
- Get external log URL for a specific task instance.
-
- :param dag_id: (required)
- :type dag_id: str
- :param dag_run_id: (required)
- :type dag_run_id: str
- :param task_id: (required)
- :type task_id: str
- :param try_number: (required)
- :type try_number: int
- :param map_index:
- :type map_index: int
- :param _request_timeout: timeout setting for this request. If one
- number provided, it will be total request
- timeout. It can also be a pair (tuple) of
- (connection, read) timeouts.
- :type _request_timeout: int, tuple(int, int), optional
- :param _request_auth: set to override the auth_settings for an a single
- request; this effectively ignores the
- authentication in the spec for a single request.
- :type _request_auth: dict, optional
- :param _content_type: force content-type for the request.
- :type _content_type: str, Optional
- :param _headers: set to override the headers for a single
- request; this effectively ignores the headers
- in the spec for a single request.
- :type _headers: dict, optional
- :param _host_index: set to override the host_index for a single
- request; this effectively ignores the host_index
- in the spec for a single request.
- :type _host_index: int, optional
- :return: Returns the result object.
- """ # noqa: E501
-
- _param = self._get_external_log_url_serialize(
- dag_id=dag_id,
- dag_run_id=dag_run_id,
- task_id=task_id,
- try_number=try_number,
- map_index=map_index,
- _request_auth=_request_auth,
- _content_type=_content_type,
- _headers=_headers,
- _host_index=_host_index
- )
-
- _response_types_map: Dict[str, Optional[str]] = {
- '200': "ExternalLogUrlResponse",
- '400': "HTTPExceptionResponse",
- '401': "HTTPExceptionResponse",
- '403': "HTTPExceptionResponse",
- '404': "HTTPExceptionResponse",
- '422': "HTTPValidationError",
- }
- response_data = self.api_client.call_api(
- *_param,
- _request_timeout=_request_timeout
- )
- response_data.read()
- return self.api_client.response_deserialize(
- response_data=response_data,
- response_types_map=_response_types_map,
- ).data
-
-
- @validate_call
- def get_external_log_url_with_http_info(
- self,
- dag_id: StrictStr,
- dag_run_id: StrictStr,
- task_id: StrictStr,
- try_number: StrictInt,
- map_index: Optional[StrictInt] = None,
- _request_timeout: Union[
- None,
- Annotated[StrictFloat, Field(gt=0)],
- Tuple[
- Annotated[StrictFloat, Field(gt=0)],
- Annotated[StrictFloat, Field(gt=0)]
- ]
- ] = None,
- _request_auth: Optional[Dict[StrictStr, Any]] = None,
- _content_type: Optional[StrictStr] = None,
- _headers: Optional[Dict[StrictStr, Any]] = None,
- _host_index: Annotated[StrictInt, Field(ge=0, le=0)] = 0,
- ) -> ApiResponse[ExternalLogUrlResponse]:
- """Get External Log Url
-
- Get external log URL for a specific task instance.
-
- :param dag_id: (required)
- :type dag_id: str
- :param dag_run_id: (required)
- :type dag_run_id: str
- :param task_id: (required)
- :type task_id: str
- :param try_number: (required)
- :type try_number: int
- :param map_index:
- :type map_index: int
- :param _request_timeout: timeout setting for this request. If one
- number provided, it will be total request
- timeout. It can also be a pair (tuple) of
- (connection, read) timeouts.
- :type _request_timeout: int, tuple(int, int), optional
- :param _request_auth: set to override the auth_settings for an a single
- request; this effectively ignores the
- authentication in the spec for a single request.
- :type _request_auth: dict, optional
- :param _content_type: force content-type for the request.
- :type _content_type: str, Optional
- :param _headers: set to override the headers for a single
- request; this effectively ignores the headers
- in the spec for a single request.
- :type _headers: dict, optional
- :param _host_index: set to override the host_index for a single
- request; this effectively ignores the host_index
- in the spec for a single request.
- :type _host_index: int, optional
- :return: Returns the result object.
- """ # noqa: E501
-
- _param = self._get_external_log_url_serialize(
- dag_id=dag_id,
- dag_run_id=dag_run_id,
- task_id=task_id,
- try_number=try_number,
- map_index=map_index,
- _request_auth=_request_auth,
- _content_type=_content_type,
- _headers=_headers,
- _host_index=_host_index
- )
-
- _response_types_map: Dict[str, Optional[str]] = {
- '200': "ExternalLogUrlResponse",
- '400': "HTTPExceptionResponse",
- '401': "HTTPExceptionResponse",
- '403': "HTTPExceptionResponse",
- '404': "HTTPExceptionResponse",
- '422': "HTTPValidationError",
- }
- response_data = self.api_client.call_api(
- *_param,
- _request_timeout=_request_timeout
- )
- response_data.read()
- return self.api_client.response_deserialize(
- response_data=response_data,
- response_types_map=_response_types_map,
- )
-
-
- @validate_call
- def get_external_log_url_without_preload_content(
- self,
- dag_id: StrictStr,
- dag_run_id: StrictStr,
- task_id: StrictStr,
- try_number: StrictInt,
- map_index: Optional[StrictInt] = None,
- _request_timeout: Union[
- None,
- Annotated[StrictFloat, Field(gt=0)],
- Tuple[
- Annotated[StrictFloat, Field(gt=0)],
- Annotated[StrictFloat, Field(gt=0)]
- ]
- ] = None,
- _request_auth: Optional[Dict[StrictStr, Any]] = None,
- _content_type: Optional[StrictStr] = None,
- _headers: Optional[Dict[StrictStr, Any]] = None,
- _host_index: Annotated[StrictInt, Field(ge=0, le=0)] = 0,
- ) -> RESTResponseType:
- """Get External Log Url
-
- Get external log URL for a specific task instance.
-
- :param dag_id: (required)
- :type dag_id: str
- :param dag_run_id: (required)
- :type dag_run_id: str
- :param task_id: (required)
- :type task_id: str
- :param try_number: (required)
- :type try_number: int
- :param map_index:
- :type map_index: int
- :param _request_timeout: timeout setting for this request. If one
- number provided, it will be total request
- timeout. It can also be a pair (tuple) of
- (connection, read) timeouts.
- :type _request_timeout: int, tuple(int, int), optional
- :param _request_auth: set to override the auth_settings for an a single
- request; this effectively ignores the
- authentication in the spec for a single request.
- :type _request_auth: dict, optional
- :param _content_type: force content-type for the request.
- :type _content_type: str, Optional
- :param _headers: set to override the headers for a single
- request; this effectively ignores the headers
- in the spec for a single request.
- :type _headers: dict, optional
- :param _host_index: set to override the host_index for a single
- request; this effectively ignores the host_index
- in the spec for a single request.
- :type _host_index: int, optional
- :return: Returns the result object.
- """ # noqa: E501
-
- _param = self._get_external_log_url_serialize(
- dag_id=dag_id,
- dag_run_id=dag_run_id,
- task_id=task_id,
- try_number=try_number,
- map_index=map_index,
- _request_auth=_request_auth,
- _content_type=_content_type,
- _headers=_headers,
- _host_index=_host_index
- )
-
- _response_types_map: Dict[str, Optional[str]] = {
- '200': "ExternalLogUrlResponse",
- '400': "HTTPExceptionResponse",
- '401': "HTTPExceptionResponse",
- '403': "HTTPExceptionResponse",
- '404': "HTTPExceptionResponse",
- '422': "HTTPValidationError",
- }
- response_data = self.api_client.call_api(
- *_param,
- _request_timeout=_request_timeout
- )
- return response_data.response
-
-
- def _get_external_log_url_serialize(
- self,
- dag_id,
- dag_run_id,
- task_id,
- try_number,
- map_index,
- _request_auth,
- _content_type,
- _headers,
- _host_index,
- ) -> RequestSerialized:
-
- _host = None
-
- _collection_formats: Dict[str, str] = {
- }
-
- _path_params: Dict[str, str] = {}
- _query_params: List[Tuple[str, str]] = []
- _header_params: Dict[str, Optional[str]] = _headers or {}
- _form_params: List[Tuple[str, str]] = []
- _files: Dict[
- str, Union[str, bytes, List[str], List[bytes], List[Tuple[str, bytes]]]
- ] = {}
- _body_params: Optional[bytes] = None
-
- # process the path parameters
- if dag_id is not None:
- _path_params['dag_id'] = dag_id
- if dag_run_id is not None:
- _path_params['dag_run_id'] = dag_run_id
- if task_id is not None:
- _path_params['task_id'] = task_id
- if try_number is not None:
- _path_params['try_number'] = try_number
- # process the query parameters
- if map_index is not None:
-
- _query_params.append(('map_index', map_index))
-
- # process the header parameters
- # process the form parameters
- # process the body parameter
-
-
- # set the HTTP header `Accept`
- if 'Accept' not in _header_params:
- _header_params['Accept'] = self.api_client.select_header_accept(
- [
- 'application/json'
- ]
- )
-
-
- # authentication setting
- _auth_settings: List[str] = [
- 'OAuth2PasswordBearer'
- ]
-
- return self.api_client.param_serialize(
- method='GET',
- resource_path='/api/v2/dags/{dag_id}/dagRuns/{dag_run_id}/taskInstances/{task_id}/externalLogUrl/{try_number}',
- path_params=_path_params,
- query_params=_query_params,
- header_params=_header_params,
- body=_body_params,
- post_params=_form_params,
- files=_files,
- auth_settings=_auth_settings,
- collection_formats=_collection_formats,
- _host=_host,
- _request_auth=_request_auth
- )
-
-
-
-
- @validate_call
def get_extra_links(
self,
dag_id: StrictStr,
@@ -1385,7 +726,7 @@
_header_params['Accept'] = self.api_client.select_header_accept(
[
'application/json',
- 'application/x-ndjson'
+ 'text/plain'
]
)
@@ -4728,7 +4069,7 @@
updated_at_lte: Optional[datetime] = None,
duration_gte: Optional[Union[StrictFloat, StrictInt]] = None,
duration_lte: Optional[Union[StrictFloat, StrictInt]] = None,
- task_display_name_pattern: Annotated[Optional[StrictStr], Field(description="SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). Regular expressions are **not** supported.")] = None,
+ task_display_name_pattern: Optional[StrictStr] = None,
state: Optional[List[StrictStr]] = None,
pool: Optional[List[StrictStr]] = None,
queue: Optional[List[StrictStr]] = None,
@@ -4784,7 +4125,7 @@
:type duration_gte: float
:param duration_lte:
:type duration_lte: float
- :param task_display_name_pattern: SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). Regular expressions are **not** supported.
+ :param task_display_name_pattern:
:type task_display_name_pattern: str
:param state:
:type state: List[str]
@@ -4891,7 +4232,7 @@
updated_at_lte: Optional[datetime] = None,
duration_gte: Optional[Union[StrictFloat, StrictInt]] = None,
duration_lte: Optional[Union[StrictFloat, StrictInt]] = None,
- task_display_name_pattern: Annotated[Optional[StrictStr], Field(description="SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). Regular expressions are **not** supported.")] = None,
+ task_display_name_pattern: Optional[StrictStr] = None,
state: Optional[List[StrictStr]] = None,
pool: Optional[List[StrictStr]] = None,
queue: Optional[List[StrictStr]] = None,
@@ -4947,7 +4288,7 @@
:type duration_gte: float
:param duration_lte:
:type duration_lte: float
- :param task_display_name_pattern: SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). Regular expressions are **not** supported.
+ :param task_display_name_pattern:
:type task_display_name_pattern: str
:param state:
:type state: List[str]
@@ -5054,7 +4395,7 @@
updated_at_lte: Optional[datetime] = None,
duration_gte: Optional[Union[StrictFloat, StrictInt]] = None,
duration_lte: Optional[Union[StrictFloat, StrictInt]] = None,
- task_display_name_pattern: Annotated[Optional[StrictStr], Field(description="SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). Regular expressions are **not** supported.")] = None,
+ task_display_name_pattern: Optional[StrictStr] = None,
state: Optional[List[StrictStr]] = None,
pool: Optional[List[StrictStr]] = None,
queue: Optional[List[StrictStr]] = None,
@@ -5110,7 +4451,7 @@
:type duration_gte: float
:param duration_lte:
:type duration_lte: float
- :param task_display_name_pattern: SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). Regular expressions are **not** supported.
+ :param task_display_name_pattern:
:type task_display_name_pattern: str
:param state:
:type state: List[str]
diff --git a/airflow_client/client/api/variable_api.py b/airflow_client/client/api/variable_api.py
index 5481773..8900fa9 100644
--- a/airflow_client/client/api/variable_api.py
+++ b/airflow_client/client/api/variable_api.py
@@ -878,7 +878,7 @@
limit: Optional[Annotated[int, Field(strict=True, ge=0)]] = None,
offset: Optional[Annotated[int, Field(strict=True, ge=0)]] = None,
order_by: Optional[StrictStr] = None,
- variable_key_pattern: Annotated[Optional[StrictStr], Field(description="SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). Regular expressions are **not** supported.")] = None,
+ variable_key_pattern: Optional[StrictStr] = None,
_request_timeout: Union[
None,
Annotated[StrictFloat, Field(gt=0)],
@@ -902,7 +902,7 @@
:type offset: int
:param order_by:
:type order_by: str
- :param variable_key_pattern: SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). Regular expressions are **not** supported.
+ :param variable_key_pattern:
:type variable_key_pattern: str
:param _request_timeout: timeout setting for this request. If one
number provided, it will be total request
@@ -960,7 +960,7 @@
limit: Optional[Annotated[int, Field(strict=True, ge=0)]] = None,
offset: Optional[Annotated[int, Field(strict=True, ge=0)]] = None,
order_by: Optional[StrictStr] = None,
- variable_key_pattern: Annotated[Optional[StrictStr], Field(description="SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). Regular expressions are **not** supported.")] = None,
+ variable_key_pattern: Optional[StrictStr] = None,
_request_timeout: Union[
None,
Annotated[StrictFloat, Field(gt=0)],
@@ -984,7 +984,7 @@
:type offset: int
:param order_by:
:type order_by: str
- :param variable_key_pattern: SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). Regular expressions are **not** supported.
+ :param variable_key_pattern:
:type variable_key_pattern: str
:param _request_timeout: timeout setting for this request. If one
number provided, it will be total request
@@ -1042,7 +1042,7 @@
limit: Optional[Annotated[int, Field(strict=True, ge=0)]] = None,
offset: Optional[Annotated[int, Field(strict=True, ge=0)]] = None,
order_by: Optional[StrictStr] = None,
- variable_key_pattern: Annotated[Optional[StrictStr], Field(description="SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). Regular expressions are **not** supported.")] = None,
+ variable_key_pattern: Optional[StrictStr] = None,
_request_timeout: Union[
None,
Annotated[StrictFloat, Field(gt=0)],
@@ -1066,7 +1066,7 @@
:type offset: int
:param order_by:
:type order_by: str
- :param variable_key_pattern: SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). Regular expressions are **not** supported.
+ :param variable_key_pattern:
:type variable_key_pattern: str
:param _request_timeout: timeout setting for this request. If one
number provided, it will be total request
diff --git a/airflow_client/client/models/__init__.py b/airflow_client/client/models/__init__.py
index 303b7a0..fe07d0c 100644
--- a/airflow_client/client/models/__init__.py
+++ b/airflow_client/client/models/__init__.py
@@ -89,7 +89,6 @@
from airflow_client.client.models.dry_run_backfill_response import DryRunBackfillResponse
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
from airflow_client.client.models.extra_link_collection_response import ExtraLinkCollectionResponse
from airflow_client.client.models.fast_api_app_response import FastAPIAppResponse
from airflow_client.client.models.fast_api_root_middleware_response import FastAPIRootMiddlewareResponse
@@ -100,11 +99,8 @@
from airflow_client.client.models.import_error_response import ImportErrorResponse
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.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
-from airflow_client.client.models.plugin_import_error_response import PluginImportErrorResponse
from airflow_client.client.models.plugin_response import PluginResponse
from airflow_client.client.models.pool_body import PoolBody
from airflow_client.client.models.pool_collection_response import PoolCollectionResponse
diff --git a/airflow_client/client/models/asset_response.py b/airflow_client/client/models/asset_response.py
index cc33dec..49a3235 100644
--- a/airflow_client/client/models/asset_response.py
+++ b/airflow_client/client/models/asset_response.py
@@ -22,7 +22,6 @@
from typing import Any, ClassVar, Dict, List, Optional
from airflow_client.client.models.asset_alias_response import AssetAliasResponse
from airflow_client.client.models.dag_schedule_asset_reference import DagScheduleAssetReference
-from airflow_client.client.models.last_asset_event_response import LastAssetEventResponse
from airflow_client.client.models.task_outlet_asset_reference import TaskOutletAssetReference
from typing import Optional, Set
from typing_extensions import Self
@@ -37,12 +36,11 @@
extra: Optional[Dict[str, Any]] = None
group: StrictStr
id: StrictInt
- last_asset_event: Optional[LastAssetEventResponse] = None
name: StrictStr
producing_tasks: List[TaskOutletAssetReference]
updated_at: datetime
uri: StrictStr
- __properties: ClassVar[List[str]] = ["aliases", "consuming_dags", "created_at", "extra", "group", "id", "last_asset_event", "name", "producing_tasks", "updated_at", "uri"]
+ __properties: ClassVar[List[str]] = ["aliases", "consuming_dags", "created_at", "extra", "group", "id", "name", "producing_tasks", "updated_at", "uri"]
model_config = ConfigDict(
populate_by_name=True,
@@ -97,9 +95,6 @@
if _item_consuming_dags:
_items.append(_item_consuming_dags.to_dict())
_dict['consuming_dags'] = _items
- # override the default output from pydantic by calling `to_dict()` of last_asset_event
- if self.last_asset_event:
- _dict['last_asset_event'] = self.last_asset_event.to_dict()
# override the default output from pydantic by calling `to_dict()` of each item in producing_tasks (list)
_items = []
if self.producing_tasks:
@@ -125,7 +120,6 @@
"extra": obj.get("extra"),
"group": obj.get("group"),
"id": obj.get("id"),
- "last_asset_event": LastAssetEventResponse.from_dict(obj["last_asset_event"]) if obj.get("last_asset_event") is not None else None,
"name": obj.get("name"),
"producing_tasks": [TaskOutletAssetReference.from_dict(_item) for _item in obj["producing_tasks"]] if obj.get("producing_tasks") is not None else None,
"updated_at": obj.get("updated_at"),
diff --git a/airflow_client/client/models/backfill_response.py b/airflow_client/client/models/backfill_response.py
index 4f8664d..569b6e3 100644
--- a/airflow_client/client/models/backfill_response.py
+++ b/airflow_client/client/models/backfill_response.py
@@ -31,7 +31,6 @@
""" # noqa: E501
completed_at: Optional[datetime] = None
created_at: datetime
- dag_display_name: StrictStr
dag_id: StrictStr
dag_run_conf: Dict[str, Any]
from_date: datetime
@@ -41,7 +40,7 @@
reprocess_behavior: ReprocessBehavior
to_date: datetime
updated_at: datetime
- __properties: ClassVar[List[str]] = ["completed_at", "created_at", "dag_display_name", "dag_id", "dag_run_conf", "from_date", "id", "is_paused", "max_active_runs", "reprocess_behavior", "to_date", "updated_at"]
+ __properties: ClassVar[List[str]] = ["completed_at", "created_at", "dag_id", "dag_run_conf", "from_date", "id", "is_paused", "max_active_runs", "reprocess_behavior", "to_date", "updated_at"]
model_config = ConfigDict(
populate_by_name=True,
@@ -96,7 +95,6 @@
_obj = cls.model_validate({
"completed_at": obj.get("completed_at"),
"created_at": obj.get("created_at"),
- "dag_display_name": obj.get("dag_display_name"),
"dag_id": obj.get("dag_id"),
"dag_run_conf": obj.get("dag_run_conf"),
"from_date": obj.get("from_date"),
diff --git a/airflow_client/client/models/dag_details_response.py b/airflow_client/client/models/dag_details_response.py
index 35606c7..8c4bef7 100644
--- a/airflow_client/client/models/dag_details_response.py
+++ b/airflow_client/client/models/dag_details_response.py
@@ -37,7 +37,6 @@
dag_display_name: StrictStr
dag_id: StrictStr
dag_run_timeout: Optional[StrictStr] = None
- default_args: Optional[Dict[str, Any]] = None
description: Optional[StrictStr] = None
doc_md: Optional[StrictStr] = None
end_date: Optional[datetime] = None
@@ -70,7 +69,7 @@
timetable_description: Optional[StrictStr] = None
timetable_summary: Optional[StrictStr] = None
timezone: Optional[StrictStr] = None
- __properties: ClassVar[List[str]] = ["asset_expression", "bundle_name", "bundle_version", "catchup", "concurrency", "dag_display_name", "dag_id", "dag_run_timeout", "default_args", "description", "doc_md", "end_date", "file_token", "fileloc", "has_import_errors", "has_task_concurrency_limits", "is_paused", "is_paused_upon_creation", "is_stale", "last_expired", "last_parsed", "last_parsed_time", "latest_dag_version", "max_active_runs", "max_active_tasks", "max_consecutive_failed_dag_runs", "next_dagrun_data_interval_end", "next_dagrun_data_interval_start", "next_dagrun_logical_date", "next_dagrun_run_after", "owner_links", "owners", "params", "relative_fileloc", "render_template_as_native_obj", "start_date", "tags", "template_search_path", "timetable_description", "timetable_summary", "timezone"]
+ __properties: ClassVar[List[str]] = ["asset_expression", "bundle_name", "bundle_version", "catchup", "concurrency", "dag_display_name", "dag_id", "dag_run_timeout", "description", "doc_md", "end_date", "file_token", "fileloc", "has_import_errors", "has_task_concurrency_limits", "is_paused", "is_paused_upon_creation", "is_stale", "last_expired", "last_parsed", "last_parsed_time", "latest_dag_version", "max_active_runs", "max_active_tasks", "max_consecutive_failed_dag_runs", "next_dagrun_data_interval_end", "next_dagrun_data_interval_start", "next_dagrun_logical_date", "next_dagrun_run_after", "owner_links", "owners", "params", "relative_fileloc", "render_template_as_native_obj", "start_date", "tags", "template_search_path", "timetable_description", "timetable_summary", "timezone"]
model_config = ConfigDict(
populate_by_name=True,
@@ -145,7 +144,6 @@
"dag_display_name": obj.get("dag_display_name"),
"dag_id": obj.get("dag_id"),
"dag_run_timeout": obj.get("dag_run_timeout"),
- "default_args": obj.get("default_args"),
"description": obj.get("description"),
"doc_md": obj.get("doc_md"),
"end_date": obj.get("end_date"),
diff --git a/airflow_client/client/models/dag_run_response.py b/airflow_client/client/models/dag_run_response.py
index f7cdb2d..9da74c6 100644
--- a/airflow_client/client/models/dag_run_response.py
+++ b/airflow_client/client/models/dag_run_response.py
@@ -33,7 +33,6 @@
""" # noqa: E501
bundle_version: Optional[StrictStr] = None
conf: Dict[str, Any]
- dag_display_name: StrictStr
dag_id: StrictStr
dag_run_id: StrictStr
dag_versions: List[DagVersionResponse]
@@ -49,7 +48,7 @@
start_date: Optional[datetime] = None
state: DagRunState
triggered_by: Optional[DagRunTriggeredByType] = None
- __properties: ClassVar[List[str]] = ["bundle_version", "conf", "dag_display_name", "dag_id", "dag_run_id", "dag_versions", "data_interval_end", "data_interval_start", "end_date", "last_scheduling_decision", "logical_date", "note", "queued_at", "run_after", "run_type", "start_date", "state", "triggered_by"]
+ __properties: ClassVar[List[str]] = ["bundle_version", "conf", "dag_id", "dag_run_id", "dag_versions", "data_interval_end", "data_interval_start", "end_date", "last_scheduling_decision", "logical_date", "note", "queued_at", "run_after", "run_type", "start_date", "state", "triggered_by"]
model_config = ConfigDict(
populate_by_name=True,
@@ -111,7 +110,6 @@
_obj = cls.model_validate({
"bundle_version": obj.get("bundle_version"),
"conf": obj.get("conf"),
- "dag_display_name": obj.get("dag_display_name"),
"dag_id": obj.get("dag_id"),
"dag_run_id": obj.get("dag_run_id"),
"dag_versions": [DagVersionResponse.from_dict(_item) for _item in obj["dag_versions"]] if obj.get("dag_versions") is not None else None,
diff --git a/airflow_client/client/models/dag_source_response.py b/airflow_client/client/models/dag_source_response.py
index a93f3cc..a0ee01f 100644
--- a/airflow_client/client/models/dag_source_response.py
+++ b/airflow_client/client/models/dag_source_response.py
@@ -27,10 +27,9 @@
DAG Source serializer for responses.
""" # noqa: E501
content: Optional[StrictStr] = None
- dag_display_name: StrictStr
dag_id: StrictStr
version_number: Optional[StrictInt] = None
- __properties: ClassVar[List[str]] = ["content", "dag_display_name", "dag_id", "version_number"]
+ __properties: ClassVar[List[str]] = ["content", "dag_id", "version_number"]
model_config = ConfigDict(
populate_by_name=True,
@@ -84,7 +83,6 @@
_obj = cls.model_validate({
"content": obj.get("content"),
- "dag_display_name": obj.get("dag_display_name"),
"dag_id": obj.get("dag_id"),
"version_number": obj.get("version_number")
})
diff --git a/airflow_client/client/models/dag_version_response.py b/airflow_client/client/models/dag_version_response.py
index b9ed86d..d9ad70b 100644
--- a/airflow_client/client/models/dag_version_response.py
+++ b/airflow_client/client/models/dag_version_response.py
@@ -31,11 +31,10 @@
bundle_url: Optional[StrictStr] = None
bundle_version: Optional[StrictStr] = None
created_at: datetime
- dag_display_name: StrictStr
dag_id: StrictStr
id: StrictStr
version_number: StrictInt
- __properties: ClassVar[List[str]] = ["bundle_name", "bundle_url", "bundle_version", "created_at", "dag_display_name", "dag_id", "id", "version_number"]
+ __properties: ClassVar[List[str]] = ["bundle_name", "bundle_url", "bundle_version", "created_at", "dag_id", "id", "version_number"]
model_config = ConfigDict(
populate_by_name=True,
@@ -92,7 +91,6 @@
"bundle_url": obj.get("bundle_url"),
"bundle_version": obj.get("bundle_version"),
"created_at": obj.get("created_at"),
- "dag_display_name": obj.get("dag_display_name"),
"dag_id": obj.get("dag_id"),
"id": obj.get("id"),
"version_number": obj.get("version_number")
diff --git a/airflow_client/client/models/event_log_response.py b/airflow_client/client/models/event_log_response.py
index d864db2..e7cb2bb 100644
--- a/airflow_client/client/models/event_log_response.py
+++ b/airflow_client/client/models/event_log_response.py
@@ -27,7 +27,6 @@
"""
Event Log Response.
""" # noqa: E501
- dag_display_name: Optional[StrictStr] = None
dag_id: Optional[StrictStr] = None
event: StrictStr
event_log_id: StrictInt
@@ -39,7 +38,7 @@
task_id: Optional[StrictStr] = None
try_number: Optional[StrictInt] = None
when: datetime
- __properties: ClassVar[List[str]] = ["dag_display_name", "dag_id", "event", "event_log_id", "extra", "logical_date", "map_index", "owner", "run_id", "task_id", "try_number", "when"]
+ __properties: ClassVar[List[str]] = ["dag_id", "event", "event_log_id", "extra", "logical_date", "map_index", "owner", "run_id", "task_id", "try_number", "when"]
model_config = ConfigDict(
populate_by_name=True,
@@ -92,7 +91,6 @@
return cls.model_validate(obj)
_obj = cls.model_validate({
- "dag_display_name": obj.get("dag_display_name"),
"dag_id": obj.get("dag_id"),
"event": obj.get("event"),
"event_log_id": obj.get("event_log_id"),
diff --git a/airflow_client/client/models/external_log_url_response.py b/airflow_client/client/models/external_log_url_response.py
deleted file mode 100644
index 3b903a6..0000000
--- a/airflow_client/client/models/external_log_url_response.py
+++ /dev/null
@@ -1,87 +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
-
-
-from __future__ import annotations
-import pprint
-import re # noqa: F401
-import json
-
-from pydantic import BaseModel, ConfigDict, StrictStr
-from typing import Any, ClassVar, Dict, List
-from typing import Optional, Set
-from typing_extensions import Self
-
-class ExternalLogUrlResponse(BaseModel):
- """
- Response for the external log URL endpoint.
- """ # noqa: E501
- url: StrictStr
- __properties: ClassVar[List[str]] = ["url"]
-
- model_config = ConfigDict(
- populate_by_name=True,
- validate_assignment=True,
- protected_namespaces=(),
- )
-
-
- def to_str(self) -> str:
- """Returns the string representation of the model using alias"""
- return pprint.pformat(self.model_dump(by_alias=True))
-
- def to_json(self) -> str:
- """Returns the JSON representation of the model using alias"""
- # TODO: pydantic v2: use .model_dump_json(by_alias=True, exclude_unset=True) instead
- return json.dumps(self.to_dict())
-
- @classmethod
- def from_json(cls, json_str: str) -> Optional[Self]:
- """Create an instance of ExternalLogUrlResponse from a JSON string"""
- return cls.from_dict(json.loads(json_str))
-
- def to_dict(self) -> Dict[str, Any]:
- """Return the dictionary representation of the model using alias.
-
- This has the following differences from calling pydantic's
- `self.model_dump(by_alias=True)`:
-
- * `None` is only added to the output dict for nullable fields that
- were set at model initialization. Other fields with value `None`
- are ignored.
- """
- excluded_fields: Set[str] = set([
- ])
-
- _dict = self.model_dump(
- by_alias=True,
- exclude=excluded_fields,
- exclude_none=True,
- )
- return _dict
-
- @classmethod
- def from_dict(cls, obj: Optional[Dict[str, Any]]) -> Optional[Self]:
- """Create an instance of ExternalLogUrlResponse from a dict"""
- if obj is None:
- return None
-
- if not isinstance(obj, dict):
- return cls.model_validate(obj)
-
- _obj = cls.model_validate({
- "url": obj.get("url")
- })
- return _obj
-
-
diff --git a/airflow_client/client/models/job_response.py b/airflow_client/client/models/job_response.py
index a153cf8..07287b5 100644
--- a/airflow_client/client/models/job_response.py
+++ b/airflow_client/client/models/job_response.py
@@ -27,7 +27,6 @@
"""
Job serializer for responses.
""" # noqa: E501
- dag_display_name: Optional[StrictStr] = None
dag_id: Optional[StrictStr] = None
end_date: Optional[datetime] = None
executor_class: Optional[StrictStr] = None
@@ -38,7 +37,7 @@
start_date: Optional[datetime] = None
state: Optional[StrictStr] = None
unixname: Optional[StrictStr] = None
- __properties: ClassVar[List[str]] = ["dag_display_name", "dag_id", "end_date", "executor_class", "hostname", "id", "job_type", "latest_heartbeat", "start_date", "state", "unixname"]
+ __properties: ClassVar[List[str]] = ["dag_id", "end_date", "executor_class", "hostname", "id", "job_type", "latest_heartbeat", "start_date", "state", "unixname"]
model_config = ConfigDict(
populate_by_name=True,
@@ -91,7 +90,6 @@
return cls.model_validate(obj)
_obj = cls.model_validate({
- "dag_display_name": obj.get("dag_display_name"),
"dag_id": obj.get("dag_id"),
"end_date": obj.get("end_date"),
"executor_class": obj.get("executor_class"),
diff --git a/airflow_client/client/models/last_asset_event_response.py b/airflow_client/client/models/last_asset_event_response.py
deleted file mode 100644
index 288f545..0000000
--- a/airflow_client/client/models/last_asset_event_response.py
+++ /dev/null
@@ -1,91 +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
-
-
-from __future__ import annotations
-import pprint
-import re # noqa: F401
-import json
-
-from datetime import datetime
-from pydantic import BaseModel, ConfigDict, Field
-from typing import Any, ClassVar, Dict, List, Optional
-from typing_extensions import Annotated
-from typing import Optional, Set
-from typing_extensions import Self
-
-class LastAssetEventResponse(BaseModel):
- """
- Last asset event response serializer.
- """ # noqa: E501
- id: Optional[Annotated[int, Field(strict=True, ge=0)]] = None
- timestamp: Optional[datetime] = None
- __properties: ClassVar[List[str]] = ["id", "timestamp"]
-
- model_config = ConfigDict(
- populate_by_name=True,
- validate_assignment=True,
- protected_namespaces=(),
- )
-
-
- def to_str(self) -> str:
- """Returns the string representation of the model using alias"""
- return pprint.pformat(self.model_dump(by_alias=True))
-
- def to_json(self) -> str:
- """Returns the JSON representation of the model using alias"""
- # TODO: pydantic v2: use .model_dump_json(by_alias=True, exclude_unset=True) instead
- return json.dumps(self.to_dict())
-
- @classmethod
- def from_json(cls, json_str: str) -> Optional[Self]:
- """Create an instance of LastAssetEventResponse from a JSON string"""
- return cls.from_dict(json.loads(json_str))
-
- def to_dict(self) -> Dict[str, Any]:
- """Return the dictionary representation of the model using alias.
-
- This has the following differences from calling pydantic's
- `self.model_dump(by_alias=True)`:
-
- * `None` is only added to the output dict for nullable fields that
- were set at model initialization. Other fields with value `None`
- are ignored.
- """
- excluded_fields: Set[str] = set([
- ])
-
- _dict = self.model_dump(
- by_alias=True,
- exclude=excluded_fields,
- exclude_none=True,
- )
- return _dict
-
- @classmethod
- def from_dict(cls, obj: Optional[Dict[str, Any]]) -> Optional[Self]:
- """Create an instance of LastAssetEventResponse from a dict"""
- if obj is None:
- return None
-
- if not isinstance(obj, dict):
- return cls.model_validate(obj)
-
- _obj = cls.model_validate({
- "id": obj.get("id"),
- "timestamp": obj.get("timestamp")
- })
- return _obj
-
-
diff --git a/airflow_client/client/models/plugin_import_error_collection_response.py b/airflow_client/client/models/plugin_import_error_collection_response.py
deleted file mode 100644
index ce6fdfe..0000000
--- a/airflow_client/client/models/plugin_import_error_collection_response.py
+++ /dev/null
@@ -1,97 +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
-
-
-from __future__ import annotations
-import pprint
-import re # noqa: F401
-import json
-
-from pydantic import BaseModel, ConfigDict, StrictInt
-from typing import Any, ClassVar, Dict, List
-from airflow_client.client.models.plugin_import_error_response import PluginImportErrorResponse
-from typing import Optional, Set
-from typing_extensions import Self
-
-class PluginImportErrorCollectionResponse(BaseModel):
- """
- Plugin Import Error Collection serializer.
- """ # noqa: E501
- import_errors: List[PluginImportErrorResponse]
- total_entries: StrictInt
- __properties: ClassVar[List[str]] = ["import_errors", "total_entries"]
-
- model_config = ConfigDict(
- populate_by_name=True,
- validate_assignment=True,
- protected_namespaces=(),
- )
-
-
- def to_str(self) -> str:
- """Returns the string representation of the model using alias"""
- return pprint.pformat(self.model_dump(by_alias=True))
-
- def to_json(self) -> str:
- """Returns the JSON representation of the model using alias"""
- # TODO: pydantic v2: use .model_dump_json(by_alias=True, exclude_unset=True) instead
- return json.dumps(self.to_dict())
-
- @classmethod
- def from_json(cls, json_str: str) -> Optional[Self]:
- """Create an instance of PluginImportErrorCollectionResponse from a JSON string"""
- return cls.from_dict(json.loads(json_str))
-
- def to_dict(self) -> Dict[str, Any]:
- """Return the dictionary representation of the model using alias.
-
- This has the following differences from calling pydantic's
- `self.model_dump(by_alias=True)`:
-
- * `None` is only added to the output dict for nullable fields that
- were set at model initialization. Other fields with value `None`
- are ignored.
- """
- excluded_fields: Set[str] = set([
- ])
-
- _dict = self.model_dump(
- by_alias=True,
- exclude=excluded_fields,
- exclude_none=True,
- )
- # override the default output from pydantic by calling `to_dict()` of each item in import_errors (list)
- _items = []
- if self.import_errors:
- for _item_import_errors in self.import_errors:
- if _item_import_errors:
- _items.append(_item_import_errors.to_dict())
- _dict['import_errors'] = _items
- return _dict
-
- @classmethod
- def from_dict(cls, obj: Optional[Dict[str, Any]]) -> Optional[Self]:
- """Create an instance of PluginImportErrorCollectionResponse from a dict"""
- if obj is None:
- return None
-
- if not isinstance(obj, dict):
- return cls.model_validate(obj)
-
- _obj = cls.model_validate({
- "import_errors": [PluginImportErrorResponse.from_dict(_item) for _item in obj["import_errors"]] if obj.get("import_errors") is not None else None,
- "total_entries": obj.get("total_entries")
- })
- return _obj
-
-
diff --git a/airflow_client/client/models/plugin_import_error_response.py b/airflow_client/client/models/plugin_import_error_response.py
deleted file mode 100644
index 9e6d312..0000000
--- a/airflow_client/client/models/plugin_import_error_response.py
+++ /dev/null
@@ -1,89 +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
-
-
-from __future__ import annotations
-import pprint
-import re # noqa: F401
-import json
-
-from pydantic import BaseModel, ConfigDict, StrictStr
-from typing import Any, ClassVar, Dict, List
-from typing import Optional, Set
-from typing_extensions import Self
-
-class PluginImportErrorResponse(BaseModel):
- """
- Plugin Import Error serializer for responses.
- """ # noqa: E501
- error: StrictStr
- source: StrictStr
- __properties: ClassVar[List[str]] = ["error", "source"]
-
- model_config = ConfigDict(
- populate_by_name=True,
- validate_assignment=True,
- protected_namespaces=(),
- )
-
-
- def to_str(self) -> str:
- """Returns the string representation of the model using alias"""
- return pprint.pformat(self.model_dump(by_alias=True))
-
- def to_json(self) -> str:
- """Returns the JSON representation of the model using alias"""
- # TODO: pydantic v2: use .model_dump_json(by_alias=True, exclude_unset=True) instead
- return json.dumps(self.to_dict())
-
- @classmethod
- def from_json(cls, json_str: str) -> Optional[Self]:
- """Create an instance of PluginImportErrorResponse from a JSON string"""
- return cls.from_dict(json.loads(json_str))
-
- def to_dict(self) -> Dict[str, Any]:
- """Return the dictionary representation of the model using alias.
-
- This has the following differences from calling pydantic's
- `self.model_dump(by_alias=True)`:
-
- * `None` is only added to the output dict for nullable fields that
- were set at model initialization. Other fields with value `None`
- are ignored.
- """
- excluded_fields: Set[str] = set([
- ])
-
- _dict = self.model_dump(
- by_alias=True,
- exclude=excluded_fields,
- exclude_none=True,
- )
- return _dict
-
- @classmethod
- def from_dict(cls, obj: Optional[Dict[str, Any]]) -> Optional[Self]:
- """Create an instance of PluginImportErrorResponse from a dict"""
- if obj is None:
- return None
-
- if not isinstance(obj, dict):
- return cls.model_validate(obj)
-
- _obj = cls.model_validate({
- "error": obj.get("error"),
- "source": obj.get("source")
- })
- return _obj
-
-
diff --git a/airflow_client/client/models/queued_event_response.py b/airflow_client/client/models/queued_event_response.py
index d9a8a2a..3725503 100644
--- a/airflow_client/client/models/queued_event_response.py
+++ b/airflow_client/client/models/queued_event_response.py
@@ -29,9 +29,8 @@
""" # noqa: E501
asset_id: StrictInt
created_at: datetime
- dag_display_name: StrictStr
dag_id: StrictStr
- __properties: ClassVar[List[str]] = ["asset_id", "created_at", "dag_display_name", "dag_id"]
+ __properties: ClassVar[List[str]] = ["asset_id", "created_at", "dag_id"]
model_config = ConfigDict(
populate_by_name=True,
@@ -86,7 +85,6 @@
_obj = cls.model_validate({
"asset_id": obj.get("asset_id"),
"created_at": obj.get("created_at"),
- "dag_display_name": obj.get("dag_display_name"),
"dag_id": obj.get("dag_id")
})
return _obj
diff --git a/airflow_client/client/models/task_instance_history_response.py b/airflow_client/client/models/task_instance_history_response.py
index d6d141e..3fdbedb 100644
--- a/airflow_client/client/models/task_instance_history_response.py
+++ b/airflow_client/client/models/task_instance_history_response.py
@@ -29,7 +29,6 @@
"""
TaskInstanceHistory serializer for responses.
""" # noqa: E501
- dag_display_name: StrictStr
dag_id: StrictStr
dag_run_id: StrictStr
dag_version: Optional[DagVersionResponse] = None
@@ -54,7 +53,7 @@
task_id: StrictStr
try_number: StrictInt
unixname: Optional[StrictStr] = None
- __properties: ClassVar[List[str]] = ["dag_display_name", "dag_id", "dag_run_id", "dag_version", "duration", "end_date", "executor", "executor_config", "hostname", "map_index", "max_tries", "operator", "pid", "pool", "pool_slots", "priority_weight", "queue", "queued_when", "scheduled_when", "start_date", "state", "task_display_name", "task_id", "try_number", "unixname"]
+ __properties: ClassVar[List[str]] = ["dag_id", "dag_run_id", "dag_version", "duration", "end_date", "executor", "executor_config", "hostname", "map_index", "max_tries", "operator", "pid", "pool", "pool_slots", "priority_weight", "queue", "queued_when", "scheduled_when", "start_date", "state", "task_display_name", "task_id", "try_number", "unixname"]
model_config = ConfigDict(
populate_by_name=True,
@@ -110,7 +109,6 @@
return cls.model_validate(obj)
_obj = cls.model_validate({
- "dag_display_name": obj.get("dag_display_name"),
"dag_id": obj.get("dag_id"),
"dag_run_id": obj.get("dag_run_id"),
"dag_version": DagVersionResponse.from_dict(obj["dag_version"]) if obj.get("dag_version") is not None else None,
diff --git a/airflow_client/client/models/task_instance_response.py b/airflow_client/client/models/task_instance_response.py
index 317ec48..e507075 100644
--- a/airflow_client/client/models/task_instance_response.py
+++ b/airflow_client/client/models/task_instance_response.py
@@ -31,7 +31,6 @@
"""
TaskInstance serializer for responses.
""" # noqa: E501
- dag_display_name: StrictStr
dag_id: StrictStr
dag_run_id: StrictStr
dag_version: Optional[DagVersionResponse] = None
@@ -64,7 +63,7 @@
triggerer_job: Optional[JobResponse] = None
try_number: StrictInt
unixname: Optional[StrictStr] = None
- __properties: ClassVar[List[str]] = ["dag_display_name", "dag_id", "dag_run_id", "dag_version", "duration", "end_date", "executor", "executor_config", "hostname", "id", "logical_date", "map_index", "max_tries", "note", "operator", "pid", "pool", "pool_slots", "priority_weight", "queue", "queued_when", "rendered_fields", "rendered_map_index", "run_after", "scheduled_when", "start_date", "state", "task_display_name", "task_id", "trigger", "triggerer_job", "try_number", "unixname"]
+ __properties: ClassVar[List[str]] = ["dag_id", "dag_run_id", "dag_version", "duration", "end_date", "executor", "executor_config", "hostname", "id", "logical_date", "map_index", "max_tries", "note", "operator", "pid", "pool", "pool_slots", "priority_weight", "queue", "queued_when", "rendered_fields", "rendered_map_index", "run_after", "scheduled_when", "start_date", "state", "task_display_name", "task_id", "trigger", "triggerer_job", "try_number", "unixname"]
model_config = ConfigDict(
populate_by_name=True,
@@ -126,7 +125,6 @@
return cls.model_validate(obj)
_obj = cls.model_validate({
- "dag_display_name": obj.get("dag_display_name"),
"dag_id": obj.get("dag_id"),
"dag_run_id": obj.get("dag_run_id"),
"dag_version": DagVersionResponse.from_dict(obj["dag_version"]) if obj.get("dag_version") is not None else None,
diff --git a/airflow_client/client/models/x_com_response.py b/airflow_client/client/models/x_com_response.py
index eadf0bd..19876c7 100644
--- a/airflow_client/client/models/x_com_response.py
+++ b/airflow_client/client/models/x_com_response.py
@@ -27,7 +27,6 @@
"""
Serializer for a xcom item.
""" # noqa: E501
- dag_display_name: StrictStr
dag_id: StrictStr
key: StrictStr
logical_date: Optional[datetime] = None
@@ -35,7 +34,7 @@
run_id: StrictStr
task_id: StrictStr
timestamp: datetime
- __properties: ClassVar[List[str]] = ["dag_display_name", "dag_id", "key", "logical_date", "map_index", "run_id", "task_id", "timestamp"]
+ __properties: ClassVar[List[str]] = ["dag_id", "key", "logical_date", "map_index", "run_id", "task_id", "timestamp"]
model_config = ConfigDict(
populate_by_name=True,
@@ -88,7 +87,6 @@
return cls.model_validate(obj)
_obj = cls.model_validate({
- "dag_display_name": obj.get("dag_display_name"),
"dag_id": obj.get("dag_id"),
"key": obj.get("key"),
"logical_date": obj.get("logical_date"),
diff --git a/airflow_client/client/models/x_com_response_native.py b/airflow_client/client/models/x_com_response_native.py
index 170fed2..19feb8d 100644
--- a/airflow_client/client/models/x_com_response_native.py
+++ b/airflow_client/client/models/x_com_response_native.py
@@ -27,7 +27,6 @@
"""
XCom response serializer with native return type.
""" # noqa: E501
- dag_display_name: StrictStr
dag_id: StrictStr
key: StrictStr
logical_date: Optional[datetime] = None
@@ -36,7 +35,7 @@
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_id", "timestamp", "value"]
+ __properties: ClassVar[List[str]] = ["dag_id", "key", "logical_date", "map_index", "run_id", "task_id", "timestamp", "value"]
model_config = ConfigDict(
populate_by_name=True,
@@ -94,7 +93,6 @@
return cls.model_validate(obj)
_obj = cls.model_validate({
- "dag_display_name": obj.get("dag_display_name"),
"dag_id": obj.get("dag_id"),
"key": obj.get("key"),
"logical_date": obj.get("logical_date"),
diff --git a/airflow_client/client/models/x_com_response_string.py b/airflow_client/client/models/x_com_response_string.py
index 79361fe..2c30e01 100644
--- a/airflow_client/client/models/x_com_response_string.py
+++ b/airflow_client/client/models/x_com_response_string.py
@@ -27,7 +27,6 @@
"""
XCom response serializer with string return type.
""" # noqa: E501
- dag_display_name: StrictStr
dag_id: StrictStr
key: StrictStr
logical_date: Optional[datetime] = None
@@ -36,7 +35,7 @@
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_id", "timestamp", "value"]
+ __properties: ClassVar[List[str]] = ["dag_id", "key", "logical_date", "map_index", "run_id", "task_id", "timestamp", "value"]
model_config = ConfigDict(
populate_by_name=True,
@@ -89,7 +88,6 @@
return cls.model_validate(obj)
_obj = cls.model_validate({
- "dag_display_name": obj.get("dag_display_name"),
"dag_id": obj.get("dag_id"),
"key": obj.get("key"),
"logical_date": obj.get("logical_date"),
diff --git a/docs/AssetApi.md b/docs/AssetApi.md
index 99536dd..78d960e 100644
--- a/docs/AssetApi.md
+++ b/docs/AssetApi.md
@@ -528,7 +528,7 @@
api_instance = airflow_client.client.AssetApi(api_client)
limit = 50 # int | (optional) (default to 50)
offset = 0 # int | (optional) (default to 0)
- name_pattern = 'name_pattern_example' # str | SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). Regular expressions are **not** supported. (optional)
+ name_pattern = 'name_pattern_example' # str | (optional)
order_by = 'id' # str | (optional) (default to 'id')
try:
@@ -549,7 +549,7 @@
------------- | ------------- | ------------- | -------------
**limit** | **int**| | [optional] [default to 50]
**offset** | **int**| | [optional] [default to 0]
- **name_pattern** | **str**| SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). Regular expressions are **not** supported. | [optional]
+ **name_pattern** | **str**| | [optional]
**order_by** | **str**| | [optional] [default to 'id']
### Return type
@@ -791,8 +791,8 @@
api_instance = airflow_client.client.AssetApi(api_client)
limit = 50 # int | (optional) (default to 50)
offset = 0 # int | (optional) (default to 0)
- name_pattern = 'name_pattern_example' # str | SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). Regular expressions are **not** supported. (optional)
- uri_pattern = 'uri_pattern_example' # str | SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). Regular expressions are **not** supported. (optional)
+ name_pattern = 'name_pattern_example' # str | (optional)
+ uri_pattern = 'uri_pattern_example' # str | (optional)
dag_ids = ['dag_ids_example'] # List[str] | (optional)
only_active = True # bool | (optional) (default to True)
order_by = 'id' # str | (optional) (default to 'id')
@@ -815,8 +815,8 @@
------------- | ------------- | ------------- | -------------
**limit** | **int**| | [optional] [default to 50]
**offset** | **int**| | [optional] [default to 0]
- **name_pattern** | **str**| SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). Regular expressions are **not** supported. | [optional]
- **uri_pattern** | **str**| SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). Regular expressions are **not** supported. | [optional]
+ **name_pattern** | **str**| | [optional]
+ **uri_pattern** | **str**| | [optional]
**dag_ids** | [**List[str]**](str.md)| | [optional]
**only_active** | **bool**| | [optional] [default to True]
**order_by** | **str**| | [optional] [default to 'id']
diff --git a/docs/AssetResponse.md b/docs/AssetResponse.md
index 5e6932f..e99bb00 100644
--- a/docs/AssetResponse.md
+++ b/docs/AssetResponse.md
@@ -12,7 +12,6 @@
**extra** | **object** | | [optional]
**group** | **str** | |
**id** | **int** | |
-**last_asset_event** | [**LastAssetEventResponse**](LastAssetEventResponse.md) | | [optional]
**name** | **str** | |
**producing_tasks** | [**List[TaskOutletAssetReference]**](TaskOutletAssetReference.md) | |
**updated_at** | **datetime** | |
diff --git a/docs/BackfillResponse.md b/docs/BackfillResponse.md
index bf89ab7..f3479bd 100644
--- a/docs/BackfillResponse.md
+++ b/docs/BackfillResponse.md
@@ -8,7 +8,6 @@
------------ | ------------- | ------------- | -------------
**completed_at** | **datetime** | | [optional]
**created_at** | **datetime** | |
-**dag_display_name** | **str** | |
**dag_id** | **str** | |
**dag_run_conf** | **object** | |
**from_date** | **datetime** | |
diff --git a/docs/ConnectionApi.md b/docs/ConnectionApi.md
index 5d00ba7..af99887 100644
--- a/docs/ConnectionApi.md
+++ b/docs/ConnectionApi.md
@@ -355,7 +355,7 @@
limit = 50 # int | (optional) (default to 50)
offset = 0 # int | (optional) (default to 0)
order_by = 'id' # str | (optional) (default to 'id')
- connection_id_pattern = 'connection_id_pattern_example' # str | SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). Regular expressions are **not** supported. (optional)
+ connection_id_pattern = 'connection_id_pattern_example' # str | (optional)
try:
# Get Connections
@@ -376,7 +376,7 @@
**limit** | **int**| | [optional] [default to 50]
**offset** | **int**| | [optional] [default to 0]
**order_by** | **str**| | [optional] [default to 'id']
- **connection_id_pattern** | **str**| SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). Regular expressions are **not** supported. | [optional]
+ **connection_id_pattern** | **str**| | [optional]
### Return type
diff --git a/docs/DAGApi.md b/docs/DAGApi.md
index 5f002b7..9148268 100644
--- a/docs/DAGApi.md
+++ b/docs/DAGApi.md
@@ -289,7 +289,7 @@
limit = 50 # int | (optional) (default to 50)
offset = 0 # int | (optional) (default to 0)
order_by = 'name' # str | (optional) (default to 'name')
- tag_name_pattern = 'tag_name_pattern_example' # str | SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). Regular expressions are **not** supported. (optional)
+ tag_name_pattern = 'tag_name_pattern_example' # str | (optional)
try:
# Get Dag Tags
@@ -310,7 +310,7 @@
**limit** | **int**| | [optional] [default to 50]
**offset** | **int**| | [optional] [default to 0]
**order_by** | **str**| | [optional] [default to 'name']
- **tag_name_pattern** | **str**| SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). Regular expressions are **not** supported. | [optional]
+ **tag_name_pattern** | **str**| | [optional]
### Return type
@@ -376,8 +376,8 @@
tags = ['tags_example'] # List[str] | (optional)
tags_match_mode = 'tags_match_mode_example' # str | (optional)
owners = ['owners_example'] # List[str] | (optional)
- dag_id_pattern = 'dag_id_pattern_example' # str | SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). Regular expressions are **not** supported. (optional)
- dag_display_name_pattern = 'dag_display_name_pattern_example' # str | SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). Regular expressions are **not** supported. (optional)
+ dag_id_pattern = 'dag_id_pattern_example' # str | (optional)
+ dag_display_name_pattern = 'dag_display_name_pattern_example' # str | (optional)
exclude_stale = True # bool | (optional) (default to True)
paused = True # bool | (optional)
last_dag_run_state = airflow_client.client.DagRunState() # DagRunState | (optional)
@@ -409,8 +409,8 @@
**tags** | [**List[str]**](str.md)| | [optional]
**tags_match_mode** | **str**| | [optional]
**owners** | [**List[str]**](str.md)| | [optional]
- **dag_id_pattern** | **str**| SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). Regular expressions are **not** supported. | [optional]
- **dag_display_name_pattern** | **str**| SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). Regular expressions are **not** supported. | [optional]
+ **dag_id_pattern** | **str**| | [optional]
+ **dag_display_name_pattern** | **str**| | [optional]
**exclude_stale** | **bool**| | [optional] [default to True]
**paused** | **bool**| | [optional]
**last_dag_run_state** | [**DagRunState**](.md)| | [optional]
@@ -573,7 +573,7 @@
tags = ['tags_example'] # List[str] | (optional)
tags_match_mode = 'tags_match_mode_example' # str | (optional)
owners = ['owners_example'] # List[str] | (optional)
- dag_id_pattern = 'dag_id_pattern_example' # str | SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). Regular expressions are **not** supported. (optional)
+ dag_id_pattern = 'dag_id_pattern_example' # str | (optional)
exclude_stale = True # bool | (optional) (default to True)
paused = True # bool | (optional)
last_dag_run_state = airflow_client.client.DagRunState() # DagRunState | (optional)
@@ -601,7 +601,7 @@
**tags** | [**List[str]**](str.md)| | [optional]
**tags_match_mode** | **str**| | [optional]
**owners** | [**List[str]**](str.md)| | [optional]
- **dag_id_pattern** | **str**| SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). Regular expressions are **not** supported. | [optional]
+ **dag_id_pattern** | **str**| | [optional]
**exclude_stale** | **bool**| | [optional] [default to True]
**paused** | **bool**| | [optional]
**last_dag_run_state** | [**DagRunState**](.md)| | [optional]
diff --git a/docs/DAGDetailsResponse.md b/docs/DAGDetailsResponse.md
index 99b0501..dc71dc3 100644
--- a/docs/DAGDetailsResponse.md
+++ b/docs/DAGDetailsResponse.md
@@ -14,7 +14,6 @@
**dag_display_name** | **str** | |
**dag_id** | **str** | |
**dag_run_timeout** | **str** | | [optional]
-**default_args** | **object** | | [optional]
**description** | **str** | | [optional]
**doc_md** | **str** | | [optional]
**end_date** | **datetime** | | [optional]
diff --git a/docs/DAGRunResponse.md b/docs/DAGRunResponse.md
index c5615b4..61b4893 100644
--- a/docs/DAGRunResponse.md
+++ b/docs/DAGRunResponse.md
@@ -8,7 +8,6 @@
------------ | ------------- | ------------- | -------------
**bundle_version** | **str** | | [optional]
**conf** | **object** | |
-**dag_display_name** | **str** | |
**dag_id** | **str** | |
**dag_run_id** | **str** | |
**dag_versions** | [**List[DagVersionResponse]**](DagVersionResponse.md) | |
diff --git a/docs/DAGSourceResponse.md b/docs/DAGSourceResponse.md
index c806e90..bb25c10 100644
--- a/docs/DAGSourceResponse.md
+++ b/docs/DAGSourceResponse.md
@@ -7,7 +7,6 @@
Name | Type | Description | Notes
------------ | ------------- | ------------- | -------------
**content** | **str** | | [optional]
-**dag_display_name** | **str** | |
**dag_id** | **str** | |
**version_number** | **int** | | [optional]
diff --git a/docs/DagVersionResponse.md b/docs/DagVersionResponse.md
index a89bf6a..a18910f 100644
--- a/docs/DagVersionResponse.md
+++ b/docs/DagVersionResponse.md
@@ -10,7 +10,6 @@
**bundle_url** | **str** | | [optional]
**bundle_version** | **str** | | [optional]
**created_at** | **datetime** | |
-**dag_display_name** | **str** | |
**dag_id** | **str** | |
**id** | **str** | |
**version_number** | **int** | |
diff --git a/docs/EventLogResponse.md b/docs/EventLogResponse.md
index 23df114..b054803 100644
--- a/docs/EventLogResponse.md
+++ b/docs/EventLogResponse.md
@@ -6,7 +6,6 @@
Name | Type | Description | Notes
------------ | ------------- | ------------- | -------------
-**dag_display_name** | **str** | | [optional]
**dag_id** | **str** | | [optional]
**event** | **str** | |
**event_log_id** | **int** | |
diff --git a/docs/ExternalLogUrlResponse.md b/docs/ExternalLogUrlResponse.md
deleted file mode 100644
index bce0a0d..0000000
--- a/docs/ExternalLogUrlResponse.md
+++ /dev/null
@@ -1,30 +0,0 @@
-# ExternalLogUrlResponse
-
-Response for the external log URL endpoint.
-
-## Properties
-
-Name | Type | Description | Notes
------------- | ------------- | ------------- | -------------
-**url** | **str** | |
-
-## Example
-
-```python
-from airflow_client.client.models.external_log_url_response import ExternalLogUrlResponse
-
-# TODO update the JSON string below
-json = "{}"
-# create an instance of ExternalLogUrlResponse from a JSON string
-external_log_url_response_instance = ExternalLogUrlResponse.from_json(json)
-# print the JSON string representation of the object
-print(ExternalLogUrlResponse.to_json())
-
-# convert the object into a dict
-external_log_url_response_dict = external_log_url_response_instance.to_dict()
-# create an instance of ExternalLogUrlResponse from a dict
-external_log_url_response_from_dict = ExternalLogUrlResponse.from_dict(external_log_url_response_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/JobResponse.md b/docs/JobResponse.md
index 74cb3d8..f20cbe6 100644
--- a/docs/JobResponse.md
+++ b/docs/JobResponse.md
@@ -6,7 +6,6 @@
Name | Type | Description | Notes
------------ | ------------- | ------------- | -------------
-**dag_display_name** | **str** | | [optional]
**dag_id** | **str** | | [optional]
**end_date** | **datetime** | | [optional]
**executor_class** | **str** | | [optional]
diff --git a/docs/LastAssetEventResponse.md b/docs/LastAssetEventResponse.md
deleted file mode 100644
index 485c02e..0000000
--- a/docs/LastAssetEventResponse.md
+++ /dev/null
@@ -1,31 +0,0 @@
-# LastAssetEventResponse
-
-Last asset event response serializer.
-
-## Properties
-
-Name | Type | Description | Notes
------------- | ------------- | ------------- | -------------
-**id** | **int** | | [optional]
-**timestamp** | **datetime** | | [optional]
-
-## Example
-
-```python
-from airflow_client.client.models.last_asset_event_response import LastAssetEventResponse
-
-# TODO update the JSON string below
-json = "{}"
-# create an instance of LastAssetEventResponse from a JSON string
-last_asset_event_response_instance = LastAssetEventResponse.from_json(json)
-# print the JSON string representation of the object
-print(LastAssetEventResponse.to_json())
-
-# convert the object into a dict
-last_asset_event_response_dict = last_asset_event_response_instance.to_dict()
-# create an instance of LastAssetEventResponse from a dict
-last_asset_event_response_from_dict = LastAssetEventResponse.from_dict(last_asset_event_response_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/PluginApi.md b/docs/PluginApi.md
index dd8bd83..76108c8 100644
--- a/docs/PluginApi.md
+++ b/docs/PluginApi.md
@@ -5,7 +5,6 @@
Method | HTTP request | Description
------------- | ------------- | -------------
[**get_plugins**](PluginApi.md#get_plugins) | **GET** /api/v2/plugins | Get Plugins
-[**import_errors**](PluginApi.md#import_errors) | **GET** /api/v2/plugins/importErrors | Import Errors
# **get_plugins**
@@ -86,74 +85,3 @@
[[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)
-# **import_errors**
-> PluginImportErrorCollectionResponse import_errors()
-
-Import Errors
-
-### Example
-
-* OAuth Authentication (OAuth2PasswordBearer):
-
-```python
-import airflow_client.client
-from airflow_client.client.models.plugin_import_error_collection_response import PluginImportErrorCollectionResponse
-from airflow_client.client.rest import ApiException
-from pprint import pprint
-
-# Defining the host is optional and defaults to http://localhost
-# See configuration.py for a list of all supported configuration parameters.
-configuration = airflow_client.client.Configuration(
- host = "http://localhost"
-)
-
-# The client must configure the authentication and authorization parameters
-# in accordance with the API server security policy.
-# Examples for each auth method are provided below, use the example that
-# satisfies your auth use case.
-
-configuration.access_token = os.environ["ACCESS_TOKEN"]
-
-# Enter a context with an instance of the API client
-with airflow_client.client.ApiClient(configuration) as api_client:
- # Create an instance of the API class
- api_instance = airflow_client.client.PluginApi(api_client)
-
- try:
- # Import Errors
- api_response = api_instance.import_errors()
- print("The response of PluginApi->import_errors:\n")
- pprint(api_response)
- except Exception as e:
- print("Exception when calling PluginApi->import_errors: %s\n" % e)
-```
-
-
-
-### Parameters
-
-This endpoint does not need any parameter.
-
-### Return type
-
-[**PluginImportErrorCollectionResponse**](PluginImportErrorCollectionResponse.md)
-
-### Authorization
-
-[OAuth2PasswordBearer](../README.md#OAuth2PasswordBearer)
-
-### HTTP request headers
-
- - **Content-Type**: Not defined
- - **Accept**: application/json
-
-### HTTP response details
-
-| Status code | Description | Response headers |
-|-------------|-------------|------------------|
-**200** | Successful Response | - |
-**401** | Unauthorized | - |
-**403** | Forbidden | - |
-
-[[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/PluginImportErrorCollectionResponse.md b/docs/PluginImportErrorCollectionResponse.md
deleted file mode 100644
index a404f4b..0000000
--- a/docs/PluginImportErrorCollectionResponse.md
+++ /dev/null
@@ -1,31 +0,0 @@
-# PluginImportErrorCollectionResponse
-
-Plugin Import Error Collection serializer.
-
-## Properties
-
-Name | Type | Description | Notes
------------- | ------------- | ------------- | -------------
-**import_errors** | [**List[PluginImportErrorResponse]**](PluginImportErrorResponse.md) | |
-**total_entries** | **int** | |
-
-## Example
-
-```python
-from airflow_client.client.models.plugin_import_error_collection_response import PluginImportErrorCollectionResponse
-
-# TODO update the JSON string below
-json = "{}"
-# create an instance of PluginImportErrorCollectionResponse from a JSON string
-plugin_import_error_collection_response_instance = PluginImportErrorCollectionResponse.from_json(json)
-# print the JSON string representation of the object
-print(PluginImportErrorCollectionResponse.to_json())
-
-# convert the object into a dict
-plugin_import_error_collection_response_dict = plugin_import_error_collection_response_instance.to_dict()
-# create an instance of PluginImportErrorCollectionResponse from a dict
-plugin_import_error_collection_response_from_dict = PluginImportErrorCollectionResponse.from_dict(plugin_import_error_collection_response_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/PluginImportErrorResponse.md b/docs/PluginImportErrorResponse.md
deleted file mode 100644
index 751fbaa..0000000
--- a/docs/PluginImportErrorResponse.md
+++ /dev/null
@@ -1,31 +0,0 @@
-# PluginImportErrorResponse
-
-Plugin Import Error serializer for responses.
-
-## Properties
-
-Name | Type | Description | Notes
------------- | ------------- | ------------- | -------------
-**error** | **str** | |
-**source** | **str** | |
-
-## Example
-
-```python
-from airflow_client.client.models.plugin_import_error_response import PluginImportErrorResponse
-
-# TODO update the JSON string below
-json = "{}"
-# create an instance of PluginImportErrorResponse from a JSON string
-plugin_import_error_response_instance = PluginImportErrorResponse.from_json(json)
-# print the JSON string representation of the object
-print(PluginImportErrorResponse.to_json())
-
-# convert the object into a dict
-plugin_import_error_response_dict = plugin_import_error_response_instance.to_dict()
-# create an instance of PluginImportErrorResponse from a dict
-plugin_import_error_response_from_dict = PluginImportErrorResponse.from_dict(plugin_import_error_response_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/PoolApi.md b/docs/PoolApi.md
index 7479793..e20b2c4 100644
--- a/docs/PoolApi.md
+++ b/docs/PoolApi.md
@@ -284,7 +284,7 @@
limit = 50 # int | (optional) (default to 50)
offset = 0 # int | (optional) (default to 0)
order_by = 'id' # str | (optional) (default to 'id')
- pool_name_pattern = 'pool_name_pattern_example' # str | SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). Regular expressions are **not** supported. (optional)
+ pool_name_pattern = 'pool_name_pattern_example' # str | (optional)
try:
# Get Pools
@@ -305,7 +305,7 @@
**limit** | **int**| | [optional] [default to 50]
**offset** | **int**| | [optional] [default to 0]
**order_by** | **str**| | [optional] [default to 'id']
- **pool_name_pattern** | **str**| SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). Regular expressions are **not** supported. | [optional]
+ **pool_name_pattern** | **str**| | [optional]
### Return type
diff --git a/docs/QueuedEventResponse.md b/docs/QueuedEventResponse.md
index 9a645a2..d96ae94 100644
--- a/docs/QueuedEventResponse.md
+++ b/docs/QueuedEventResponse.md
@@ -8,7 +8,6 @@
------------ | ------------- | ------------- | -------------
**asset_id** | **int** | |
**created_at** | **datetime** | |
-**dag_display_name** | **str** | |
**dag_id** | **str** | |
## Example
diff --git a/docs/ResponseClearDagRun.md b/docs/ResponseClearDagRun.md
index f9c1f8e..549fc0a 100644
--- a/docs/ResponseClearDagRun.md
+++ b/docs/ResponseClearDagRun.md
@@ -9,7 +9,6 @@
**total_entries** | **int** | |
**bundle_version** | **str** | | [optional]
**conf** | **object** | |
-**dag_display_name** | **str** | |
**dag_id** | **str** | |
**dag_run_id** | **str** | |
**dag_versions** | [**List[DagVersionResponse]**](DagVersionResponse.md) | |
diff --git a/docs/ResponseGetXcomEntry.md b/docs/ResponseGetXcomEntry.md
index f927141..b105d59 100644
--- a/docs/ResponseGetXcomEntry.md
+++ b/docs/ResponseGetXcomEntry.md
@@ -5,7 +5,6 @@
Name | Type | Description | Notes
------------ | ------------- | ------------- | -------------
-**dag_display_name** | **str** | |
**dag_id** | **str** | |
**key** | **str** | |
**logical_date** | **datetime** | | [optional]
diff --git a/docs/TaskInstanceApi.md b/docs/TaskInstanceApi.md
index 955bdb7..f1f7cf3 100644
--- a/docs/TaskInstanceApi.md
+++ b/docs/TaskInstanceApi.md
@@ -4,8 +4,6 @@
Method | HTTP request | Description
------------- | ------------- | -------------
-[**delete_task_instance**](TaskInstanceApi.md#delete_task_instance) | **DELETE** /api/v2/dags/{dag_id}/dagRuns/{dag_run_id}/taskInstances/{task_id} | Delete Task Instance
-[**get_external_log_url**](TaskInstanceApi.md#get_external_log_url) | **GET** /api/v2/dags/{dag_id}/dagRuns/{dag_run_id}/taskInstances/{task_id}/externalLogUrl/{try_number} | Get External Log Url
[**get_extra_links**](TaskInstanceApi.md#get_extra_links) | **GET** /api/v2/dags/{dag_id}/dagRuns/{dag_run_id}/taskInstances/{task_id}/links | Get Extra Links
[**get_log**](TaskInstanceApi.md#get_log) | **GET** /api/v2/dags/{dag_id}/dagRuns/{dag_run_id}/taskInstances/{task_id}/logs/{try_number} | Get Log
[**get_mapped_task_instance**](TaskInstanceApi.md#get_mapped_task_instance) | **GET** /api/v2/dags/{dag_id}/dagRuns/{dag_run_id}/taskInstances/{task_id}/{map_index} | Get Mapped Task Instance
@@ -26,178 +24,6 @@
[**post_clear_task_instances**](TaskInstanceApi.md#post_clear_task_instances) | **POST** /api/v2/dags/{dag_id}/clearTaskInstances | Post Clear Task Instances
-# **delete_task_instance**
-> object delete_task_instance(dag_id, dag_run_id, task_id, map_index=map_index)
-
-Delete Task Instance
-
-Delete a task instance.
-
-### Example
-
-* OAuth Authentication (OAuth2PasswordBearer):
-
-```python
-import airflow_client.client
-from airflow_client.client.rest import ApiException
-from pprint import pprint
-
-# Defining the host is optional and defaults to http://localhost
-# See configuration.py for a list of all supported configuration parameters.
-configuration = airflow_client.client.Configuration(
- host = "http://localhost"
-)
-
-# The client must configure the authentication and authorization parameters
-# in accordance with the API server security policy.
-# Examples for each auth method are provided below, use the example that
-# satisfies your auth use case.
-
-configuration.access_token = os.environ["ACCESS_TOKEN"]
-
-# Enter a context with an instance of the API client
-with airflow_client.client.ApiClient(configuration) as api_client:
- # Create an instance of the API class
- api_instance = airflow_client.client.TaskInstanceApi(api_client)
- dag_id = 'dag_id_example' # str |
- dag_run_id = 'dag_run_id_example' # str |
- task_id = 'task_id_example' # str |
- map_index = -1 # int | (optional) (default to -1)
-
- try:
- # Delete Task Instance
- api_response = api_instance.delete_task_instance(dag_id, dag_run_id, task_id, map_index=map_index)
- print("The response of TaskInstanceApi->delete_task_instance:\n")
- pprint(api_response)
- except Exception as e:
- print("Exception when calling TaskInstanceApi->delete_task_instance: %s\n" % e)
-```
-
-
-
-### Parameters
-
-
-Name | Type | Description | Notes
-------------- | ------------- | ------------- | -------------
- **dag_id** | **str**| |
- **dag_run_id** | **str**| |
- **task_id** | **str**| |
- **map_index** | **int**| | [optional] [default to -1]
-
-### Return type
-
-**object**
-
-### Authorization
-
-[OAuth2PasswordBearer](../README.md#OAuth2PasswordBearer)
-
-### HTTP request headers
-
- - **Content-Type**: Not defined
- - **Accept**: application/json
-
-### HTTP response details
-
-| Status code | Description | Response headers |
-|-------------|-------------|------------------|
-**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)
-
-# **get_external_log_url**
-> ExternalLogUrlResponse get_external_log_url(dag_id, dag_run_id, task_id, try_number, map_index=map_index)
-
-Get External Log Url
-
-Get external log URL for a specific task instance.
-
-### Example
-
-* OAuth Authentication (OAuth2PasswordBearer):
-
-```python
-import airflow_client.client
-from airflow_client.client.models.external_log_url_response import ExternalLogUrlResponse
-from airflow_client.client.rest import ApiException
-from pprint import pprint
-
-# Defining the host is optional and defaults to http://localhost
-# See configuration.py for a list of all supported configuration parameters.
-configuration = airflow_client.client.Configuration(
- host = "http://localhost"
-)
-
-# The client must configure the authentication and authorization parameters
-# in accordance with the API server security policy.
-# Examples for each auth method are provided below, use the example that
-# satisfies your auth use case.
-
-configuration.access_token = os.environ["ACCESS_TOKEN"]
-
-# Enter a context with an instance of the API client
-with airflow_client.client.ApiClient(configuration) as api_client:
- # Create an instance of the API class
- api_instance = airflow_client.client.TaskInstanceApi(api_client)
- dag_id = 'dag_id_example' # str |
- dag_run_id = 'dag_run_id_example' # str |
- task_id = 'task_id_example' # str |
- try_number = 56 # int |
- map_index = -1 # int | (optional) (default to -1)
-
- try:
- # Get External Log Url
- api_response = api_instance.get_external_log_url(dag_id, dag_run_id, task_id, try_number, map_index=map_index)
- print("The response of TaskInstanceApi->get_external_log_url:\n")
- pprint(api_response)
- except Exception as e:
- print("Exception when calling TaskInstanceApi->get_external_log_url: %s\n" % e)
-```
-
-
-
-### Parameters
-
-
-Name | Type | Description | Notes
-------------- | ------------- | ------------- | -------------
- **dag_id** | **str**| |
- **dag_run_id** | **str**| |
- **task_id** | **str**| |
- **try_number** | **int**| |
- **map_index** | **int**| | [optional] [default to -1]
-
-### Return type
-
-[**ExternalLogUrlResponse**](ExternalLogUrlResponse.md)
-
-### Authorization
-
-[OAuth2PasswordBearer](../README.md#OAuth2PasswordBearer)
-
-### HTTP request headers
-
- - **Content-Type**: Not defined
- - **Accept**: application/json
-
-### HTTP response details
-
-| Status code | Description | Response headers |
-|-------------|-------------|------------------|
-**200** | Successful Response | - |
-**400** | Bad Request | - |
-**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)
-
# **get_extra_links**
> ExtraLinkCollectionResponse get_extra_links(dag_id, dag_run_id, task_id, map_index=map_index)
@@ -362,7 +188,7 @@
### HTTP request headers
- **Content-Type**: Not defined
- - **Accept**: application/json, application/x-ndjson
+ - **Accept**: application/json, text/plain
### HTTP response details
@@ -1229,7 +1055,7 @@
updated_at_lte = '2013-10-20T19:20:30+01:00' # datetime | (optional)
duration_gte = 3.4 # float | (optional)
duration_lte = 3.4 # float | (optional)
- task_display_name_pattern = 'task_display_name_pattern_example' # str | SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). Regular expressions are **not** supported. (optional)
+ task_display_name_pattern = 'task_display_name_pattern_example' # str | (optional)
state = ['state_example'] # List[str] | (optional)
pool = ['pool_example'] # List[str] | (optional)
queue = ['queue_example'] # List[str] | (optional)
@@ -1270,7 +1096,7 @@
**updated_at_lte** | **datetime**| | [optional]
**duration_gte** | **float**| | [optional]
**duration_lte** | **float**| | [optional]
- **task_display_name_pattern** | **str**| SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). Regular expressions are **not** supported. | [optional]
+ **task_display_name_pattern** | **str**| | [optional]
**state** | [**List[str]**](str.md)| | [optional]
**pool** | [**List[str]**](str.md)| | [optional]
**queue** | [**List[str]**](str.md)| | [optional]
diff --git a/docs/TaskInstanceHistoryResponse.md b/docs/TaskInstanceHistoryResponse.md
index 80b8642..ee09369 100644
--- a/docs/TaskInstanceHistoryResponse.md
+++ b/docs/TaskInstanceHistoryResponse.md
@@ -6,7 +6,6 @@
Name | Type | Description | Notes
------------ | ------------- | ------------- | -------------
-**dag_display_name** | **str** | |
**dag_id** | **str** | |
**dag_run_id** | **str** | |
**dag_version** | [**DagVersionResponse**](DagVersionResponse.md) | | [optional]
diff --git a/docs/TaskInstanceResponse.md b/docs/TaskInstanceResponse.md
index d2acd9a..c4d711b 100644
--- a/docs/TaskInstanceResponse.md
+++ b/docs/TaskInstanceResponse.md
@@ -6,7 +6,6 @@
Name | Type | Description | Notes
------------ | ------------- | ------------- | -------------
-**dag_display_name** | **str** | |
**dag_id** | **str** | |
**dag_run_id** | **str** | |
**dag_version** | [**DagVersionResponse**](DagVersionResponse.md) | | [optional]
diff --git a/docs/VariableApi.md b/docs/VariableApi.md
index 8d1475b..d7ad02f 100644
--- a/docs/VariableApi.md
+++ b/docs/VariableApi.md
@@ -283,7 +283,7 @@
limit = 50 # int | (optional) (default to 50)
offset = 0 # int | (optional) (default to 0)
order_by = 'id' # str | (optional) (default to 'id')
- variable_key_pattern = 'variable_key_pattern_example' # str | SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). Regular expressions are **not** supported. (optional)
+ variable_key_pattern = 'variable_key_pattern_example' # str | (optional)
try:
# Get Variables
@@ -304,7 +304,7 @@
**limit** | **int**| | [optional] [default to 50]
**offset** | **int**| | [optional] [default to 0]
**order_by** | **str**| | [optional] [default to 'id']
- **variable_key_pattern** | **str**| SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). Regular expressions are **not** supported. | [optional]
+ **variable_key_pattern** | **str**| | [optional]
### Return type
diff --git a/docs/XComResponse.md b/docs/XComResponse.md
index 6a69808..b346b71 100644
--- a/docs/XComResponse.md
+++ b/docs/XComResponse.md
@@ -6,7 +6,6 @@
Name | Type | Description | Notes
------------ | ------------- | ------------- | -------------
-**dag_display_name** | **str** | |
**dag_id** | **str** | |
**key** | **str** | |
**logical_date** | **datetime** | | [optional]
diff --git a/docs/XComResponseNative.md b/docs/XComResponseNative.md
index f36f221..7567dd3 100644
--- a/docs/XComResponseNative.md
+++ b/docs/XComResponseNative.md
@@ -6,7 +6,6 @@
Name | Type | Description | Notes
------------ | ------------- | ------------- | -------------
-**dag_display_name** | **str** | |
**dag_id** | **str** | |
**key** | **str** | |
**logical_date** | **datetime** | | [optional]
diff --git a/docs/XComResponseString.md b/docs/XComResponseString.md
index 987612b..dd87c31 100644
--- a/docs/XComResponseString.md
+++ b/docs/XComResponseString.md
@@ -6,7 +6,6 @@
Name | Type | Description | Notes
------------ | ------------- | ------------- | -------------
-**dag_display_name** | **str** | |
**dag_id** | **str** | |
**key** | **str** | |
**logical_date** | **datetime** | | [optional]
diff --git a/pyproject.toml b/pyproject.toml
index 6a16411..ec4baeb 100644
--- a/pyproject.toml
+++ b/pyproject.toml
@@ -52,7 +52,7 @@
dependencies = [
"pydantic >= 2.11.0",
"python-dateutil",
- "urllib3 >= 1.25.3",
+ "urllib3 >= 2.1.0",
]
[project.urls]
@@ -66,7 +66,6 @@
[tool.hatch.envs.test]
dependencies = [
"pytest-cov>=2.8.1",
- "urllib3 >= 1.25.3",
]
[tool.hatch.envs.test.scripts]
diff --git a/spec/v1.yaml b/spec/v2.yaml
similarity index 96%
rename from spec/v1.yaml
rename to spec/v2.yaml
index e29b1ef..279a273 100644
--- a/spec/v1.yaml
+++ b/spec/v2.yaml
@@ -179,9 +179,6 @@
id:
title: Id
type: integer
- last_asset_event:
- $ref: '#/components/schemas/LastAssetEventResponse'
- nullable: true
name:
title: Name
type: string
@@ -273,9 +270,6 @@
format: date-time
title: Created At
type: string
- dag_display_name:
- title: Dag Display Name
- type: string
dag_id:
title: Dag Id
type: string
@@ -318,7 +312,6 @@
- max_active_runs
- created_at
- updated_at
- - dag_display_name
title: BackfillResponse
type: object
BaseInfoResponse:
@@ -910,10 +903,6 @@
format: duration
nullable: true
type: string
- default_args:
- additionalProperties: true
- nullable: true
- type: object
description:
nullable: true
type: string
@@ -1225,9 +1214,6 @@
additionalProperties: true
title: Conf
type: object
- dag_display_name:
- title: Dag Display Name
- type: string
dag_id:
title: Dag Id
type: string
@@ -1289,7 +1275,6 @@
- state
- conf
- dag_versions
- - dag_display_name
title: DAGRunResponse
type: object
DAGRunsBatchBody:
@@ -1361,9 +1346,6 @@
content:
nullable: true
type: string
- dag_display_name:
- title: Dag Display Name
- type: string
dag_id:
title: Dag Id
type: string
@@ -1372,7 +1354,6 @@
type: integer
required:
- dag_id
- - dag_display_name
title: DAGSourceResponse
type: object
DAGTagCollectionResponse:
@@ -1631,9 +1612,6 @@
format: date-time
title: Created At
type: string
- dag_display_name:
- title: Dag Display Name
- type: string
dag_id:
title: Dag Id
type: string
@@ -1649,7 +1627,6 @@
- version_number
- dag_id
- created_at
- - dag_display_name
title: DagVersionResponse
type: object
DagWarningType:
@@ -1710,9 +1687,6 @@
EventLogResponse:
description: Event Log Response.
properties:
- dag_display_name:
- nullable: true
- type: string
dag_id:
nullable: true
type: string
@@ -1754,16 +1728,6 @@
- event
title: EventLogResponse
type: object
- ExternalLogUrlResponse:
- description: Response for the external log URL endpoint.
- properties:
- url:
- title: Url
- type: string
- required:
- - url
- title: ExternalLogUrlResponse
- type: object
ExtraLinkCollectionResponse:
description: Extra Links Response.
properties:
@@ -1916,9 +1880,6 @@
JobResponse:
description: Job serializer for responses.
properties:
- dag_display_name:
- nullable: true
- type: string
dag_id:
nullable: true
type: string
@@ -1957,19 +1918,6 @@
title: JobResponse
type: object
JsonValue: {}
- LastAssetEventResponse:
- description: Last asset event response serializer.
- properties:
- id:
- minimum: 0.0
- nullable: true
- type: integer
- timestamp:
- format: date-time
- nullable: true
- type: string
- title: LastAssetEventResponse
- type: object
PatchTaskInstanceBody:
additionalProperties: false
description: Request body for Clear Task Instances endpoint.
@@ -2015,36 +1963,6 @@
- total_entries
title: PluginCollectionResponse
type: object
- PluginImportErrorCollectionResponse:
- description: Plugin Import Error Collection serializer.
- properties:
- import_errors:
- items:
- $ref: '#/components/schemas/PluginImportErrorResponse'
- title: Import Errors
- type: array
- total_entries:
- title: Total Entries
- type: integer
- required:
- - import_errors
- - total_entries
- title: PluginImportErrorCollectionResponse
- type: object
- PluginImportErrorResponse:
- description: Plugin Import Error serializer for responses.
- properties:
- error:
- title: Error
- type: string
- source:
- title: Source
- type: string
- required:
- - source
- - error
- title: PluginImportErrorResponse
- type: object
PluginResponse:
description: Plugin serializer.
properties:
@@ -2281,9 +2199,6 @@
format: date-time
title: Created At
type: string
- dag_display_name:
- title: Dag Display Name
- type: string
dag_id:
title: Dag Id
type: string
@@ -2291,7 +2206,6 @@
- dag_id
- asset_id
- created_at
- - dag_display_name
title: QueuedEventResponse
type: object
ReprocessBehavior:
@@ -2409,9 +2323,6 @@
TaskInstanceHistoryResponse:
description: TaskInstanceHistory serializer for responses.
properties:
- dag_display_name:
- title: Dag Display Name
- type: string
dag_id:
title: Dag Id
type: string
@@ -2496,7 +2407,6 @@
- try_number
- max_tries
- task_display_name
- - dag_display_name
- pool
- pool_slots
- executor_config
@@ -2505,9 +2415,6 @@
TaskInstanceResponse:
description: TaskInstance serializer for responses.
properties:
- dag_display_name:
- title: Dag Display Name
- type: string
dag_id:
title: Dag Id
type: string
@@ -2621,7 +2528,6 @@
- try_number
- max_tries
- task_display_name
- - dag_display_name
- pool
- pool_slots
- executor_config
@@ -3107,9 +3013,6 @@
XComResponse:
description: Serializer for a xcom item.
properties:
- dag_display_name:
- title: Dag Display Name
- type: string
dag_id:
title: Dag Id
type: string
@@ -3140,15 +3043,11 @@
- task_id
- dag_id
- run_id
- - dag_display_name
title: XComResponse
type: object
XComResponseNative:
description: XCom response serializer with native return type.
properties:
- dag_display_name:
- title: Dag Display Name
- type: string
dag_id:
title: Dag Id
type: string
@@ -3181,16 +3080,12 @@
- task_id
- dag_id
- run_id
- - dag_display_name
- value
title: XComResponseNative
type: object
XComResponseString:
description: XCom response serializer with string return type.
properties:
- dag_display_name:
- title: Dag Display Name
- type: string
dag_id:
title: Dag Id
type: string
@@ -3224,7 +3119,6 @@
- task_id
- dag_id
- run_id
- - dag_display_name
title: XComResponseString
type: object
XComUpdateBody:
@@ -3286,17 +3180,13 @@
minimum: 0
title: Offset
type: integer
- - description: "SQL LIKE expression \u2014 use `%` / `_` wildcards (e.g. `%customer_%`).\
- \ Regular expressions are **not** supported."
- in: query
+ - in: query
name: name_pattern
required: false
schema:
nullable: true
type: string
- - description: "SQL LIKE expression \u2014 use `%` / `_` wildcards (e.g. `%customer_%`).\
- \ Regular expressions are **not** supported."
- in: query
+ - in: query
name: uri_pattern
required: false
schema:
@@ -3381,9 +3271,7 @@
minimum: 0
title: Offset
type: integer
- - description: "SQL LIKE expression \u2014 use `%` / `_` wildcards (e.g. `%customer_%`).\
- \ Regular expressions are **not** supported."
- in: query
+ - in: query
name: name_pattern
required: false
schema:
@@ -4453,9 +4341,7 @@
default: id
title: Order By
type: string
- - description: "SQL LIKE expression \u2014 use `%` / `_` wildcards (e.g. `%customer_%`).\
- \ Regular expressions are **not** supported."
- in: query
+ - in: query
name: connection_id_pattern
required: false
schema:
@@ -5018,9 +4904,7 @@
default: name
title: Order By
type: string
- - description: "SQL LIKE expression \u2014 use `%` / `_` wildcards (e.g. `%customer_%`).\
- \ Regular expressions are **not** supported."
- in: query
+ - in: query
name: tag_name_pattern
required: false
schema:
@@ -5172,17 +5056,13 @@
type: string
title: Owners
type: array
- - description: "SQL LIKE expression \u2014 use `%` / `_` wildcards (e.g. `%customer_%`).\
- \ Regular expressions are **not** supported."
- in: query
+ - in: query
name: dag_id_pattern
required: false
schema:
nullable: true
type: string
- - description: "SQL LIKE expression \u2014 use `%` / `_` wildcards (e.g. `%customer_%`).\
- \ Regular expressions are **not** supported."
- in: query
+ - in: query
name: dag_display_name_pattern
required: false
schema:
@@ -5333,9 +5213,7 @@
type: string
title: Owners
type: array
- - description: "SQL LIKE expression \u2014 use `%` / `_` wildcards (e.g. `%customer_%`).\
- \ Regular expressions are **not** supported."
- in: query
+ - in: query
name: dag_id_pattern
required: false
schema:
@@ -6483,9 +6361,7 @@
schema:
nullable: true
type: number
- - description: "SQL LIKE expression \u2014 use `%` / `_` wildcards (e.g. `%customer_%`).\
- \ Regular expressions are **not** supported."
- in: query
+ - in: query
name: task_display_name_pattern
required: false
schema:
@@ -6652,72 +6528,6 @@
tags:
- Task Instance
/api/v2/dags/{dag_id}/dagRuns/{dag_run_id}/taskInstances/{task_id}:
- delete:
- description: Delete a task instance.
- operationId: delete_task_instance
- parameters:
- - in: path
- name: dag_id
- required: true
- schema:
- title: Dag Id
- type: string
- - in: path
- name: dag_run_id
- required: true
- schema:
- title: Dag Run Id
- type: string
- - in: path
- name: task_id
- required: true
- schema:
- title: Task Id
- type: string
- - in: query
- name: map_index
- required: false
- schema:
- default: -1
- title: Map Index
- type: integer
- responses:
- '200':
- content:
- application/json:
- schema:
- title: Response Delete Task Instance
- type: 'null'
- description: Successful Response
- '401':
- content:
- application/json:
- schema:
- $ref: '#/components/schemas/HTTPExceptionResponse'
- description: Unauthorized
- '403':
- content:
- application/json:
- schema:
- $ref: '#/components/schemas/HTTPExceptionResponse'
- description: Forbidden
- '404':
- content:
- application/json:
- schema:
- $ref: '#/components/schemas/HTTPExceptionResponse'
- description: Not Found
- '422':
- content:
- application/json:
- schema:
- $ref: '#/components/schemas/HTTPValidationError'
- description: Validation Error
- security:
- - OAuth2PasswordBearer: []
- summary: Delete Task Instance
- tags:
- - Task Instance
get:
description: Get task instance.
operationId: get_task_instance
@@ -7017,85 +6827,6 @@
summary: Patch Task Instance Dry Run
tags:
- Task Instance
- /api/v2/dags/{dag_id}/dagRuns/{dag_run_id}/taskInstances/{task_id}/externalLogUrl/{try_number}:
- get:
- description: Get external log URL for a specific task instance.
- operationId: get_external_log_url
- parameters:
- - in: path
- name: dag_id
- required: true
- schema:
- title: Dag Id
- type: string
- - in: path
- name: dag_run_id
- required: true
- schema:
- title: Dag Run Id
- type: string
- - in: path
- name: task_id
- required: true
- schema:
- title: Task Id
- type: string
- - in: path
- name: try_number
- required: true
- schema:
- exclusiveMinimum: 0
- title: Try Number
- type: integer
- - in: query
- name: map_index
- required: false
- schema:
- default: -1
- title: Map Index
- type: integer
- responses:
- '200':
- content:
- application/json:
- schema:
- $ref: '#/components/schemas/ExternalLogUrlResponse'
- description: Successful Response
- '400':
- content:
- application/json:
- schema:
- $ref: '#/components/schemas/HTTPExceptionResponse'
- description: Bad Request
- '401':
- content:
- application/json:
- schema:
- $ref: '#/components/schemas/HTTPExceptionResponse'
- description: Unauthorized
- '403':
- content:
- application/json:
- schema:
- $ref: '#/components/schemas/HTTPExceptionResponse'
- description: Forbidden
- '404':
- content:
- application/json:
- schema:
- $ref: '#/components/schemas/HTTPExceptionResponse'
- description: Not Found
- '422':
- content:
- application/json:
- schema:
- $ref: '#/components/schemas/HTTPValidationError'
- description: Validation Error
- security:
- - OAuth2PasswordBearer: []
- summary: Get External Log Url
- tags:
- - Task Instance
/api/v2/dags/{dag_id}/dagRuns/{dag_run_id}/taskInstances/{task_id}/links:
get:
description: Get extra links for task instance.
@@ -7424,7 +7155,7 @@
default: '*/*'
enum:
- application/json
- - application/x-ndjson
+ - text/plain
- '*/*'
title: Accept
type: string
@@ -7434,11 +7165,9 @@
application/json:
schema:
$ref: '#/components/schemas/TaskInstancesLogResponse'
- application/x-ndjson:
+ text/plain:
schema:
- example: '{"content": "content"}
-
- {"content": "content"}
+ example: 'content
'
type: string
@@ -9273,33 +9002,6 @@
summary: Get Plugins
tags:
- Plugin
- /api/v2/plugins/importErrors:
- get:
- operationId: import_errors
- responses:
- '200':
- content:
- application/json:
- schema:
- $ref: '#/components/schemas/PluginImportErrorCollectionResponse'
- description: Successful Response
- '401':
- content:
- application/json:
- schema:
- $ref: '#/components/schemas/HTTPExceptionResponse'
- description: Unauthorized
- '403':
- content:
- application/json:
- schema:
- $ref: '#/components/schemas/HTTPExceptionResponse'
- description: Forbidden
- security:
- - OAuth2PasswordBearer: []
- summary: Import Errors
- tags:
- - Plugin
/api/v2/pools:
get:
description: Get all pools entries.
@@ -9328,9 +9030,7 @@
default: id
title: Order By
type: string
- - description: "SQL LIKE expression \u2014 use `%` / `_` wildcards (e.g. `%customer_%`).\
- \ Regular expressions are **not** supported."
- in: query
+ - in: query
name: pool_name_pattern
required: false
schema:
@@ -9696,9 +9396,7 @@
default: id
title: Order By
type: string
- - description: "SQL LIKE expression \u2014 use `%` / `_` wildcards (e.g. `%customer_%`).\
- \ Regular expressions are **not** supported."
- in: query
+ - in: query
name: variable_key_pattern
required: false
schema:
diff --git a/test/test_asset_collection_response.py b/test/test_asset_collection_response.py
index bcb675b..267b1eb 100644
--- a/test/test_asset_collection_response.py
+++ b/test/test_asset_collection_response.py
@@ -53,9 +53,6 @@
extra = airflow_client.client.models.extra.extra(),
group = '',
id = 56,
- last_asset_event = airflow_client.client.models.last_asset_event_response.LastAssetEventResponse(
- id = 0.0,
- timestamp = datetime.datetime.strptime('2013-10-20 19:20:30.00', '%Y-%m-%d %H:%M:%S.%f'), ),
name = '',
producing_tasks = [
airflow_client.client.models.task_outlet_asset_reference.TaskOutletAssetReference(
@@ -89,9 +86,6 @@
extra = airflow_client.client.models.extra.extra(),
group = '',
id = 56,
- last_asset_event = airflow_client.client.models.last_asset_event_response.LastAssetEventResponse(
- id = 0.0,
- timestamp = datetime.datetime.strptime('2013-10-20 19:20:30.00', '%Y-%m-%d %H:%M:%S.%f'), ),
name = '',
producing_tasks = [
airflow_client.client.models.task_outlet_asset_reference.TaskOutletAssetReference(
diff --git a/test/test_asset_response.py b/test/test_asset_response.py
index f1cf00c..507a0db 100644
--- a/test/test_asset_response.py
+++ b/test/test_asset_response.py
@@ -51,9 +51,6 @@
extra = airflow_client.client.models.extra.extra(),
group = '',
id = 56,
- last_asset_event = airflow_client.client.models.last_asset_event_response.LastAssetEventResponse(
- id = 0.0,
- timestamp = datetime.datetime.strptime('2013-10-20 19:20:30.00', '%Y-%m-%d %H:%M:%S.%f'), ),
name = '',
producing_tasks = [
airflow_client.client.models.task_outlet_asset_reference.TaskOutletAssetReference(
diff --git a/test/test_backfill_collection_response.py b/test/test_backfill_collection_response.py
index 5fac5b1..e66c7f1 100644
--- a/test/test_backfill_collection_response.py
+++ b/test/test_backfill_collection_response.py
@@ -39,7 +39,6 @@
airflow_client.client.models.backfill_response.BackfillResponse(
completed_at = datetime.datetime.strptime('2013-10-20 19:20:30.00', '%Y-%m-%d %H:%M:%S.%f'),
created_at = datetime.datetime.strptime('2013-10-20 19:20:30.00', '%Y-%m-%d %H:%M:%S.%f'),
- dag_display_name = '',
dag_id = '',
dag_run_conf = airflow_client.client.models.dag_run_conf.Dag Run Conf(),
from_date = datetime.datetime.strptime('2013-10-20 19:20:30.00', '%Y-%m-%d %H:%M:%S.%f'),
@@ -58,7 +57,6 @@
airflow_client.client.models.backfill_response.BackfillResponse(
completed_at = datetime.datetime.strptime('2013-10-20 19:20:30.00', '%Y-%m-%d %H:%M:%S.%f'),
created_at = datetime.datetime.strptime('2013-10-20 19:20:30.00', '%Y-%m-%d %H:%M:%S.%f'),
- dag_display_name = '',
dag_id = '',
dag_run_conf = airflow_client.client.models.dag_run_conf.Dag Run Conf(),
from_date = datetime.datetime.strptime('2013-10-20 19:20:30.00', '%Y-%m-%d %H:%M:%S.%f'),
diff --git a/test/test_backfill_response.py b/test/test_backfill_response.py
index 64b398a..864988e 100644
--- a/test/test_backfill_response.py
+++ b/test/test_backfill_response.py
@@ -37,7 +37,6 @@
return BackfillResponse(
completed_at = datetime.datetime.strptime('2013-10-20 19:20:30.00', '%Y-%m-%d %H:%M:%S.%f'),
created_at = datetime.datetime.strptime('2013-10-20 19:20:30.00', '%Y-%m-%d %H:%M:%S.%f'),
- dag_display_name = '',
dag_id = '',
dag_run_conf = airflow_client.client.models.dag_run_conf.Dag Run Conf(),
from_date = datetime.datetime.strptime('2013-10-20 19:20:30.00', '%Y-%m-%d %H:%M:%S.%f'),
@@ -51,7 +50,6 @@
else:
return BackfillResponse(
created_at = datetime.datetime.strptime('2013-10-20 19:20:30.00', '%Y-%m-%d %H:%M:%S.%f'),
- dag_display_name = '',
dag_id = '',
dag_run_conf = airflow_client.client.models.dag_run_conf.Dag Run Conf(),
from_date = datetime.datetime.strptime('2013-10-20 19:20:30.00', '%Y-%m-%d %H:%M:%S.%f'),
diff --git a/test/test_dag_details_response.py b/test/test_dag_details_response.py
index a552c02..d43e503 100644
--- a/test/test_dag_details_response.py
+++ b/test/test_dag_details_response.py
@@ -43,7 +43,6 @@
dag_display_name = '',
dag_id = '',
dag_run_timeout = '',
- default_args = airflow_client.client.models.extra.extra(),
description = '',
doc_md = '',
end_date = datetime.datetime.strptime('2013-10-20 19:20:30.00', '%Y-%m-%d %H:%M:%S.%f'),
@@ -62,7 +61,6 @@
bundle_url = '',
bundle_version = '',
created_at = datetime.datetime.strptime('2013-10-20 19:20:30.00', '%Y-%m-%d %H:%M:%S.%f'),
- dag_display_name = '',
dag_id = '',
id = '',
version_number = 56, ),
diff --git a/test/test_dag_run_collection_response.py b/test/test_dag_run_collection_response.py
index f6d0fa0..ff78f7c 100644
--- a/test/test_dag_run_collection_response.py
+++ b/test/test_dag_run_collection_response.py
@@ -39,7 +39,6 @@
airflow_client.client.models.dag_run_response.DAGRunResponse(
bundle_version = '',
conf = airflow_client.client.models.conf.Conf(),
- dag_display_name = '',
dag_id = '',
dag_run_id = '',
dag_versions = [
@@ -48,7 +47,6 @@
bundle_url = '',
bundle_version = '',
created_at = datetime.datetime.strptime('2013-10-20 19:20:30.00', '%Y-%m-%d %H:%M:%S.%f'),
- dag_display_name = '',
dag_id = '',
id = '',
version_number = 56, )
@@ -74,7 +72,6 @@
airflow_client.client.models.dag_run_response.DAGRunResponse(
bundle_version = '',
conf = airflow_client.client.models.conf.Conf(),
- dag_display_name = '',
dag_id = '',
dag_run_id = '',
dag_versions = [
@@ -83,7 +80,6 @@
bundle_url = '',
bundle_version = '',
created_at = datetime.datetime.strptime('2013-10-20 19:20:30.00', '%Y-%m-%d %H:%M:%S.%f'),
- dag_display_name = '',
dag_id = '',
id = '',
version_number = 56, )
diff --git a/test/test_dag_run_response.py b/test/test_dag_run_response.py
index 6450ace..38ae045 100644
--- a/test/test_dag_run_response.py
+++ b/test/test_dag_run_response.py
@@ -37,7 +37,6 @@
return DAGRunResponse(
bundle_version = '',
conf = airflow_client.client.models.conf.Conf(),
- dag_display_name = '',
dag_id = '',
dag_run_id = '',
dag_versions = [
@@ -46,7 +45,6 @@
bundle_url = '',
bundle_version = '',
created_at = datetime.datetime.strptime('2013-10-20 19:20:30.00', '%Y-%m-%d %H:%M:%S.%f'),
- dag_display_name = '',
dag_id = '',
id = '',
version_number = 56, )
@@ -67,7 +65,6 @@
else:
return DAGRunResponse(
conf = airflow_client.client.models.conf.Conf(),
- dag_display_name = '',
dag_id = '',
dag_run_id = '',
dag_versions = [
@@ -76,7 +73,6 @@
bundle_url = '',
bundle_version = '',
created_at = datetime.datetime.strptime('2013-10-20 19:20:30.00', '%Y-%m-%d %H:%M:%S.%f'),
- dag_display_name = '',
dag_id = '',
id = '',
version_number = 56, )
diff --git a/test/test_dag_source_response.py b/test/test_dag_source_response.py
index ca636a6..a95b9dc 100644
--- a/test/test_dag_source_response.py
+++ b/test/test_dag_source_response.py
@@ -36,13 +36,11 @@
if include_optional:
return DAGSourceResponse(
content = '',
- dag_display_name = '',
dag_id = '',
version_number = 56
)
else:
return DAGSourceResponse(
- dag_display_name = '',
dag_id = '',
)
"""
diff --git a/test/test_dag_version_collection_response.py b/test/test_dag_version_collection_response.py
index 2d311df..cf35afb 100644
--- a/test/test_dag_version_collection_response.py
+++ b/test/test_dag_version_collection_response.py
@@ -41,7 +41,6 @@
bundle_url = '',
bundle_version = '',
created_at = datetime.datetime.strptime('2013-10-20 19:20:30.00', '%Y-%m-%d %H:%M:%S.%f'),
- dag_display_name = '',
dag_id = '',
id = '',
version_number = 56, )
@@ -56,7 +55,6 @@
bundle_url = '',
bundle_version = '',
created_at = datetime.datetime.strptime('2013-10-20 19:20:30.00', '%Y-%m-%d %H:%M:%S.%f'),
- dag_display_name = '',
dag_id = '',
id = '',
version_number = 56, )
diff --git a/test/test_dag_version_response.py b/test/test_dag_version_response.py
index 04060db..ef4adba 100644
--- a/test/test_dag_version_response.py
+++ b/test/test_dag_version_response.py
@@ -39,7 +39,6 @@
bundle_url = '',
bundle_version = '',
created_at = datetime.datetime.strptime('2013-10-20 19:20:30.00', '%Y-%m-%d %H:%M:%S.%f'),
- dag_display_name = '',
dag_id = '',
id = '',
version_number = 56
@@ -47,7 +46,6 @@
else:
return DagVersionResponse(
created_at = datetime.datetime.strptime('2013-10-20 19:20:30.00', '%Y-%m-%d %H:%M:%S.%f'),
- dag_display_name = '',
dag_id = '',
id = '',
version_number = 56,
diff --git a/test/test_event_log_collection_response.py b/test/test_event_log_collection_response.py
index 2c8cc35..2fe92de 100644
--- a/test/test_event_log_collection_response.py
+++ b/test/test_event_log_collection_response.py
@@ -37,7 +37,6 @@
return EventLogCollectionResponse(
event_logs = [
airflow_client.client.models.event_log_response.EventLogResponse(
- dag_display_name = '',
dag_id = '',
event = '',
event_log_id = 56,
@@ -56,7 +55,6 @@
return EventLogCollectionResponse(
event_logs = [
airflow_client.client.models.event_log_response.EventLogResponse(
- dag_display_name = '',
dag_id = '',
event = '',
event_log_id = 56,
diff --git a/test/test_event_log_response.py b/test/test_event_log_response.py
index 47e0e6f..8aab2ec 100644
--- a/test/test_event_log_response.py
+++ b/test/test_event_log_response.py
@@ -35,7 +35,6 @@
model = EventLogResponse()
if include_optional:
return EventLogResponse(
- dag_display_name = '',
dag_id = '',
event = '',
event_log_id = 56,
diff --git a/test/test_external_log_url_response.py b/test/test_external_log_url_response.py
deleted file mode 100644
index 76fd7cb..0000000
--- a/test/test_external_log_url_response.py
+++ /dev/null
@@ -1,52 +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.external_log_url_response import ExternalLogUrlResponse
-
-class TestExternalLogUrlResponse(unittest.TestCase):
- """ExternalLogUrlResponse unit test stubs"""
-
- def setUp(self):
- pass
-
- def tearDown(self):
- pass
-
- def make_instance(self, include_optional) -> ExternalLogUrlResponse:
- """Test ExternalLogUrlResponse
- 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 `ExternalLogUrlResponse`
- """
- model = ExternalLogUrlResponse()
- if include_optional:
- return ExternalLogUrlResponse(
- url = ''
- )
- else:
- return ExternalLogUrlResponse(
- url = '',
- )
- """
-
- def testExternalLogUrlResponse(self):
- """Test ExternalLogUrlResponse"""
- # 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_job_collection_response.py b/test/test_job_collection_response.py
index 24c2038..062ff99 100644
--- a/test/test_job_collection_response.py
+++ b/test/test_job_collection_response.py
@@ -37,7 +37,6 @@
return JobCollectionResponse(
jobs = [
airflow_client.client.models.job_response.JobResponse(
- dag_display_name = '',
dag_id = '',
end_date = datetime.datetime.strptime('2013-10-20 19:20:30.00', '%Y-%m-%d %H:%M:%S.%f'),
executor_class = '',
@@ -55,7 +54,6 @@
return JobCollectionResponse(
jobs = [
airflow_client.client.models.job_response.JobResponse(
- dag_display_name = '',
dag_id = '',
end_date = datetime.datetime.strptime('2013-10-20 19:20:30.00', '%Y-%m-%d %H:%M:%S.%f'),
executor_class = '',
diff --git a/test/test_job_response.py b/test/test_job_response.py
index 32112bd..e18d024 100644
--- a/test/test_job_response.py
+++ b/test/test_job_response.py
@@ -35,7 +35,6 @@
model = JobResponse()
if include_optional:
return JobResponse(
- dag_display_name = '',
dag_id = '',
end_date = datetime.datetime.strptime('2013-10-20 19:20:30.00', '%Y-%m-%d %H:%M:%S.%f'),
executor_class = '',
diff --git a/test/test_last_asset_event_response.py b/test/test_last_asset_event_response.py
deleted file mode 100644
index eb21138..0000000
--- a/test/test_last_asset_event_response.py
+++ /dev/null
@@ -1,52 +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.last_asset_event_response import LastAssetEventResponse
-
-class TestLastAssetEventResponse(unittest.TestCase):
- """LastAssetEventResponse unit test stubs"""
-
- def setUp(self):
- pass
-
- def tearDown(self):
- pass
-
- def make_instance(self, include_optional) -> LastAssetEventResponse:
- """Test LastAssetEventResponse
- 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 `LastAssetEventResponse`
- """
- model = LastAssetEventResponse()
- if include_optional:
- return LastAssetEventResponse(
- id = 0.0,
- timestamp = datetime.datetime.strptime('2013-10-20 19:20:30.00', '%Y-%m-%d %H:%M:%S.%f')
- )
- else:
- return LastAssetEventResponse(
- )
- """
-
- def testLastAssetEventResponse(self):
- """Test LastAssetEventResponse"""
- # 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_plugin_api.py b/test/test_plugin_api.py
index dbb929c..16e26ff 100644
--- a/test/test_plugin_api.py
+++ b/test/test_plugin_api.py
@@ -33,13 +33,6 @@
"""
pass
- def test_import_errors(self) -> None:
- """Test case for import_errors
-
- Import Errors
- """
- pass
-
if __name__ == '__main__':
unittest.main()
diff --git a/test/test_plugin_import_error_collection_response.py b/test/test_plugin_import_error_collection_response.py
deleted file mode 100644
index 1022103..0000000
--- a/test/test_plugin_import_error_collection_response.py
+++ /dev/null
@@ -1,62 +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.plugin_import_error_collection_response import PluginImportErrorCollectionResponse
-
-class TestPluginImportErrorCollectionResponse(unittest.TestCase):
- """PluginImportErrorCollectionResponse unit test stubs"""
-
- def setUp(self):
- pass
-
- def tearDown(self):
- pass
-
- def make_instance(self, include_optional) -> PluginImportErrorCollectionResponse:
- """Test PluginImportErrorCollectionResponse
- 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 `PluginImportErrorCollectionResponse`
- """
- model = PluginImportErrorCollectionResponse()
- if include_optional:
- return PluginImportErrorCollectionResponse(
- import_errors = [
- airflow_client.client.models.plugin_import_error_response.PluginImportErrorResponse(
- error = '',
- source = '', )
- ],
- total_entries = 56
- )
- else:
- return PluginImportErrorCollectionResponse(
- import_errors = [
- airflow_client.client.models.plugin_import_error_response.PluginImportErrorResponse(
- error = '',
- source = '', )
- ],
- total_entries = 56,
- )
- """
-
- def testPluginImportErrorCollectionResponse(self):
- """Test PluginImportErrorCollectionResponse"""
- # 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_plugin_import_error_response.py b/test/test_plugin_import_error_response.py
deleted file mode 100644
index eab0f75..0000000
--- a/test/test_plugin_import_error_response.py
+++ /dev/null
@@ -1,54 +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.plugin_import_error_response import PluginImportErrorResponse
-
-class TestPluginImportErrorResponse(unittest.TestCase):
- """PluginImportErrorResponse unit test stubs"""
-
- def setUp(self):
- pass
-
- def tearDown(self):
- pass
-
- def make_instance(self, include_optional) -> PluginImportErrorResponse:
- """Test PluginImportErrorResponse
- 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 `PluginImportErrorResponse`
- """
- model = PluginImportErrorResponse()
- if include_optional:
- return PluginImportErrorResponse(
- error = '',
- source = ''
- )
- else:
- return PluginImportErrorResponse(
- error = '',
- source = '',
- )
- """
-
- def testPluginImportErrorResponse(self):
- """Test PluginImportErrorResponse"""
- # 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_queued_event_collection_response.py b/test/test_queued_event_collection_response.py
index 5628635..0eedc40 100644
--- a/test/test_queued_event_collection_response.py
+++ b/test/test_queued_event_collection_response.py
@@ -39,7 +39,6 @@
airflow_client.client.models.queued_event_response.QueuedEventResponse(
asset_id = 56,
created_at = datetime.datetime.strptime('2013-10-20 19:20:30.00', '%Y-%m-%d %H:%M:%S.%f'),
- dag_display_name = '',
dag_id = '', )
],
total_entries = 56
@@ -50,7 +49,6 @@
airflow_client.client.models.queued_event_response.QueuedEventResponse(
asset_id = 56,
created_at = datetime.datetime.strptime('2013-10-20 19:20:30.00', '%Y-%m-%d %H:%M:%S.%f'),
- dag_display_name = '',
dag_id = '', )
],
total_entries = 56,
diff --git a/test/test_queued_event_response.py b/test/test_queued_event_response.py
index a2bf766..9646d64 100644
--- a/test/test_queued_event_response.py
+++ b/test/test_queued_event_response.py
@@ -37,14 +37,12 @@
return QueuedEventResponse(
asset_id = 56,
created_at = datetime.datetime.strptime('2013-10-20 19:20:30.00', '%Y-%m-%d %H:%M:%S.%f'),
- dag_display_name = '',
dag_id = ''
)
else:
return QueuedEventResponse(
asset_id = 56,
created_at = datetime.datetime.strptime('2013-10-20 19:20:30.00', '%Y-%m-%d %H:%M:%S.%f'),
- dag_display_name = '',
dag_id = '',
)
"""
diff --git a/test/test_response_clear_dag_run.py b/test/test_response_clear_dag_run.py
index b7fa927..6713274 100644
--- a/test/test_response_clear_dag_run.py
+++ b/test/test_response_clear_dag_run.py
@@ -37,7 +37,6 @@
return ResponseClearDagRun(
task_instances = [
airflow_client.client.models.task_instance_response.TaskInstanceResponse(
- dag_display_name = '',
dag_id = '',
dag_run_id = '',
dag_version = airflow_client.client.models.dag_version_response.DagVersionResponse(
@@ -45,7 +44,6 @@
bundle_url = '',
bundle_version = '',
created_at = datetime.datetime.strptime('2013-10-20 19:20:30.00', '%Y-%m-%d %H:%M:%S.%f'),
- dag_display_name = '',
dag_id = '',
id = '',
version_number = 56, ),
@@ -81,7 +79,6 @@
kwargs = '',
triggerer_id = 56, ),
triggerer_job = airflow_client.client.models.job_response.JobResponse(
- dag_display_name = '',
dag_id = '',
end_date = datetime.datetime.strptime('2013-10-20 19:20:30.00', '%Y-%m-%d %H:%M:%S.%f'),
executor_class = '',
@@ -97,7 +94,6 @@
total_entries = 56,
bundle_version = '',
conf = airflow_client.client.models.conf.Conf(),
- dag_display_name = '',
dag_id = '',
dag_run_id = '',
dag_versions = [
@@ -106,7 +102,6 @@
bundle_url = '',
bundle_version = '',
created_at = datetime.datetime.strptime('2013-10-20 19:20:30.00', '%Y-%m-%d %H:%M:%S.%f'),
- dag_display_name = '',
dag_id = '',
id = '',
version_number = 56, )
@@ -128,7 +123,6 @@
return ResponseClearDagRun(
task_instances = [
airflow_client.client.models.task_instance_response.TaskInstanceResponse(
- dag_display_name = '',
dag_id = '',
dag_run_id = '',
dag_version = airflow_client.client.models.dag_version_response.DagVersionResponse(
@@ -136,7 +130,6 @@
bundle_url = '',
bundle_version = '',
created_at = datetime.datetime.strptime('2013-10-20 19:20:30.00', '%Y-%m-%d %H:%M:%S.%f'),
- dag_display_name = '',
dag_id = '',
id = '',
version_number = 56, ),
@@ -172,7 +165,6 @@
kwargs = '',
triggerer_id = 56, ),
triggerer_job = airflow_client.client.models.job_response.JobResponse(
- dag_display_name = '',
dag_id = '',
end_date = datetime.datetime.strptime('2013-10-20 19:20:30.00', '%Y-%m-%d %H:%M:%S.%f'),
executor_class = '',
@@ -187,7 +179,6 @@
],
total_entries = 56,
conf = airflow_client.client.models.conf.Conf(),
- dag_display_name = '',
dag_id = '',
dag_run_id = '',
dag_versions = [
@@ -196,7 +187,6 @@
bundle_url = '',
bundle_version = '',
created_at = datetime.datetime.strptime('2013-10-20 19:20:30.00', '%Y-%m-%d %H:%M:%S.%f'),
- dag_display_name = '',
dag_id = '',
id = '',
version_number = 56, )
diff --git a/test/test_response_get_xcom_entry.py b/test/test_response_get_xcom_entry.py
index fc0729b..2683c87 100644
--- a/test/test_response_get_xcom_entry.py
+++ b/test/test_response_get_xcom_entry.py
@@ -35,7 +35,6 @@
model = ResponseGetXcomEntry()
if include_optional:
return ResponseGetXcomEntry(
- dag_display_name = '',
dag_id = '',
key = '',
logical_date = datetime.datetime.strptime('2013-10-20 19:20:30.00', '%Y-%m-%d %H:%M:%S.%f'),
@@ -47,7 +46,6 @@
)
else:
return ResponseGetXcomEntry(
- dag_display_name = '',
dag_id = '',
key = '',
map_index = 56,
diff --git a/test/test_task_instance_api.py b/test/test_task_instance_api.py
index f82c3c0..7b8a9b8 100644
--- a/test/test_task_instance_api.py
+++ b/test/test_task_instance_api.py
@@ -26,20 +26,6 @@
def tearDown(self) -> None:
pass
- def test_delete_task_instance(self) -> None:
- """Test case for delete_task_instance
-
- Delete Task Instance
- """
- pass
-
- def test_get_external_log_url(self) -> None:
- """Test case for get_external_log_url
-
- Get External Log Url
- """
- pass
-
def test_get_extra_links(self) -> None:
"""Test case for get_extra_links
diff --git a/test/test_task_instance_collection_response.py b/test/test_task_instance_collection_response.py
index 077c631..a3b5e59 100644
--- a/test/test_task_instance_collection_response.py
+++ b/test/test_task_instance_collection_response.py
@@ -37,7 +37,6 @@
return TaskInstanceCollectionResponse(
task_instances = [
airflow_client.client.models.task_instance_response.TaskInstanceResponse(
- dag_display_name = '',
dag_id = '',
dag_run_id = '',
dag_version = airflow_client.client.models.dag_version_response.DagVersionResponse(
@@ -45,7 +44,6 @@
bundle_url = '',
bundle_version = '',
created_at = datetime.datetime.strptime('2013-10-20 19:20:30.00', '%Y-%m-%d %H:%M:%S.%f'),
- dag_display_name = '',
dag_id = '',
id = '',
version_number = 56, ),
@@ -81,7 +79,6 @@
kwargs = '',
triggerer_id = 56, ),
triggerer_job = airflow_client.client.models.job_response.JobResponse(
- dag_display_name = '',
dag_id = '',
end_date = datetime.datetime.strptime('2013-10-20 19:20:30.00', '%Y-%m-%d %H:%M:%S.%f'),
executor_class = '',
@@ -100,7 +97,6 @@
return TaskInstanceCollectionResponse(
task_instances = [
airflow_client.client.models.task_instance_response.TaskInstanceResponse(
- dag_display_name = '',
dag_id = '',
dag_run_id = '',
dag_version = airflow_client.client.models.dag_version_response.DagVersionResponse(
@@ -108,7 +104,6 @@
bundle_url = '',
bundle_version = '',
created_at = datetime.datetime.strptime('2013-10-20 19:20:30.00', '%Y-%m-%d %H:%M:%S.%f'),
- dag_display_name = '',
dag_id = '',
id = '',
version_number = 56, ),
@@ -144,7 +139,6 @@
kwargs = '',
triggerer_id = 56, ),
triggerer_job = airflow_client.client.models.job_response.JobResponse(
- dag_display_name = '',
dag_id = '',
end_date = datetime.datetime.strptime('2013-10-20 19:20:30.00', '%Y-%m-%d %H:%M:%S.%f'),
executor_class = '',
diff --git a/test/test_task_instance_history_collection_response.py b/test/test_task_instance_history_collection_response.py
index d95349a..bb90858 100644
--- a/test/test_task_instance_history_collection_response.py
+++ b/test/test_task_instance_history_collection_response.py
@@ -37,7 +37,6 @@
return TaskInstanceHistoryCollectionResponse(
task_instances = [
airflow_client.client.models.task_instance_history_response.TaskInstanceHistoryResponse(
- dag_display_name = '',
dag_id = '',
dag_run_id = '',
dag_version = airflow_client.client.models.dag_version_response.DagVersionResponse(
@@ -45,7 +44,6 @@
bundle_url = '',
bundle_version = '',
created_at = datetime.datetime.strptime('2013-10-20 19:20:30.00', '%Y-%m-%d %H:%M:%S.%f'),
- dag_display_name = '',
dag_id = '',
id = '',
version_number = 56, ),
@@ -77,7 +75,6 @@
return TaskInstanceHistoryCollectionResponse(
task_instances = [
airflow_client.client.models.task_instance_history_response.TaskInstanceHistoryResponse(
- dag_display_name = '',
dag_id = '',
dag_run_id = '',
dag_version = airflow_client.client.models.dag_version_response.DagVersionResponse(
@@ -85,7 +82,6 @@
bundle_url = '',
bundle_version = '',
created_at = datetime.datetime.strptime('2013-10-20 19:20:30.00', '%Y-%m-%d %H:%M:%S.%f'),
- dag_display_name = '',
dag_id = '',
id = '',
version_number = 56, ),
diff --git a/test/test_task_instance_history_response.py b/test/test_task_instance_history_response.py
index f182c5f..2d42523 100644
--- a/test/test_task_instance_history_response.py
+++ b/test/test_task_instance_history_response.py
@@ -35,7 +35,6 @@
model = TaskInstanceHistoryResponse()
if include_optional:
return TaskInstanceHistoryResponse(
- dag_display_name = '',
dag_id = '',
dag_run_id = '',
dag_version = airflow_client.client.models.dag_version_response.DagVersionResponse(
@@ -43,7 +42,6 @@
bundle_url = '',
bundle_version = '',
created_at = datetime.datetime.strptime('2013-10-20 19:20:30.00', '%Y-%m-%d %H:%M:%S.%f'),
- dag_display_name = '',
dag_id = '',
id = '',
version_number = 56, ),
@@ -71,7 +69,6 @@
)
else:
return TaskInstanceHistoryResponse(
- dag_display_name = '',
dag_id = '',
dag_run_id = '',
executor_config = '',
diff --git a/test/test_task_instance_response.py b/test/test_task_instance_response.py
index 39a619e..dab1085 100644
--- a/test/test_task_instance_response.py
+++ b/test/test_task_instance_response.py
@@ -35,7 +35,6 @@
model = TaskInstanceResponse()
if include_optional:
return TaskInstanceResponse(
- dag_display_name = '',
dag_id = '',
dag_run_id = '',
dag_version = airflow_client.client.models.dag_version_response.DagVersionResponse(
@@ -43,7 +42,6 @@
bundle_url = '',
bundle_version = '',
created_at = datetime.datetime.strptime('2013-10-20 19:20:30.00', '%Y-%m-%d %H:%M:%S.%f'),
- dag_display_name = '',
dag_id = '',
id = '',
version_number = 56, ),
@@ -79,7 +77,6 @@
kwargs = '',
triggerer_id = 56, ),
triggerer_job = airflow_client.client.models.job_response.JobResponse(
- dag_display_name = '',
dag_id = '',
end_date = datetime.datetime.strptime('2013-10-20 19:20:30.00', '%Y-%m-%d %H:%M:%S.%f'),
executor_class = '',
@@ -95,7 +92,6 @@
)
else:
return TaskInstanceResponse(
- dag_display_name = '',
dag_id = '',
dag_run_id = '',
executor_config = '',
diff --git a/test/test_x_com_collection_response.py b/test/test_x_com_collection_response.py
index 3596ede..c61d47a 100644
--- a/test/test_x_com_collection_response.py
+++ b/test/test_x_com_collection_response.py
@@ -38,7 +38,6 @@
total_entries = 56,
xcom_entries = [
airflow_client.client.models.x_com_response.XComResponse(
- dag_display_name = '',
dag_id = '',
key = '',
logical_date = datetime.datetime.strptime('2013-10-20 19:20:30.00', '%Y-%m-%d %H:%M:%S.%f'),
@@ -53,7 +52,6 @@
total_entries = 56,
xcom_entries = [
airflow_client.client.models.x_com_response.XComResponse(
- dag_display_name = '',
dag_id = '',
key = '',
logical_date = datetime.datetime.strptime('2013-10-20 19:20:30.00', '%Y-%m-%d %H:%M:%S.%f'),
diff --git a/test/test_x_com_response.py b/test/test_x_com_response.py
index 4b962e1..af5b24a 100644
--- a/test/test_x_com_response.py
+++ b/test/test_x_com_response.py
@@ -35,7 +35,6 @@
model = XComResponse()
if include_optional:
return XComResponse(
- dag_display_name = '',
dag_id = '',
key = '',
logical_date = datetime.datetime.strptime('2013-10-20 19:20:30.00', '%Y-%m-%d %H:%M:%S.%f'),
@@ -46,7 +45,6 @@
)
else:
return XComResponse(
- dag_display_name = '',
dag_id = '',
key = '',
map_index = 56,
diff --git a/test/test_x_com_response_native.py b/test/test_x_com_response_native.py
index ee33229..3170519 100644
--- a/test/test_x_com_response_native.py
+++ b/test/test_x_com_response_native.py
@@ -35,7 +35,6 @@
model = XComResponseNative()
if include_optional:
return XComResponseNative(
- dag_display_name = '',
dag_id = '',
key = '',
logical_date = datetime.datetime.strptime('2013-10-20 19:20:30.00', '%Y-%m-%d %H:%M:%S.%f'),
@@ -47,7 +46,6 @@
)
else:
return XComResponseNative(
- dag_display_name = '',
dag_id = '',
key = '',
map_index = 56,
diff --git a/test/test_x_com_response_string.py b/test/test_x_com_response_string.py
index ec1b71e..bcb2361 100644
--- a/test/test_x_com_response_string.py
+++ b/test/test_x_com_response_string.py
@@ -35,7 +35,6 @@
model = XComResponseString()
if include_optional:
return XComResponseString(
- dag_display_name = '',
dag_id = '',
key = '',
logical_date = datetime.datetime.strptime('2013-10-20 19:20:30.00', '%Y-%m-%d %H:%M:%S.%f'),
@@ -47,7 +46,6 @@
)
else:
return XComResponseString(
- dag_display_name = '',
dag_id = '',
key = '',
map_index = 56,
diff --git a/version.txt b/version.txt
index 4a36342..56fea8a 100644
--- a/version.txt
+++ b/version.txt
@@ -1 +1 @@
-3.0.0
+3.0.0
\ No newline at end of file
