From f335398229e9f19e70af6b997bbf3bb9e781fd5c Mon Sep 17 00:00:00 2001 From: Ephraim Anierobi Date: Tue, 18 Nov 2025 17:05:17 +0100 Subject: [PATCH] Update Python Client to 3.1.3rc1 --- CHANGELOG.md | 21 ++ airflow_client/client/__init__.py | 3 +- airflow_client/client/api/__init__.py | 1 - airflow_client/client/api/asset_api.py | 36 +- airflow_client/client/api/backfill_api.py | 12 +- airflow_client/client/api/connection_api.py | 12 +- airflow_client/client/api/dag_api.py | 24 +- airflow_client/client/api/dag_report_api.py | 313 ------------------ airflow_client/client/api/dag_run_api.py | 12 +- airflow_client/client/api/dag_version_api.py | 12 +- airflow_client/client/api/dag_warning_api.py | 12 +- airflow_client/client/api/event_log_api.py | 12 +- airflow_client/client/api/import_error_api.py | 12 +- airflow_client/client/api/job_api.py | 12 +- airflow_client/client/api/login_api.py | 20 -- airflow_client/client/api/pool_api.py | 12 +- .../client/api/task_instance_api.py | 36 +- airflow_client/client/api/variable_api.py | 12 +- airflow_client/client/api_client.py | 2 +- airflow_client/client/configuration.py | 2 +- .../client/models/dag_details_response.py | 4 +- .../client/models/event_log_response.py | 4 +- docs/AssetApi.md | 12 +- docs/AssetEventResponse.md | 2 +- docs/AssetResponse.md | 2 +- docs/BackfillApi.md | 4 +- docs/ConnectionApi.md | 4 +- docs/DAGApi.md | 8 +- docs/DAGDetailsResponse.md | 1 + docs/DAGRunApi.md | 4 +- docs/DagReportApi.md | 93 ------ docs/DagVersionApi.md | 4 +- docs/DagWarningApi.md | 4 +- docs/EventLogApi.md | 4 +- docs/EventLogResponse.md | 1 + docs/ImportErrorApi.md | 4 +- docs/JobApi.md | 4 +- docs/LoginApi.md | 11 +- docs/PoolApi.md | 4 +- docs/TaskInstanceApi.md | 12 +- docs/VariableApi.md | 4 +- pyproject.toml | 4 +- spec/v2.yaml | 225 ++++++++----- test/test_asset_collection_response.py | 8 +- test/test_asset_event_collection_response.py | 8 +- test/test_asset_event_response.py | 4 +- test/test_asset_response.py | 4 +- test/test_dag_details_response.py | 7 +- test/test_dag_report_api.py | 38 --- test/test_dag_run_collection_response.py | 4 +- test/test_dag_run_response.py | 2 +- test/test_event_log_collection_response.py | 2 + test/test_event_log_response.py | 1 + test/test_response_clear_dag_run.py | 2 +- test/test_task_collection_response.py | 8 +- test/test_task_response.py | 4 +- test/test_trigger_dag_run_post_body.py | 2 +- version.txt | 2 +- 58 files changed, 365 insertions(+), 728 deletions(-) delete mode 100644 airflow_client/client/api/dag_report_api.py delete mode 100644 docs/DagReportApi.md delete mode 100644 test/test_dag_report_api.py diff --git a/CHANGELOG.md b/CHANGELOG.md index 7be084d3..e0d7a18a 100644 --- a/CHANGELOG.md +++ b/CHANGELOG.md @@ -17,6 +17,27 @@ under the License. --> +# v3.1.3 + +## New Features: + +- Add query limit protection to prevent excessive database queries in DAG runs list endpoints ([#57450](https://github.com/apache/airflow/pull/57450)) +- Change `extra` field type to `dict[str, JsonValue]` for Asset, AssetAlias, and AssetEvent models ([#57352](https://github.com/apache/airflow/pull/57352)) +- Add `task_display_name` alias field to EventLogResponse for better task identification ([#55160](https://github.com/apache/airflow/pull/55160)) +- Add `is_favorite` field to DAGs list API to support user-specific DAG favorites ([#56341](https://github.com/apache/airflow/pull/56341)) + +## Improvements: + +- Enhance API documentation for sorting functionality ([#56617](https://github.com/apache/airflow/pull/56617)) +- Improve API documentation for the `order_by` query parameter ([#55988](https://github.com/apache/airflow/pull/55988)) +- Remove deprecated `dagReports` API endpoint ([#56609](https://github.com/apache/airflow/pull/56609)) + +## Bug Fixes: + +- Fix logout functionality in airflow-core to properly handle session termination ([#57990](https://github.com/apache/airflow/pull/57990)) +- Fix API endpoint for clearing task instances to properly support mapped task instances with specific map indexes ([#56346](https://github.com/apache/airflow/pull/56346)) + + # v3.1.0 ## New Features: diff --git a/airflow_client/client/__init__.py b/airflow_client/client/__init__.py index e95b35ad..25c3d1a9 100644 --- a/airflow_client/client/__init__.py +++ b/airflow_client/client/__init__.py @@ -14,7 +14,7 @@ """ # noqa: E501 -__version__ = "3.1.0" +__version__ = "3.1.3" # import apis into sdk package from airflow_client.client.api.asset_api import AssetApi @@ -23,7 +23,6 @@ from airflow_client.client.api.connection_api import ConnectionApi from airflow_client.client.api.dag_api import DAGApi from airflow_client.client.api.dag_parsing_api import DAGParsingApi -from airflow_client.client.api.dag_report_api import DagReportApi from airflow_client.client.api.dag_run_api import DagRunApi from airflow_client.client.api.dag_source_api import DagSourceApi from airflow_client.client.api.dag_stats_api import DagStatsApi diff --git a/airflow_client/client/api/__init__.py b/airflow_client/client/api/__init__.py index bfbd4b0a..49c24fdc 100644 --- a/airflow_client/client/api/__init__.py +++ b/airflow_client/client/api/__init__.py @@ -7,7 +7,6 @@ from airflow_client.client.api.connection_api import ConnectionApi from airflow_client.client.api.dag_api import DAGApi from airflow_client.client.api.dag_parsing_api import DAGParsingApi -from airflow_client.client.api.dag_report_api import DagReportApi from airflow_client.client.api.dag_run_api import DagRunApi from airflow_client.client.api.dag_source_api import DagSourceApi from airflow_client.client.api.dag_stats_api import DagStatsApi diff --git a/airflow_client/client/api/asset_api.py b/airflow_client/client/api/asset_api.py index 1a4ab9de..d46fb41d 100644 --- a/airflow_client/client/api/asset_api.py +++ b/airflow_client/client/api/asset_api.py @@ -1780,7 +1780,7 @@ def get_asset_aliases( 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, - order_by: Optional[List[StrictStr]] = None, + order_by: Annotated[Optional[List[StrictStr]], Field(description="Attributes to order by, multi criteria sort is supported. Prefix with `-` for descending order. Supported attributes: `id, name`")] = None, _request_timeout: Union[ None, Annotated[StrictFloat, Field(gt=0)], @@ -1804,7 +1804,7 @@ def get_asset_aliases( :type offset: int :param name_pattern: SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). Regular expressions are **not** supported. :type name_pattern: str - :param order_by: + :param order_by: Attributes to order by, multi criteria sort is supported. Prefix with `-` for descending order. Supported attributes: `id, name` :type order_by: List[str] :param _request_timeout: timeout setting for this request. If one number provided, it will be total request @@ -1863,7 +1863,7 @@ def get_asset_aliases_with_http_info( 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, - order_by: Optional[List[StrictStr]] = None, + order_by: Annotated[Optional[List[StrictStr]], Field(description="Attributes to order by, multi criteria sort is supported. Prefix with `-` for descending order. Supported attributes: `id, name`")] = None, _request_timeout: Union[ None, Annotated[StrictFloat, Field(gt=0)], @@ -1887,7 +1887,7 @@ def get_asset_aliases_with_http_info( :type offset: int :param name_pattern: SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). Regular expressions are **not** supported. :type name_pattern: str - :param order_by: + :param order_by: Attributes to order by, multi criteria sort is supported. Prefix with `-` for descending order. Supported attributes: `id, name` :type order_by: List[str] :param _request_timeout: timeout setting for this request. If one number provided, it will be total request @@ -1946,7 +1946,7 @@ def get_asset_aliases_without_preload_content( 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, - order_by: Optional[List[StrictStr]] = None, + order_by: Annotated[Optional[List[StrictStr]], Field(description="Attributes to order by, multi criteria sort is supported. Prefix with `-` for descending order. Supported attributes: `id, name`")] = None, _request_timeout: Union[ None, Annotated[StrictFloat, Field(gt=0)], @@ -1970,7 +1970,7 @@ def get_asset_aliases_without_preload_content( :type offset: int :param name_pattern: SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). Regular expressions are **not** supported. :type name_pattern: str - :param order_by: + :param order_by: Attributes to order by, multi criteria sort is supported. Prefix with `-` for descending order. Supported attributes: `id, name` :type order_by: List[str] :param _request_timeout: timeout setting for this request. If one number provided, it will be total request @@ -2107,7 +2107,7 @@ def get_asset_events( self, limit: Optional[Annotated[int, Field(strict=True, ge=0)]] = None, offset: Optional[Annotated[int, Field(strict=True, ge=0)]] = None, - order_by: Optional[List[StrictStr]] = None, + order_by: Annotated[Optional[List[StrictStr]], Field(description="Attributes to order by, multi criteria sort is supported. Prefix with `-` for descending order. Supported attributes: `source_task_id, source_dag_id, source_run_id, source_map_index, timestamp`")] = None, asset_id: Optional[StrictInt] = None, source_dag_id: Optional[StrictStr] = None, source_task_id: Optional[StrictStr] = None, @@ -2138,7 +2138,7 @@ def get_asset_events( :type limit: int :param offset: :type offset: int - :param order_by: + :param order_by: Attributes to order by, multi criteria sort is supported. Prefix with `-` for descending order. Supported attributes: `source_task_id, source_dag_id, source_run_id, source_map_index, timestamp` :type order_by: List[str] :param asset_id: :type asset_id: int @@ -2222,7 +2222,7 @@ def get_asset_events_with_http_info( self, limit: Optional[Annotated[int, Field(strict=True, ge=0)]] = None, offset: Optional[Annotated[int, Field(strict=True, ge=0)]] = None, - order_by: Optional[List[StrictStr]] = None, + order_by: Annotated[Optional[List[StrictStr]], Field(description="Attributes to order by, multi criteria sort is supported. Prefix with `-` for descending order. Supported attributes: `source_task_id, source_dag_id, source_run_id, source_map_index, timestamp`")] = None, asset_id: Optional[StrictInt] = None, source_dag_id: Optional[StrictStr] = None, source_task_id: Optional[StrictStr] = None, @@ -2253,7 +2253,7 @@ def get_asset_events_with_http_info( :type limit: int :param offset: :type offset: int - :param order_by: + :param order_by: Attributes to order by, multi criteria sort is supported. Prefix with `-` for descending order. Supported attributes: `source_task_id, source_dag_id, source_run_id, source_map_index, timestamp` :type order_by: List[str] :param asset_id: :type asset_id: int @@ -2337,7 +2337,7 @@ def get_asset_events_without_preload_content( self, limit: Optional[Annotated[int, Field(strict=True, ge=0)]] = None, offset: Optional[Annotated[int, Field(strict=True, ge=0)]] = None, - order_by: Optional[List[StrictStr]] = None, + order_by: Annotated[Optional[List[StrictStr]], Field(description="Attributes to order by, multi criteria sort is supported. Prefix with `-` for descending order. Supported attributes: `source_task_id, source_dag_id, source_run_id, source_map_index, timestamp`")] = None, asset_id: Optional[StrictInt] = None, source_dag_id: Optional[StrictStr] = None, source_task_id: Optional[StrictStr] = None, @@ -2368,7 +2368,7 @@ def get_asset_events_without_preload_content( :type limit: int :param offset: :type offset: int - :param order_by: + :param order_by: Attributes to order by, multi criteria sort is supported. Prefix with `-` for descending order. Supported attributes: `source_task_id, source_dag_id, source_run_id, source_map_index, timestamp` :type order_by: List[str] :param asset_id: :type asset_id: int @@ -2902,7 +2902,7 @@ def get_assets( uri_pattern: Annotated[Optional[StrictStr], Field(description="SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). Regular expressions are **not** supported.")] = None, dag_ids: Optional[List[StrictStr]] = None, only_active: Optional[StrictBool] = None, - order_by: Optional[List[StrictStr]] = None, + order_by: Annotated[Optional[List[StrictStr]], Field(description="Attributes to order by, multi criteria sort is supported. Prefix with `-` for descending order. Supported attributes: `id, name, uri, created_at, updated_at`")] = None, _request_timeout: Union[ None, Annotated[StrictFloat, Field(gt=0)], @@ -2932,7 +2932,7 @@ def get_assets( :type dag_ids: List[str] :param only_active: :type only_active: bool - :param order_by: + :param order_by: Attributes to order by, multi criteria sort is supported. Prefix with `-` for descending order. Supported attributes: `id, name, uri, created_at, updated_at` :type order_by: List[str] :param _request_timeout: timeout setting for this request. If one number provided, it will be total request @@ -2997,7 +2997,7 @@ def get_assets_with_http_info( uri_pattern: Annotated[Optional[StrictStr], Field(description="SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). Regular expressions are **not** supported.")] = None, dag_ids: Optional[List[StrictStr]] = None, only_active: Optional[StrictBool] = None, - order_by: Optional[List[StrictStr]] = None, + order_by: Annotated[Optional[List[StrictStr]], Field(description="Attributes to order by, multi criteria sort is supported. Prefix with `-` for descending order. Supported attributes: `id, name, uri, created_at, updated_at`")] = None, _request_timeout: Union[ None, Annotated[StrictFloat, Field(gt=0)], @@ -3027,7 +3027,7 @@ def get_assets_with_http_info( :type dag_ids: List[str] :param only_active: :type only_active: bool - :param order_by: + :param order_by: Attributes to order by, multi criteria sort is supported. Prefix with `-` for descending order. Supported attributes: `id, name, uri, created_at, updated_at` :type order_by: List[str] :param _request_timeout: timeout setting for this request. If one number provided, it will be total request @@ -3092,7 +3092,7 @@ def get_assets_without_preload_content( uri_pattern: Annotated[Optional[StrictStr], Field(description="SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). Regular expressions are **not** supported.")] = None, dag_ids: Optional[List[StrictStr]] = None, only_active: Optional[StrictBool] = None, - order_by: Optional[List[StrictStr]] = None, + order_by: Annotated[Optional[List[StrictStr]], Field(description="Attributes to order by, multi criteria sort is supported. Prefix with `-` for descending order. Supported attributes: `id, name, uri, created_at, updated_at`")] = None, _request_timeout: Union[ None, Annotated[StrictFloat, Field(gt=0)], @@ -3122,7 +3122,7 @@ def get_assets_without_preload_content( :type dag_ids: List[str] :param only_active: :type only_active: bool - :param order_by: + :param order_by: Attributes to order by, multi criteria sort is supported. Prefix with `-` for descending order. Supported attributes: `id, name, uri, created_at, updated_at` :type order_by: List[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/backfill_api.py b/airflow_client/client/api/backfill_api.py index 1e453cd4..d537265d 100644 --- a/airflow_client/client/api/backfill_api.py +++ b/airflow_client/client/api/backfill_api.py @@ -1167,7 +1167,7 @@ def list_backfills( dag_id: StrictStr, limit: Optional[Annotated[int, Field(strict=True, ge=0)]] = None, offset: Optional[Annotated[int, Field(strict=True, ge=0)]] = None, - order_by: Optional[List[StrictStr]] = None, + order_by: Annotated[Optional[List[StrictStr]], Field(description="Attributes to order by, multi criteria sort is supported. Prefix with `-` for descending order. Supported attributes: `id`")] = None, _request_timeout: Union[ None, Annotated[StrictFloat, Field(gt=0)], @@ -1190,7 +1190,7 @@ def list_backfills( :type limit: int :param offset: :type offset: int - :param order_by: + :param order_by: Attributes to order by, multi criteria sort is supported. Prefix with `-` for descending order. Supported attributes: `id` :type order_by: List[str] :param _request_timeout: timeout setting for this request. If one number provided, it will be total request @@ -1248,7 +1248,7 @@ def list_backfills_with_http_info( dag_id: StrictStr, limit: Optional[Annotated[int, Field(strict=True, ge=0)]] = None, offset: Optional[Annotated[int, Field(strict=True, ge=0)]] = None, - order_by: Optional[List[StrictStr]] = None, + order_by: Annotated[Optional[List[StrictStr]], Field(description="Attributes to order by, multi criteria sort is supported. Prefix with `-` for descending order. Supported attributes: `id`")] = None, _request_timeout: Union[ None, Annotated[StrictFloat, Field(gt=0)], @@ -1271,7 +1271,7 @@ def list_backfills_with_http_info( :type limit: int :param offset: :type offset: int - :param order_by: + :param order_by: Attributes to order by, multi criteria sort is supported. Prefix with `-` for descending order. Supported attributes: `id` :type order_by: List[str] :param _request_timeout: timeout setting for this request. If one number provided, it will be total request @@ -1329,7 +1329,7 @@ def list_backfills_without_preload_content( dag_id: StrictStr, limit: Optional[Annotated[int, Field(strict=True, ge=0)]] = None, offset: Optional[Annotated[int, Field(strict=True, ge=0)]] = None, - order_by: Optional[List[StrictStr]] = None, + order_by: Annotated[Optional[List[StrictStr]], Field(description="Attributes to order by, multi criteria sort is supported. Prefix with `-` for descending order. Supported attributes: `id`")] = None, _request_timeout: Union[ None, Annotated[StrictFloat, Field(gt=0)], @@ -1352,7 +1352,7 @@ def list_backfills_without_preload_content( :type limit: int :param offset: :type offset: int - :param order_by: + :param order_by: Attributes to order by, multi criteria sort is supported. Prefix with `-` for descending order. Supported attributes: `id` :type order_by: List[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/connection_api.py b/airflow_client/client/api/connection_api.py index 3bec8625..285ef928 100644 --- a/airflow_client/client/api/connection_api.py +++ b/airflow_client/client/api/connection_api.py @@ -1134,7 +1134,7 @@ def get_connections( self, limit: Optional[Annotated[int, Field(strict=True, ge=0)]] = None, offset: Optional[Annotated[int, Field(strict=True, ge=0)]] = None, - order_by: Optional[List[StrictStr]] = None, + order_by: Annotated[Optional[List[StrictStr]], Field(description="Attributes to order by, multi criteria sort is supported. Prefix with `-` for descending order. Supported attributes: `conn_id, conn_type, description, host, port, id, connection_id`")] = None, connection_id_pattern: Annotated[Optional[StrictStr], Field(description="SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). Regular expressions are **not** supported.")] = None, _request_timeout: Union[ None, @@ -1157,7 +1157,7 @@ def get_connections( :type limit: int :param offset: :type offset: int - :param order_by: + :param order_by: Attributes to order by, multi criteria sort is supported. Prefix with `-` for descending order. Supported attributes: `conn_id, conn_type, description, host, port, id, connection_id` :type order_by: List[str] :param connection_id_pattern: SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). Regular expressions are **not** supported. :type connection_id_pattern: str @@ -1217,7 +1217,7 @@ def get_connections_with_http_info( self, limit: Optional[Annotated[int, Field(strict=True, ge=0)]] = None, offset: Optional[Annotated[int, Field(strict=True, ge=0)]] = None, - order_by: Optional[List[StrictStr]] = None, + order_by: Annotated[Optional[List[StrictStr]], Field(description="Attributes to order by, multi criteria sort is supported. Prefix with `-` for descending order. Supported attributes: `conn_id, conn_type, description, host, port, id, connection_id`")] = None, connection_id_pattern: Annotated[Optional[StrictStr], Field(description="SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). Regular expressions are **not** supported.")] = None, _request_timeout: Union[ None, @@ -1240,7 +1240,7 @@ def get_connections_with_http_info( :type limit: int :param offset: :type offset: int - :param order_by: + :param order_by: Attributes to order by, multi criteria sort is supported. Prefix with `-` for descending order. Supported attributes: `conn_id, conn_type, description, host, port, id, connection_id` :type order_by: List[str] :param connection_id_pattern: SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). Regular expressions are **not** supported. :type connection_id_pattern: str @@ -1300,7 +1300,7 @@ def get_connections_without_preload_content( self, limit: Optional[Annotated[int, Field(strict=True, ge=0)]] = None, offset: Optional[Annotated[int, Field(strict=True, ge=0)]] = None, - order_by: Optional[List[StrictStr]] = None, + order_by: Annotated[Optional[List[StrictStr]], Field(description="Attributes to order by, multi criteria sort is supported. Prefix with `-` for descending order. Supported attributes: `conn_id, conn_type, description, host, port, id, connection_id`")] = None, connection_id_pattern: Annotated[Optional[StrictStr], Field(description="SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). Regular expressions are **not** supported.")] = None, _request_timeout: Union[ None, @@ -1323,7 +1323,7 @@ def get_connections_without_preload_content( :type limit: int :param offset: :type offset: int - :param order_by: + :param order_by: Attributes to order by, multi criteria sort is supported. Prefix with `-` for descending order. Supported attributes: `conn_id, conn_type, description, host, port, id, connection_id` :type order_by: List[str] :param connection_id_pattern: SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). Regular expressions are **not** supported. :type connection_id_pattern: str diff --git a/airflow_client/client/api/dag_api.py b/airflow_client/client/api/dag_api.py index 6a7bcebc..b3df75a5 100644 --- a/airflow_client/client/api/dag_api.py +++ b/airflow_client/client/api/dag_api.py @@ -1155,7 +1155,7 @@ def get_dag_tags( self, limit: Optional[Annotated[int, Field(strict=True, ge=0)]] = None, offset: Optional[Annotated[int, Field(strict=True, ge=0)]] = None, - order_by: Optional[List[StrictStr]] = None, + order_by: Annotated[Optional[List[StrictStr]], Field(description="Attributes to order by, multi criteria sort is supported. Prefix with `-` for descending order. Supported attributes: `name`")] = None, tag_name_pattern: Annotated[Optional[StrictStr], Field(description="SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). Regular expressions are **not** supported.")] = None, _request_timeout: Union[ None, @@ -1178,7 +1178,7 @@ def get_dag_tags( :type limit: int :param offset: :type offset: int - :param order_by: + :param order_by: Attributes to order by, multi criteria sort is supported. Prefix with `-` for descending order. Supported attributes: `name` :type order_by: List[str] :param tag_name_pattern: SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). Regular expressions are **not** supported. :type tag_name_pattern: str @@ -1237,7 +1237,7 @@ def get_dag_tags_with_http_info( self, limit: Optional[Annotated[int, Field(strict=True, ge=0)]] = None, offset: Optional[Annotated[int, Field(strict=True, ge=0)]] = None, - order_by: Optional[List[StrictStr]] = None, + order_by: Annotated[Optional[List[StrictStr]], Field(description="Attributes to order by, multi criteria sort is supported. Prefix with `-` for descending order. Supported attributes: `name`")] = None, tag_name_pattern: Annotated[Optional[StrictStr], Field(description="SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). Regular expressions are **not** supported.")] = None, _request_timeout: Union[ None, @@ -1260,7 +1260,7 @@ def get_dag_tags_with_http_info( :type limit: int :param offset: :type offset: int - :param order_by: + :param order_by: Attributes to order by, multi criteria sort is supported. Prefix with `-` for descending order. Supported attributes: `name` :type order_by: List[str] :param tag_name_pattern: SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). Regular expressions are **not** supported. :type tag_name_pattern: str @@ -1319,7 +1319,7 @@ def get_dag_tags_without_preload_content( self, limit: Optional[Annotated[int, Field(strict=True, ge=0)]] = None, offset: Optional[Annotated[int, Field(strict=True, ge=0)]] = None, - order_by: Optional[List[StrictStr]] = None, + order_by: Annotated[Optional[List[StrictStr]], Field(description="Attributes to order by, multi criteria sort is supported. Prefix with `-` for descending order. Supported attributes: `name`")] = None, tag_name_pattern: Annotated[Optional[StrictStr], Field(description="SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). Regular expressions are **not** supported.")] = None, _request_timeout: Union[ None, @@ -1342,7 +1342,7 @@ def get_dag_tags_without_preload_content( :type limit: int :param offset: :type offset: int - :param order_by: + :param order_by: Attributes to order by, multi criteria sort is supported. Prefix with `-` for descending order. Supported attributes: `name` :type order_by: List[str] :param tag_name_pattern: SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). Regular expressions are **not** supported. :type tag_name_pattern: str @@ -1502,7 +1502,7 @@ def get_dags( dag_run_end_date_lte: Optional[datetime] = None, dag_run_end_date_lt: Optional[datetime] = None, dag_run_state: Optional[List[StrictStr]] = None, - order_by: Optional[List[StrictStr]] = None, + order_by: Annotated[Optional[List[StrictStr]], Field(description="Attributes to order by, multi criteria sort is supported. Prefix with `-` for descending order. Supported attributes: `dag_id, dag_display_name, next_dagrun, state, start_date, last_run_state, last_run_start_date`")] = None, is_favorite: Optional[StrictBool] = None, _request_timeout: Union[ None, @@ -1569,7 +1569,7 @@ def get_dags( :type dag_run_end_date_lt: datetime :param dag_run_state: :type dag_run_state: List[str] - :param order_by: + :param order_by: Attributes to order by, multi criteria sort is supported. Prefix with `-` for descending order. Supported attributes: `dag_id, dag_display_name, next_dagrun, state, start_date, last_run_state, last_run_start_date` :type order_by: List[str] :param is_favorite: :type is_favorite: bool @@ -1672,7 +1672,7 @@ def get_dags_with_http_info( dag_run_end_date_lte: Optional[datetime] = None, dag_run_end_date_lt: Optional[datetime] = None, dag_run_state: Optional[List[StrictStr]] = None, - order_by: Optional[List[StrictStr]] = None, + order_by: Annotated[Optional[List[StrictStr]], Field(description="Attributes to order by, multi criteria sort is supported. Prefix with `-` for descending order. Supported attributes: `dag_id, dag_display_name, next_dagrun, state, start_date, last_run_state, last_run_start_date`")] = None, is_favorite: Optional[StrictBool] = None, _request_timeout: Union[ None, @@ -1739,7 +1739,7 @@ def get_dags_with_http_info( :type dag_run_end_date_lt: datetime :param dag_run_state: :type dag_run_state: List[str] - :param order_by: + :param order_by: Attributes to order by, multi criteria sort is supported. Prefix with `-` for descending order. Supported attributes: `dag_id, dag_display_name, next_dagrun, state, start_date, last_run_state, last_run_start_date` :type order_by: List[str] :param is_favorite: :type is_favorite: bool @@ -1842,7 +1842,7 @@ def get_dags_without_preload_content( dag_run_end_date_lte: Optional[datetime] = None, dag_run_end_date_lt: Optional[datetime] = None, dag_run_state: Optional[List[StrictStr]] = None, - order_by: Optional[List[StrictStr]] = None, + order_by: Annotated[Optional[List[StrictStr]], Field(description="Attributes to order by, multi criteria sort is supported. Prefix with `-` for descending order. Supported attributes: `dag_id, dag_display_name, next_dagrun, state, start_date, last_run_state, last_run_start_date`")] = None, is_favorite: Optional[StrictBool] = None, _request_timeout: Union[ None, @@ -1909,7 +1909,7 @@ def get_dags_without_preload_content( :type dag_run_end_date_lt: datetime :param dag_run_state: :type dag_run_state: List[str] - :param order_by: + :param order_by: Attributes to order by, multi criteria sort is supported. Prefix with `-` for descending order. Supported attributes: `dag_id, dag_display_name, next_dagrun, state, start_date, last_run_state, last_run_start_date` :type order_by: List[str] :param is_favorite: :type is_favorite: bool diff --git a/airflow_client/client/api/dag_report_api.py b/airflow_client/client/api/dag_report_api.py deleted file mode 100644 index 43b7d7d9..00000000 --- a/airflow_client/client/api/dag_report_api.py +++ /dev/null @@ -1,313 +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 warnings -from pydantic import validate_call, Field, StrictFloat, StrictStr, StrictInt -from typing import Any, Dict, List, Optional, Tuple, Union -from typing_extensions import Annotated - -from pydantic import StrictStr -from typing import Any - -from airflow_client.client.api_client import ApiClient, RequestSerialized -from airflow_client.client.api_response import ApiResponse -from airflow_client.client.rest import RESTResponseType - - -class DagReportApi: - """NOTE: This class is auto generated by OpenAPI Generator - Ref: https://openapi-generator.tech - - Do not edit the class manually. - """ - - def __init__(self, api_client=None) -> None: - if api_client is None: - api_client = ApiClient.get_default() - self.api_client = api_client - - - @validate_call - def get_dag_reports( - self, - subdir: StrictStr, - _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: - """Get Dag Reports - - Get DAG report. - - :param subdir: (required) - :type subdir: str - :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_dag_reports_serialize( - subdir=subdir, - _request_auth=_request_auth, - _content_type=_content_type, - _headers=_headers, - _host_index=_host_index - ) - - _response_types_map: Dict[str, Optional[str]] = { - '200': "object", - '400': "HTTPExceptionResponse", - '401': "HTTPExceptionResponse", - '403': "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_dag_reports_with_http_info( - self, - subdir: StrictStr, - _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]: - """Get Dag Reports - - Get DAG report. - - :param subdir: (required) - :type subdir: str - :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_dag_reports_serialize( - subdir=subdir, - _request_auth=_request_auth, - _content_type=_content_type, - _headers=_headers, - _host_index=_host_index - ) - - _response_types_map: Dict[str, Optional[str]] = { - '200': "object", - '400': "HTTPExceptionResponse", - '401': "HTTPExceptionResponse", - '403': "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_dag_reports_without_preload_content( - self, - subdir: StrictStr, - _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 Dag Reports - - Get DAG report. - - :param subdir: (required) - :type subdir: str - :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_dag_reports_serialize( - subdir=subdir, - _request_auth=_request_auth, - _content_type=_content_type, - _headers=_headers, - _host_index=_host_index - ) - - _response_types_map: Dict[str, Optional[str]] = { - '200': "object", - '400': "HTTPExceptionResponse", - '401': "HTTPExceptionResponse", - '403': "HTTPExceptionResponse", - '422': "HTTPValidationError", - } - response_data = self.api_client.call_api( - *_param, - _request_timeout=_request_timeout - ) - return response_data.response - - - def _get_dag_reports_serialize( - self, - subdir, - _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 - if subdir is not None: - - _query_params.append(('subdir', subdir)) - - # 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', - 'HTTPBearer' - ] - - return self.api_client.param_serialize( - method='GET', - resource_path='/api/v2/dagReports', - 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/dag_run_api.py b/airflow_client/client/api/dag_run_api.py index 764643be..617f8c01 100644 --- a/airflow_client/client/api/dag_run_api.py +++ b/airflow_client/client/api/dag_run_api.py @@ -968,7 +968,7 @@ def get_dag_runs( run_type: Optional[List[StrictStr]] = None, state: Optional[List[StrictStr]] = None, dag_version: Optional[List[StrictInt]] = None, - order_by: Optional[List[StrictStr]] = None, + order_by: Annotated[Optional[List[StrictStr]], Field(description="Attributes to order by, multi criteria sort is supported. Prefix with `-` for descending order. Supported attributes: `id, state, dag_id, run_id, logical_date, run_after, start_date, end_date, updated_at, conf, duration, dag_run_id`")] = None, run_id_pattern: Annotated[Optional[StrictStr], Field(description="SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). Regular expressions are **not** supported.")] = None, triggering_user_name_pattern: Annotated[Optional[StrictStr], Field(description="SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). Regular expressions are **not** supported.")] = None, _request_timeout: Union[ @@ -1040,7 +1040,7 @@ def get_dag_runs( :type state: List[str] :param dag_version: :type dag_version: List[int] - :param order_by: + :param order_by: Attributes to order by, multi criteria sort is supported. Prefix with `-` for descending order. Supported attributes: `id, state, dag_id, run_id, logical_date, run_after, start_date, end_date, updated_at, conf, duration, dag_run_id` :type order_by: List[str] :param run_id_pattern: SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). Regular expressions are **not** supported. :type run_id_pattern: str @@ -1151,7 +1151,7 @@ def get_dag_runs_with_http_info( run_type: Optional[List[StrictStr]] = None, state: Optional[List[StrictStr]] = None, dag_version: Optional[List[StrictInt]] = None, - order_by: Optional[List[StrictStr]] = None, + order_by: Annotated[Optional[List[StrictStr]], Field(description="Attributes to order by, multi criteria sort is supported. Prefix with `-` for descending order. Supported attributes: `id, state, dag_id, run_id, logical_date, run_after, start_date, end_date, updated_at, conf, duration, dag_run_id`")] = None, run_id_pattern: Annotated[Optional[StrictStr], Field(description="SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). Regular expressions are **not** supported.")] = None, triggering_user_name_pattern: Annotated[Optional[StrictStr], Field(description="SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). Regular expressions are **not** supported.")] = None, _request_timeout: Union[ @@ -1223,7 +1223,7 @@ def get_dag_runs_with_http_info( :type state: List[str] :param dag_version: :type dag_version: List[int] - :param order_by: + :param order_by: Attributes to order by, multi criteria sort is supported. Prefix with `-` for descending order. Supported attributes: `id, state, dag_id, run_id, logical_date, run_after, start_date, end_date, updated_at, conf, duration, dag_run_id` :type order_by: List[str] :param run_id_pattern: SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). Regular expressions are **not** supported. :type run_id_pattern: str @@ -1334,7 +1334,7 @@ def get_dag_runs_without_preload_content( run_type: Optional[List[StrictStr]] = None, state: Optional[List[StrictStr]] = None, dag_version: Optional[List[StrictInt]] = None, - order_by: Optional[List[StrictStr]] = None, + order_by: Annotated[Optional[List[StrictStr]], Field(description="Attributes to order by, multi criteria sort is supported. Prefix with `-` for descending order. Supported attributes: `id, state, dag_id, run_id, logical_date, run_after, start_date, end_date, updated_at, conf, duration, dag_run_id`")] = None, run_id_pattern: Annotated[Optional[StrictStr], Field(description="SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). Regular expressions are **not** supported.")] = None, triggering_user_name_pattern: Annotated[Optional[StrictStr], Field(description="SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). Regular expressions are **not** supported.")] = None, _request_timeout: Union[ @@ -1406,7 +1406,7 @@ def get_dag_runs_without_preload_content( :type state: List[str] :param dag_version: :type dag_version: List[int] - :param order_by: + :param order_by: Attributes to order by, multi criteria sort is supported. Prefix with `-` for descending order. Supported attributes: `id, state, dag_id, run_id, logical_date, run_after, start_date, end_date, updated_at, conf, duration, dag_run_id` :type order_by: List[str] :param run_id_pattern: SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). Regular expressions are **not** supported. :type run_id_pattern: str diff --git a/airflow_client/client/api/dag_version_api.py b/airflow_client/client/api/dag_version_api.py index 438b0b3a..67024b22 100644 --- a/airflow_client/client/api/dag_version_api.py +++ b/airflow_client/client/api/dag_version_api.py @@ -338,7 +338,7 @@ def get_dag_versions( version_number: Optional[StrictInt] = None, bundle_name: Optional[StrictStr] = None, bundle_version: Optional[StrictStr] = None, - order_by: Optional[List[StrictStr]] = None, + order_by: Annotated[Optional[List[StrictStr]], Field(description="Attributes to order by, multi criteria sort is supported. Prefix with `-` for descending order. Supported attributes: `id, version_number, bundle_name, bundle_version`")] = None, _request_timeout: Union[ None, Annotated[StrictFloat, Field(gt=0)], @@ -368,7 +368,7 @@ def get_dag_versions( :type bundle_name: str :param bundle_version: :type bundle_version: str - :param order_by: + :param order_by: Attributes to order by, multi criteria sort is supported. Prefix with `-` for descending order. Supported attributes: `id, version_number, bundle_name, bundle_version` :type order_by: List[str] :param _request_timeout: timeout setting for this request. If one number provided, it will be total request @@ -433,7 +433,7 @@ def get_dag_versions_with_http_info( version_number: Optional[StrictInt] = None, bundle_name: Optional[StrictStr] = None, bundle_version: Optional[StrictStr] = None, - order_by: Optional[List[StrictStr]] = None, + order_by: Annotated[Optional[List[StrictStr]], Field(description="Attributes to order by, multi criteria sort is supported. Prefix with `-` for descending order. Supported attributes: `id, version_number, bundle_name, bundle_version`")] = None, _request_timeout: Union[ None, Annotated[StrictFloat, Field(gt=0)], @@ -463,7 +463,7 @@ def get_dag_versions_with_http_info( :type bundle_name: str :param bundle_version: :type bundle_version: str - :param order_by: + :param order_by: Attributes to order by, multi criteria sort is supported. Prefix with `-` for descending order. Supported attributes: `id, version_number, bundle_name, bundle_version` :type order_by: List[str] :param _request_timeout: timeout setting for this request. If one number provided, it will be total request @@ -528,7 +528,7 @@ def get_dag_versions_without_preload_content( version_number: Optional[StrictInt] = None, bundle_name: Optional[StrictStr] = None, bundle_version: Optional[StrictStr] = None, - order_by: Optional[List[StrictStr]] = None, + order_by: Annotated[Optional[List[StrictStr]], Field(description="Attributes to order by, multi criteria sort is supported. Prefix with `-` for descending order. Supported attributes: `id, version_number, bundle_name, bundle_version`")] = None, _request_timeout: Union[ None, Annotated[StrictFloat, Field(gt=0)], @@ -558,7 +558,7 @@ def get_dag_versions_without_preload_content( :type bundle_name: str :param bundle_version: :type bundle_version: str - :param order_by: + :param order_by: Attributes to order by, multi criteria sort is supported. Prefix with `-` for descending order. Supported attributes: `id, version_number, bundle_name, bundle_version` :type order_by: List[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_warning_api.py b/airflow_client/client/api/dag_warning_api.py index eb99ab76..8fedc8e6 100644 --- a/airflow_client/client/api/dag_warning_api.py +++ b/airflow_client/client/api/dag_warning_api.py @@ -47,7 +47,7 @@ def list_dag_warnings( warning_type: Optional[DagWarningType] = None, limit: Optional[Annotated[int, Field(strict=True, ge=0)]] = None, offset: Optional[Annotated[int, Field(strict=True, ge=0)]] = None, - order_by: Optional[List[StrictStr]] = None, + order_by: Annotated[Optional[List[StrictStr]], Field(description="Attributes to order by, multi criteria sort is supported. Prefix with `-` for descending order. Supported attributes: `dag_id, warning_type, message, timestamp`")] = None, _request_timeout: Union[ None, Annotated[StrictFloat, Field(gt=0)], @@ -73,7 +73,7 @@ def list_dag_warnings( :type limit: int :param offset: :type offset: int - :param order_by: + :param order_by: Attributes to order by, multi criteria sort is supported. Prefix with `-` for descending order. Supported attributes: `dag_id, warning_type, message, timestamp` :type order_by: List[str] :param _request_timeout: timeout setting for this request. If one number provided, it will be total request @@ -133,7 +133,7 @@ def list_dag_warnings_with_http_info( warning_type: Optional[DagWarningType] = None, limit: Optional[Annotated[int, Field(strict=True, ge=0)]] = None, offset: Optional[Annotated[int, Field(strict=True, ge=0)]] = None, - order_by: Optional[List[StrictStr]] = None, + order_by: Annotated[Optional[List[StrictStr]], Field(description="Attributes to order by, multi criteria sort is supported. Prefix with `-` for descending order. Supported attributes: `dag_id, warning_type, message, timestamp`")] = None, _request_timeout: Union[ None, Annotated[StrictFloat, Field(gt=0)], @@ -159,7 +159,7 @@ def list_dag_warnings_with_http_info( :type limit: int :param offset: :type offset: int - :param order_by: + :param order_by: Attributes to order by, multi criteria sort is supported. Prefix with `-` for descending order. Supported attributes: `dag_id, warning_type, message, timestamp` :type order_by: List[str] :param _request_timeout: timeout setting for this request. If one number provided, it will be total request @@ -219,7 +219,7 @@ def list_dag_warnings_without_preload_content( warning_type: Optional[DagWarningType] = None, limit: Optional[Annotated[int, Field(strict=True, ge=0)]] = None, offset: Optional[Annotated[int, Field(strict=True, ge=0)]] = None, - order_by: Optional[List[StrictStr]] = None, + order_by: Annotated[Optional[List[StrictStr]], Field(description="Attributes to order by, multi criteria sort is supported. Prefix with `-` for descending order. Supported attributes: `dag_id, warning_type, message, timestamp`")] = None, _request_timeout: Union[ None, Annotated[StrictFloat, Field(gt=0)], @@ -245,7 +245,7 @@ def list_dag_warnings_without_preload_content( :type limit: int :param offset: :type offset: int - :param order_by: + :param order_by: Attributes to order by, multi criteria sort is supported. Prefix with `-` for descending order. Supported attributes: `dag_id, warning_type, message, timestamp` :type order_by: List[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/event_log_api.py b/airflow_client/client/api/event_log_api.py index 161afc07..9b6ecd19 100644 --- a/airflow_client/client/api/event_log_api.py +++ b/airflow_client/client/api/event_log_api.py @@ -317,7 +317,7 @@ def get_event_logs( self, limit: Optional[Annotated[int, Field(strict=True, ge=0)]] = None, offset: Optional[Annotated[int, Field(strict=True, ge=0)]] = None, - order_by: Optional[List[StrictStr]] = None, + order_by: Annotated[Optional[List[StrictStr]], Field(description="Attributes to order by, multi criteria sort is supported. Prefix with `-` for descending order. Supported attributes: `id, dttm, dag_id, task_id, run_id, event, logical_date, owner, extra, when, event_log_id`")] = None, dag_id: Optional[StrictStr] = None, task_id: Optional[StrictStr] = None, run_id: Optional[StrictStr] = None, @@ -355,7 +355,7 @@ def get_event_logs( :type limit: int :param offset: :type offset: int - :param order_by: + :param order_by: Attributes to order by, multi criteria sort is supported. Prefix with `-` for descending order. Supported attributes: `id, dttm, dag_id, task_id, run_id, event, logical_date, owner, extra, when, event_log_id` :type order_by: List[str] :param dag_id: :type dag_id: str @@ -459,7 +459,7 @@ def get_event_logs_with_http_info( self, limit: Optional[Annotated[int, Field(strict=True, ge=0)]] = None, offset: Optional[Annotated[int, Field(strict=True, ge=0)]] = None, - order_by: Optional[List[StrictStr]] = None, + order_by: Annotated[Optional[List[StrictStr]], Field(description="Attributes to order by, multi criteria sort is supported. Prefix with `-` for descending order. Supported attributes: `id, dttm, dag_id, task_id, run_id, event, logical_date, owner, extra, when, event_log_id`")] = None, dag_id: Optional[StrictStr] = None, task_id: Optional[StrictStr] = None, run_id: Optional[StrictStr] = None, @@ -497,7 +497,7 @@ def get_event_logs_with_http_info( :type limit: int :param offset: :type offset: int - :param order_by: + :param order_by: Attributes to order by, multi criteria sort is supported. Prefix with `-` for descending order. Supported attributes: `id, dttm, dag_id, task_id, run_id, event, logical_date, owner, extra, when, event_log_id` :type order_by: List[str] :param dag_id: :type dag_id: str @@ -601,7 +601,7 @@ def get_event_logs_without_preload_content( self, limit: Optional[Annotated[int, Field(strict=True, ge=0)]] = None, offset: Optional[Annotated[int, Field(strict=True, ge=0)]] = None, - order_by: Optional[List[StrictStr]] = None, + order_by: Annotated[Optional[List[StrictStr]], Field(description="Attributes to order by, multi criteria sort is supported. Prefix with `-` for descending order. Supported attributes: `id, dttm, dag_id, task_id, run_id, event, logical_date, owner, extra, when, event_log_id`")] = None, dag_id: Optional[StrictStr] = None, task_id: Optional[StrictStr] = None, run_id: Optional[StrictStr] = None, @@ -639,7 +639,7 @@ def get_event_logs_without_preload_content( :type limit: int :param offset: :type offset: int - :param order_by: + :param order_by: Attributes to order by, multi criteria sort is supported. Prefix with `-` for descending order. Supported attributes: `id, dttm, dag_id, task_id, run_id, event, logical_date, owner, extra, when, event_log_id` :type order_by: List[str] :param dag_id: :type dag_id: str diff --git a/airflow_client/client/api/import_error_api.py b/airflow_client/client/api/import_error_api.py index b63dbdd4..ecbff9b0 100644 --- a/airflow_client/client/api/import_error_api.py +++ b/airflow_client/client/api/import_error_api.py @@ -319,7 +319,7 @@ def get_import_errors( self, limit: Optional[Annotated[int, Field(strict=True, ge=0)]] = None, offset: Optional[Annotated[int, Field(strict=True, ge=0)]] = None, - order_by: Optional[List[StrictStr]] = None, + order_by: Annotated[Optional[List[StrictStr]], Field(description="Attributes to order by, multi criteria sort is supported. Prefix with `-` for descending order. Supported attributes: `id, timestamp, filename, bundle_name, stacktrace, import_error_id`")] = None, filename_pattern: Annotated[Optional[StrictStr], Field(description="SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). Regular expressions are **not** supported.")] = None, _request_timeout: Union[ None, @@ -342,7 +342,7 @@ def get_import_errors( :type limit: int :param offset: :type offset: int - :param order_by: + :param order_by: Attributes to order by, multi criteria sort is supported. Prefix with `-` for descending order. Supported attributes: `id, timestamp, filename, bundle_name, stacktrace, import_error_id` :type order_by: List[str] :param filename_pattern: SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). Regular expressions are **not** supported. :type filename_pattern: str @@ -401,7 +401,7 @@ def get_import_errors_with_http_info( self, limit: Optional[Annotated[int, Field(strict=True, ge=0)]] = None, offset: Optional[Annotated[int, Field(strict=True, ge=0)]] = None, - order_by: Optional[List[StrictStr]] = None, + order_by: Annotated[Optional[List[StrictStr]], Field(description="Attributes to order by, multi criteria sort is supported. Prefix with `-` for descending order. Supported attributes: `id, timestamp, filename, bundle_name, stacktrace, import_error_id`")] = None, filename_pattern: Annotated[Optional[StrictStr], Field(description="SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). Regular expressions are **not** supported.")] = None, _request_timeout: Union[ None, @@ -424,7 +424,7 @@ def get_import_errors_with_http_info( :type limit: int :param offset: :type offset: int - :param order_by: + :param order_by: Attributes to order by, multi criteria sort is supported. Prefix with `-` for descending order. Supported attributes: `id, timestamp, filename, bundle_name, stacktrace, import_error_id` :type order_by: List[str] :param filename_pattern: SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). Regular expressions are **not** supported. :type filename_pattern: str @@ -483,7 +483,7 @@ def get_import_errors_without_preload_content( self, limit: Optional[Annotated[int, Field(strict=True, ge=0)]] = None, offset: Optional[Annotated[int, Field(strict=True, ge=0)]] = None, - order_by: Optional[List[StrictStr]] = None, + order_by: Annotated[Optional[List[StrictStr]], Field(description="Attributes to order by, multi criteria sort is supported. Prefix with `-` for descending order. Supported attributes: `id, timestamp, filename, bundle_name, stacktrace, import_error_id`")] = None, filename_pattern: Annotated[Optional[StrictStr], Field(description="SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). Regular expressions are **not** supported.")] = None, _request_timeout: Union[ None, @@ -506,7 +506,7 @@ def get_import_errors_without_preload_content( :type limit: int :param offset: :type offset: int - :param order_by: + :param order_by: Attributes to order by, multi criteria sort is supported. Prefix with `-` for descending order. Supported attributes: `id, timestamp, filename, bundle_name, stacktrace, import_error_id` :type order_by: List[str] :param filename_pattern: SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). Regular expressions are **not** supported. :type filename_pattern: str diff --git a/airflow_client/client/api/job_api.py b/airflow_client/client/api/job_api.py index 6c0c727f..3729fa5f 100644 --- a/airflow_client/client/api/job_api.py +++ b/airflow_client/client/api/job_api.py @@ -54,7 +54,7 @@ def get_jobs( end_date_lt: Optional[datetime] = None, limit: Optional[Annotated[int, Field(strict=True, ge=0)]] = None, offset: Optional[Annotated[int, Field(strict=True, ge=0)]] = None, - order_by: Optional[List[StrictStr]] = None, + order_by: Annotated[Optional[List[StrictStr]], Field(description="Attributes to order by, multi criteria sort is supported. Prefix with `-` for descending order. Supported attributes: `id, dag_id, state, job_type, start_date, end_date, latest_heartbeat, executor_class, hostname, unixname`")] = None, job_state: Optional[StrictStr] = None, job_type: Optional[StrictStr] = None, hostname: Optional[StrictStr] = None, @@ -98,7 +98,7 @@ def get_jobs( :type limit: int :param offset: :type offset: int - :param order_by: + :param order_by: Attributes to order by, multi criteria sort is supported. Prefix with `-` for descending order. Supported attributes: `id, dag_id, state, job_type, start_date, end_date, latest_heartbeat, executor_class, hostname, unixname` :type order_by: List[str] :param job_state: :type job_state: str @@ -185,7 +185,7 @@ def get_jobs_with_http_info( end_date_lt: Optional[datetime] = None, limit: Optional[Annotated[int, Field(strict=True, ge=0)]] = None, offset: Optional[Annotated[int, Field(strict=True, ge=0)]] = None, - order_by: Optional[List[StrictStr]] = None, + order_by: Annotated[Optional[List[StrictStr]], Field(description="Attributes to order by, multi criteria sort is supported. Prefix with `-` for descending order. Supported attributes: `id, dag_id, state, job_type, start_date, end_date, latest_heartbeat, executor_class, hostname, unixname`")] = None, job_state: Optional[StrictStr] = None, job_type: Optional[StrictStr] = None, hostname: Optional[StrictStr] = None, @@ -229,7 +229,7 @@ def get_jobs_with_http_info( :type limit: int :param offset: :type offset: int - :param order_by: + :param order_by: Attributes to order by, multi criteria sort is supported. Prefix with `-` for descending order. Supported attributes: `id, dag_id, state, job_type, start_date, end_date, latest_heartbeat, executor_class, hostname, unixname` :type order_by: List[str] :param job_state: :type job_state: str @@ -316,7 +316,7 @@ def get_jobs_without_preload_content( end_date_lt: Optional[datetime] = None, limit: Optional[Annotated[int, Field(strict=True, ge=0)]] = None, offset: Optional[Annotated[int, Field(strict=True, ge=0)]] = None, - order_by: Optional[List[StrictStr]] = None, + order_by: Annotated[Optional[List[StrictStr]], Field(description="Attributes to order by, multi criteria sort is supported. Prefix with `-` for descending order. Supported attributes: `id, dag_id, state, job_type, start_date, end_date, latest_heartbeat, executor_class, hostname, unixname`")] = None, job_state: Optional[StrictStr] = None, job_type: Optional[StrictStr] = None, hostname: Optional[StrictStr] = None, @@ -360,7 +360,7 @@ def get_jobs_without_preload_content( :type limit: int :param offset: :type offset: int - :param order_by: + :param order_by: Attributes to order by, multi criteria sort is supported. Prefix with `-` for descending order. Supported attributes: `id, dag_id, state, job_type, start_date, end_date, latest_heartbeat, executor_class, hostname, unixname` :type order_by: List[str] :param job_state: :type job_state: str diff --git a/airflow_client/client/api/login_api.py b/airflow_client/client/api/login_api.py index e1103cb3..80fc67e0 100644 --- a/airflow_client/client/api/login_api.py +++ b/airflow_client/client/api/login_api.py @@ -308,7 +308,6 @@ def _login_serialize( @validate_call def logout( self, - next: Optional[StrictStr] = None, _request_timeout: Union[ None, Annotated[StrictFloat, Field(gt=0)], @@ -326,8 +325,6 @@ def logout( Logout the user. - :param next: - :type next: str :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 @@ -351,7 +348,6 @@ def logout( """ # noqa: E501 _param = self._logout_serialize( - next=next, _request_auth=_request_auth, _content_type=_content_type, _headers=_headers, @@ -361,7 +357,6 @@ def logout( _response_types_map: Dict[str, Optional[str]] = { '200': "object", '307': "HTTPExceptionResponse", - '422': "HTTPValidationError", } response_data = self.api_client.call_api( *_param, @@ -377,7 +372,6 @@ def logout( @validate_call def logout_with_http_info( self, - next: Optional[StrictStr] = None, _request_timeout: Union[ None, Annotated[StrictFloat, Field(gt=0)], @@ -395,8 +389,6 @@ def logout_with_http_info( Logout the user. - :param next: - :type next: str :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 @@ -420,7 +412,6 @@ def logout_with_http_info( """ # noqa: E501 _param = self._logout_serialize( - next=next, _request_auth=_request_auth, _content_type=_content_type, _headers=_headers, @@ -430,7 +421,6 @@ def logout_with_http_info( _response_types_map: Dict[str, Optional[str]] = { '200': "object", '307': "HTTPExceptionResponse", - '422': "HTTPValidationError", } response_data = self.api_client.call_api( *_param, @@ -446,7 +436,6 @@ def logout_with_http_info( @validate_call def logout_without_preload_content( self, - next: Optional[StrictStr] = None, _request_timeout: Union[ None, Annotated[StrictFloat, Field(gt=0)], @@ -464,8 +453,6 @@ def logout_without_preload_content( Logout the user. - :param next: - :type next: str :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 @@ -489,7 +476,6 @@ def logout_without_preload_content( """ # noqa: E501 _param = self._logout_serialize( - next=next, _request_auth=_request_auth, _content_type=_content_type, _headers=_headers, @@ -499,7 +485,6 @@ def logout_without_preload_content( _response_types_map: Dict[str, Optional[str]] = { '200': "object", '307': "HTTPExceptionResponse", - '422': "HTTPValidationError", } response_data = self.api_client.call_api( *_param, @@ -510,7 +495,6 @@ def logout_without_preload_content( def _logout_serialize( self, - next, _request_auth, _content_type, _headers, @@ -533,10 +517,6 @@ def _logout_serialize( # process the path parameters # process the query parameters - if next is not None: - - _query_params.append(('next', next)) - # process the header parameters # process the form parameters # process the body parameter diff --git a/airflow_client/client/api/pool_api.py b/airflow_client/client/api/pool_api.py index 50ac7f72..345a2108 100644 --- a/airflow_client/client/api/pool_api.py +++ b/airflow_client/client/api/pool_api.py @@ -884,7 +884,7 @@ def get_pools( self, limit: Optional[Annotated[int, Field(strict=True, ge=0)]] = None, offset: Optional[Annotated[int, Field(strict=True, ge=0)]] = None, - order_by: Optional[List[StrictStr]] = None, + order_by: Annotated[Optional[List[StrictStr]], Field(description="Attributes to order by, multi criteria sort is supported. Prefix with `-` for descending order. Supported attributes: `id, pool, name`")] = None, pool_name_pattern: Annotated[Optional[StrictStr], Field(description="SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). Regular expressions are **not** supported.")] = None, _request_timeout: Union[ None, @@ -907,7 +907,7 @@ def get_pools( :type limit: int :param offset: :type offset: int - :param order_by: + :param order_by: Attributes to order by, multi criteria sort is supported. Prefix with `-` for descending order. Supported attributes: `id, pool, name` :type order_by: List[str] :param pool_name_pattern: SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). Regular expressions are **not** supported. :type pool_name_pattern: str @@ -967,7 +967,7 @@ def get_pools_with_http_info( self, limit: Optional[Annotated[int, Field(strict=True, ge=0)]] = None, offset: Optional[Annotated[int, Field(strict=True, ge=0)]] = None, - order_by: Optional[List[StrictStr]] = None, + order_by: Annotated[Optional[List[StrictStr]], Field(description="Attributes to order by, multi criteria sort is supported. Prefix with `-` for descending order. Supported attributes: `id, pool, name`")] = None, pool_name_pattern: Annotated[Optional[StrictStr], Field(description="SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). Regular expressions are **not** supported.")] = None, _request_timeout: Union[ None, @@ -990,7 +990,7 @@ def get_pools_with_http_info( :type limit: int :param offset: :type offset: int - :param order_by: + :param order_by: Attributes to order by, multi criteria sort is supported. Prefix with `-` for descending order. Supported attributes: `id, pool, name` :type order_by: List[str] :param pool_name_pattern: SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). Regular expressions are **not** supported. :type pool_name_pattern: str @@ -1050,7 +1050,7 @@ def get_pools_without_preload_content( self, limit: Optional[Annotated[int, Field(strict=True, ge=0)]] = None, offset: Optional[Annotated[int, Field(strict=True, ge=0)]] = None, - order_by: Optional[List[StrictStr]] = None, + order_by: Annotated[Optional[List[StrictStr]], Field(description="Attributes to order by, multi criteria sort is supported. Prefix with `-` for descending order. Supported attributes: `id, pool, name`")] = None, pool_name_pattern: Annotated[Optional[StrictStr], Field(description="SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). Regular expressions are **not** supported.")] = None, _request_timeout: Union[ None, @@ -1073,7 +1073,7 @@ def get_pools_without_preload_content( :type limit: int :param offset: :type offset: int - :param order_by: + :param order_by: Attributes to order by, multi criteria sort is supported. Prefix with `-` for descending order. Supported attributes: `id, pool, name` :type order_by: List[str] :param pool_name_pattern: SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). Regular expressions are **not** supported. :type pool_name_pattern: str diff --git a/airflow_client/client/api/task_instance_api.py b/airflow_client/client/api/task_instance_api.py index 8d3211f3..2557e26d 100644 --- a/airflow_client/client/api/task_instance_api.py +++ b/airflow_client/client/api/task_instance_api.py @@ -1677,7 +1677,7 @@ def get_hitl_details( dag_run_id: StrictStr, limit: Optional[Annotated[int, Field(strict=True, ge=0)]] = None, offset: Optional[Annotated[int, Field(strict=True, ge=0)]] = None, - order_by: Optional[List[StrictStr]] = None, + order_by: Annotated[Optional[List[StrictStr]], Field(description="Attributes to order by, multi criteria sort is supported. Prefix with `-` for descending order. Supported attributes: `ti_id, subject, responded_at, created_at, responded_by_user_id, responded_by_user_name, dag_id, run_id, run_after, rendered_map_index, task_instance_operator, task_instance_state`")] = None, dag_id_pattern: Annotated[Optional[StrictStr], Field(description="SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). Regular expressions are **not** supported.")] = None, task_id: Optional[StrictStr] = None, task_id_pattern: Annotated[Optional[StrictStr], Field(description="SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). Regular expressions are **not** supported.")] = None, @@ -1717,7 +1717,7 @@ def get_hitl_details( :type limit: int :param offset: :type offset: int - :param order_by: + :param order_by: Attributes to order by, multi criteria sort is supported. Prefix with `-` for descending order. Supported attributes: `ti_id, subject, responded_at, created_at, responded_by_user_id, responded_by_user_name, dag_id, run_id, run_after, rendered_map_index, task_instance_operator, task_instance_state` :type order_by: List[str] :param dag_id_pattern: SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). Regular expressions are **not** supported. :type dag_id_pattern: str @@ -1819,7 +1819,7 @@ def get_hitl_details_with_http_info( dag_run_id: StrictStr, limit: Optional[Annotated[int, Field(strict=True, ge=0)]] = None, offset: Optional[Annotated[int, Field(strict=True, ge=0)]] = None, - order_by: Optional[List[StrictStr]] = None, + order_by: Annotated[Optional[List[StrictStr]], Field(description="Attributes to order by, multi criteria sort is supported. Prefix with `-` for descending order. Supported attributes: `ti_id, subject, responded_at, created_at, responded_by_user_id, responded_by_user_name, dag_id, run_id, run_after, rendered_map_index, task_instance_operator, task_instance_state`")] = None, dag_id_pattern: Annotated[Optional[StrictStr], Field(description="SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). Regular expressions are **not** supported.")] = None, task_id: Optional[StrictStr] = None, task_id_pattern: Annotated[Optional[StrictStr], Field(description="SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). Regular expressions are **not** supported.")] = None, @@ -1859,7 +1859,7 @@ def get_hitl_details_with_http_info( :type limit: int :param offset: :type offset: int - :param order_by: + :param order_by: Attributes to order by, multi criteria sort is supported. Prefix with `-` for descending order. Supported attributes: `ti_id, subject, responded_at, created_at, responded_by_user_id, responded_by_user_name, dag_id, run_id, run_after, rendered_map_index, task_instance_operator, task_instance_state` :type order_by: List[str] :param dag_id_pattern: SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). Regular expressions are **not** supported. :type dag_id_pattern: str @@ -1961,7 +1961,7 @@ def get_hitl_details_without_preload_content( dag_run_id: StrictStr, limit: Optional[Annotated[int, Field(strict=True, ge=0)]] = None, offset: Optional[Annotated[int, Field(strict=True, ge=0)]] = None, - order_by: Optional[List[StrictStr]] = None, + order_by: Annotated[Optional[List[StrictStr]], Field(description="Attributes to order by, multi criteria sort is supported. Prefix with `-` for descending order. Supported attributes: `ti_id, subject, responded_at, created_at, responded_by_user_id, responded_by_user_name, dag_id, run_id, run_after, rendered_map_index, task_instance_operator, task_instance_state`")] = None, dag_id_pattern: Annotated[Optional[StrictStr], Field(description="SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). Regular expressions are **not** supported.")] = None, task_id: Optional[StrictStr] = None, task_id_pattern: Annotated[Optional[StrictStr], Field(description="SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). Regular expressions are **not** supported.")] = None, @@ -2001,7 +2001,7 @@ def get_hitl_details_without_preload_content( :type limit: int :param offset: :type offset: int - :param order_by: + :param order_by: Attributes to order by, multi criteria sort is supported. Prefix with `-` for descending order. Supported attributes: `ti_id, subject, responded_at, created_at, responded_by_user_id, responded_by_user_name, dag_id, run_id, run_after, rendered_map_index, task_instance_operator, task_instance_state` :type order_by: List[str] :param dag_id_pattern: SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). Regular expressions are **not** supported. :type dag_id_pattern: str @@ -3677,7 +3677,7 @@ def get_mapped_task_instances( map_index: Optional[List[StrictInt]] = None, limit: Optional[Annotated[int, Field(strict=True, ge=0)]] = None, offset: Optional[Annotated[int, Field(strict=True, ge=0)]] = None, - order_by: Optional[List[StrictStr]] = None, + order_by: Annotated[Optional[List[StrictStr]], Field(description="Attributes to order by, multi criteria sort is supported. Prefix with `-` for descending order. Supported attributes: `id, state, duration, start_date, end_date, map_index, try_number, logical_date, run_after, data_interval_start, data_interval_end, rendered_map_index, operator, run_after, logical_date, data_interval_start, data_interval_end`")] = None, _request_timeout: Union[ None, Annotated[StrictFloat, Field(gt=0)], @@ -3769,7 +3769,7 @@ def get_mapped_task_instances( :type limit: int :param offset: :type offset: int - :param order_by: + :param order_by: Attributes to order by, multi criteria sort is supported. Prefix with `-` for descending order. Supported attributes: `id, state, duration, start_date, end_date, map_index, try_number, logical_date, run_after, data_interval_start, data_interval_end, rendered_map_index, operator, run_after, logical_date, data_interval_start, data_interval_end` :type order_by: List[str] :param _request_timeout: timeout setting for this request. If one number provided, it will be total request @@ -3896,7 +3896,7 @@ def get_mapped_task_instances_with_http_info( map_index: Optional[List[StrictInt]] = None, limit: Optional[Annotated[int, Field(strict=True, ge=0)]] = None, offset: Optional[Annotated[int, Field(strict=True, ge=0)]] = None, - order_by: Optional[List[StrictStr]] = None, + order_by: Annotated[Optional[List[StrictStr]], Field(description="Attributes to order by, multi criteria sort is supported. Prefix with `-` for descending order. Supported attributes: `id, state, duration, start_date, end_date, map_index, try_number, logical_date, run_after, data_interval_start, data_interval_end, rendered_map_index, operator, run_after, logical_date, data_interval_start, data_interval_end`")] = None, _request_timeout: Union[ None, Annotated[StrictFloat, Field(gt=0)], @@ -3988,7 +3988,7 @@ def get_mapped_task_instances_with_http_info( :type limit: int :param offset: :type offset: int - :param order_by: + :param order_by: Attributes to order by, multi criteria sort is supported. Prefix with `-` for descending order. Supported attributes: `id, state, duration, start_date, end_date, map_index, try_number, logical_date, run_after, data_interval_start, data_interval_end, rendered_map_index, operator, run_after, logical_date, data_interval_start, data_interval_end` :type order_by: List[str] :param _request_timeout: timeout setting for this request. If one number provided, it will be total request @@ -4115,7 +4115,7 @@ def get_mapped_task_instances_without_preload_content( map_index: Optional[List[StrictInt]] = None, limit: Optional[Annotated[int, Field(strict=True, ge=0)]] = None, offset: Optional[Annotated[int, Field(strict=True, ge=0)]] = None, - order_by: Optional[List[StrictStr]] = None, + order_by: Annotated[Optional[List[StrictStr]], Field(description="Attributes to order by, multi criteria sort is supported. Prefix with `-` for descending order. Supported attributes: `id, state, duration, start_date, end_date, map_index, try_number, logical_date, run_after, data_interval_start, data_interval_end, rendered_map_index, operator, run_after, logical_date, data_interval_start, data_interval_end`")] = None, _request_timeout: Union[ None, Annotated[StrictFloat, Field(gt=0)], @@ -4207,7 +4207,7 @@ def get_mapped_task_instances_without_preload_content( :type limit: int :param offset: :type offset: int - :param order_by: + :param order_by: Attributes to order by, multi criteria sort is supported. Prefix with `-` for descending order. Supported attributes: `id, state, duration, start_date, end_date, map_index, try_number, logical_date, run_after, data_interval_start, data_interval_end, rendered_map_index, operator, run_after, logical_date, data_interval_start, data_interval_end` :type order_by: List[str] :param _request_timeout: timeout setting for this request. If one number provided, it will be total request @@ -6367,7 +6367,7 @@ def get_task_instances( map_index: Optional[List[StrictInt]] = None, limit: Optional[Annotated[int, Field(strict=True, ge=0)]] = None, offset: Optional[Annotated[int, Field(strict=True, ge=0)]] = None, - order_by: Optional[List[StrictStr]] = None, + order_by: Annotated[Optional[List[StrictStr]], Field(description="Attributes to order by, multi criteria sort is supported. Prefix with `-` for descending order. Supported attributes: `id, state, duration, start_date, end_date, map_index, try_number, logical_date, run_after, data_interval_start, data_interval_end, rendered_map_index, operator, logical_date, run_after, data_interval_start, data_interval_end`")] = None, _request_timeout: Union[ None, Annotated[StrictFloat, Field(gt=0)], @@ -6461,7 +6461,7 @@ def get_task_instances( :type limit: int :param offset: :type offset: int - :param order_by: + :param order_by: Attributes to order by, multi criteria sort is supported. Prefix with `-` for descending order. Supported attributes: `id, state, duration, start_date, end_date, map_index, try_number, logical_date, run_after, data_interval_start, data_interval_end, rendered_map_index, operator, logical_date, run_after, data_interval_start, data_interval_end` :type order_by: List[str] :param _request_timeout: timeout setting for this request. If one number provided, it will be total request @@ -6590,7 +6590,7 @@ def get_task_instances_with_http_info( map_index: Optional[List[StrictInt]] = None, limit: Optional[Annotated[int, Field(strict=True, ge=0)]] = None, offset: Optional[Annotated[int, Field(strict=True, ge=0)]] = None, - order_by: Optional[List[StrictStr]] = None, + order_by: Annotated[Optional[List[StrictStr]], Field(description="Attributes to order by, multi criteria sort is supported. Prefix with `-` for descending order. Supported attributes: `id, state, duration, start_date, end_date, map_index, try_number, logical_date, run_after, data_interval_start, data_interval_end, rendered_map_index, operator, logical_date, run_after, data_interval_start, data_interval_end`")] = None, _request_timeout: Union[ None, Annotated[StrictFloat, Field(gt=0)], @@ -6684,7 +6684,7 @@ def get_task_instances_with_http_info( :type limit: int :param offset: :type offset: int - :param order_by: + :param order_by: Attributes to order by, multi criteria sort is supported. Prefix with `-` for descending order. Supported attributes: `id, state, duration, start_date, end_date, map_index, try_number, logical_date, run_after, data_interval_start, data_interval_end, rendered_map_index, operator, logical_date, run_after, data_interval_start, data_interval_end` :type order_by: List[str] :param _request_timeout: timeout setting for this request. If one number provided, it will be total request @@ -6813,7 +6813,7 @@ def get_task_instances_without_preload_content( map_index: Optional[List[StrictInt]] = None, limit: Optional[Annotated[int, Field(strict=True, ge=0)]] = None, offset: Optional[Annotated[int, Field(strict=True, ge=0)]] = None, - order_by: Optional[List[StrictStr]] = None, + order_by: Annotated[Optional[List[StrictStr]], Field(description="Attributes to order by, multi criteria sort is supported. Prefix with `-` for descending order. Supported attributes: `id, state, duration, start_date, end_date, map_index, try_number, logical_date, run_after, data_interval_start, data_interval_end, rendered_map_index, operator, logical_date, run_after, data_interval_start, data_interval_end`")] = None, _request_timeout: Union[ None, Annotated[StrictFloat, Field(gt=0)], @@ -6907,7 +6907,7 @@ def get_task_instances_without_preload_content( :type limit: int :param offset: :type offset: int - :param order_by: + :param order_by: Attributes to order by, multi criteria sort is supported. Prefix with `-` for descending order. Supported attributes: `id, state, duration, start_date, end_date, map_index, try_number, logical_date, run_after, data_interval_start, data_interval_end, rendered_map_index, operator, logical_date, run_after, data_interval_start, data_interval_end` :type order_by: List[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/variable_api.py b/airflow_client/client/api/variable_api.py index 271735fe..1f9eda1c 100644 --- a/airflow_client/client/api/variable_api.py +++ b/airflow_client/client/api/variable_api.py @@ -880,7 +880,7 @@ def get_variables( self, limit: Optional[Annotated[int, Field(strict=True, ge=0)]] = None, offset: Optional[Annotated[int, Field(strict=True, ge=0)]] = None, - order_by: Optional[List[StrictStr]] = None, + order_by: Annotated[Optional[List[StrictStr]], Field(description="Attributes to order by, multi criteria sort is supported. Prefix with `-` for descending order. Supported attributes: `key, id, _val, description, is_encrypted`")] = None, variable_key_pattern: Annotated[Optional[StrictStr], Field(description="SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). Regular expressions are **not** supported.")] = None, _request_timeout: Union[ None, @@ -903,7 +903,7 @@ def get_variables( :type limit: int :param offset: :type offset: int - :param order_by: + :param order_by: Attributes to order by, multi criteria sort is supported. Prefix with `-` for descending order. Supported attributes: `key, id, _val, description, is_encrypted` :type order_by: List[str] :param variable_key_pattern: SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). Regular expressions are **not** supported. :type variable_key_pattern: str @@ -962,7 +962,7 @@ def get_variables_with_http_info( self, limit: Optional[Annotated[int, Field(strict=True, ge=0)]] = None, offset: Optional[Annotated[int, Field(strict=True, ge=0)]] = None, - order_by: Optional[List[StrictStr]] = None, + order_by: Annotated[Optional[List[StrictStr]], Field(description="Attributes to order by, multi criteria sort is supported. Prefix with `-` for descending order. Supported attributes: `key, id, _val, description, is_encrypted`")] = None, variable_key_pattern: Annotated[Optional[StrictStr], Field(description="SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). Regular expressions are **not** supported.")] = None, _request_timeout: Union[ None, @@ -985,7 +985,7 @@ def get_variables_with_http_info( :type limit: int :param offset: :type offset: int - :param order_by: + :param order_by: Attributes to order by, multi criteria sort is supported. Prefix with `-` for descending order. Supported attributes: `key, id, _val, description, is_encrypted` :type order_by: List[str] :param variable_key_pattern: SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). Regular expressions are **not** supported. :type variable_key_pattern: str @@ -1044,7 +1044,7 @@ def get_variables_without_preload_content( self, limit: Optional[Annotated[int, Field(strict=True, ge=0)]] = None, offset: Optional[Annotated[int, Field(strict=True, ge=0)]] = None, - order_by: Optional[List[StrictStr]] = None, + order_by: Annotated[Optional[List[StrictStr]], Field(description="Attributes to order by, multi criteria sort is supported. Prefix with `-` for descending order. Supported attributes: `key, id, _val, description, is_encrypted`")] = None, variable_key_pattern: Annotated[Optional[StrictStr], Field(description="SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). Regular expressions are **not** supported.")] = None, _request_timeout: Union[ None, @@ -1067,7 +1067,7 @@ def get_variables_without_preload_content( :type limit: int :param offset: :type offset: int - :param order_by: + :param order_by: Attributes to order by, multi criteria sort is supported. Prefix with `-` for descending order. Supported attributes: `key, id, _val, description, is_encrypted` :type order_by: List[str] :param variable_key_pattern: SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). Regular expressions are **not** supported. :type variable_key_pattern: str diff --git a/airflow_client/client/api_client.py b/airflow_client/client/api_client.py index fddd4ff5..777d3387 100644 --- a/airflow_client/client/api_client.py +++ b/airflow_client/client/api_client.py @@ -90,7 +90,7 @@ def __init__( self.default_headers[header_name] = header_value self.cookie = cookie # Set default User-Agent. - self.user_agent = 'OpenAPI-Generator/3.1.0/python' + self.user_agent = 'OpenAPI-Generator/3.1.3/python' self.client_side_validation = configuration.client_side_validation def __enter__(self): diff --git a/airflow_client/client/configuration.py b/airflow_client/client/configuration.py index dbc9328f..74ddce94 100644 --- a/airflow_client/client/configuration.py +++ b/airflow_client/client/configuration.py @@ -518,7 +518,7 @@ def to_debug_report(self) -> str: "OS: {env}\n"\ "Python Version: {pyversion}\n"\ "Version of the API: 2\n"\ - "SDK Package Version: 3.1.0".\ + "SDK Package Version: 3.1.3".\ format(env=sys.platform, pyversion=sys.version) def get_host_settings(self) -> List[HostSetting]: diff --git a/airflow_client/client/models/dag_details_response.py b/airflow_client/client/models/dag_details_response.py index ec885e0a..c258b951 100644 --- a/airflow_client/client/models/dag_details_response.py +++ b/airflow_client/client/models/dag_details_response.py @@ -45,6 +45,7 @@ class DAGDetailsResponse(BaseModel): fileloc: StrictStr has_import_errors: StrictBool has_task_concurrency_limits: StrictBool + is_favorite: Optional[StrictBool] = False is_paused: StrictBool is_paused_upon_creation: Optional[StrictBool] = None is_stale: StrictBool @@ -71,7 +72,7 @@ class DAGDetailsResponse(BaseModel): 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_parse_duration", "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", "default_args", "description", "doc_md", "end_date", "file_token", "fileloc", "has_import_errors", "has_task_concurrency_limits", "is_favorite", "is_paused", "is_paused_upon_creation", "is_stale", "last_expired", "last_parse_duration", "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, @@ -154,6 +155,7 @@ def from_dict(cls, obj: Optional[Dict[str, Any]]) -> Optional[Self]: "fileloc": obj.get("fileloc"), "has_import_errors": obj.get("has_import_errors"), "has_task_concurrency_limits": obj.get("has_task_concurrency_limits"), + "is_favorite": obj.get("is_favorite") if obj.get("is_favorite") is not None else False, "is_paused": obj.get("is_paused"), "is_paused_upon_creation": obj.get("is_paused_upon_creation"), "is_stale": obj.get("is_stale"), diff --git a/airflow_client/client/models/event_log_response.py b/airflow_client/client/models/event_log_response.py index d864db2e..7d12d7aa 100644 --- a/airflow_client/client/models/event_log_response.py +++ b/airflow_client/client/models/event_log_response.py @@ -36,10 +36,11 @@ class EventLogResponse(BaseModel): map_index: Optional[StrictInt] = None owner: Optional[StrictStr] = None run_id: Optional[StrictStr] = None + task_display_name: Optional[StrictStr] = None 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_display_name", "dag_id", "event", "event_log_id", "extra", "logical_date", "map_index", "owner", "run_id", "task_display_name", "task_id", "try_number", "when"] model_config = ConfigDict( populate_by_name=True, @@ -101,6 +102,7 @@ def from_dict(cls, obj: Optional[Dict[str, Any]]) -> Optional[Self]: "map_index": obj.get("map_index"), "owner": obj.get("owner"), "run_id": obj.get("run_id"), + "task_display_name": obj.get("task_display_name"), "task_id": obj.get("task_id"), "try_number": obj.get("try_number"), "when": obj.get("when") diff --git a/docs/AssetApi.md b/docs/AssetApi.md index 0e60be45..e35baaec 100644 --- a/docs/AssetApi.md +++ b/docs/AssetApi.md @@ -571,7 +571,7 @@ with airflow_client.client.ApiClient(configuration) as 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) - order_by = [id] # List[str] | (optional) (default to [id]) + order_by = ["id"] # List[str] | Attributes to order by, multi criteria sort is supported. Prefix with `-` for descending order. Supported attributes: `id, name` (optional) (default to ["id"]) try: # Get Asset Aliases @@ -592,7 +592,7 @@ Name | Type | Description | Notes **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] - **order_by** | [**List[str]**](str.md)| | [optional] [default to [id]] + **order_by** | [**List[str]**](str.md)| Attributes to order by, multi criteria sort is supported. Prefix with `-` for descending order. Supported attributes: `id, name` | [optional] [default to ["id"]] ### Return type @@ -661,7 +661,7 @@ with airflow_client.client.ApiClient(configuration) as api_client: api_instance = airflow_client.client.AssetApi(api_client) limit = 50 # int | (optional) (default to 50) offset = 0 # int | (optional) (default to 0) - order_by = ["timestamp"] # List[str] | (optional) (default to ["timestamp"]) + order_by = ["timestamp"] # List[str] | Attributes to order by, multi criteria sort is supported. Prefix with `-` for descending order. Supported attributes: `source_task_id, source_dag_id, source_run_id, source_map_index, timestamp` (optional) (default to ["timestamp"]) asset_id = 56 # int | (optional) source_dag_id = 'source_dag_id_example' # str | (optional) source_task_id = 'source_task_id_example' # str | (optional) @@ -690,7 +690,7 @@ Name | Type | Description | Notes ------------- | ------------- | ------------- | ------------- **limit** | **int**| | [optional] [default to 50] **offset** | **int**| | [optional] [default to 0] - **order_by** | [**List[str]**](str.md)| | [optional] [default to ["timestamp"]] + **order_by** | [**List[str]**](str.md)| Attributes to order by, multi criteria sort is supported. Prefix with `-` for descending order. Supported attributes: `source_task_id, source_dag_id, source_run_id, source_map_index, timestamp` | [optional] [default to ["timestamp"]] **asset_id** | **int**| | [optional] **source_dag_id** | **str**| | [optional] **source_task_id** | **str**| | [optional] @@ -859,7 +859,7 @@ with airflow_client.client.ApiClient(configuration) as api_client: uri_pattern = 'uri_pattern_example' # str | SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). Regular expressions are **not** supported. (optional) dag_ids = ['dag_ids_example'] # List[str] | (optional) only_active = True # bool | (optional) (default to True) - order_by = ["id"] # List[str] | (optional) (default to ["id"]) + order_by = ["id"] # List[str] | Attributes to order by, multi criteria sort is supported. Prefix with `-` for descending order. Supported attributes: `id, name, uri, created_at, updated_at` (optional) (default to ["id"]) try: # Get Assets @@ -883,7 +883,7 @@ Name | Type | Description | Notes **uri_pattern** | **str**| SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). Regular expressions are **not** supported. | [optional] **dag_ids** | [**List[str]**](str.md)| | [optional] **only_active** | **bool**| | [optional] [default to True] - **order_by** | [**List[str]**](str.md)| | [optional] [default to ["id"]] + **order_by** | [**List[str]**](str.md)| Attributes to order by, multi criteria sort is supported. Prefix with `-` for descending order. Supported attributes: `id, name, uri, created_at, updated_at` | [optional] [default to ["id"]] ### Return type diff --git a/docs/AssetEventResponse.md b/docs/AssetEventResponse.md index 6134e83e..ad031490 100644 --- a/docs/AssetEventResponse.md +++ b/docs/AssetEventResponse.md @@ -8,7 +8,7 @@ Name | Type | Description | Notes ------------ | ------------- | ------------- | ------------- **asset_id** | **int** | | **created_dagruns** | [**List[DagRunAssetReference]**](DagRunAssetReference.md) | | -**extra** | **object** | | [optional] +**extra** | **Dict[str, object]** | | [optional] **group** | **str** | | [optional] **id** | **int** | | **name** | **str** | | [optional] diff --git a/docs/AssetResponse.md b/docs/AssetResponse.md index b34c5144..0201a000 100644 --- a/docs/AssetResponse.md +++ b/docs/AssetResponse.md @@ -9,7 +9,7 @@ Name | Type | Description | Notes **aliases** | [**List[AssetAliasResponse]**](AssetAliasResponse.md) | | **consuming_tasks** | [**List[TaskInletAssetReference]**](TaskInletAssetReference.md) | | **created_at** | **datetime** | | -**extra** | **object** | | [optional] +**extra** | **Dict[str, object]** | | [optional] **group** | **str** | | **id** | **int** | | **last_asset_event** | [**LastAssetEventResponse**](LastAssetEventResponse.md) | | [optional] diff --git a/docs/BackfillApi.md b/docs/BackfillApi.md index 43bcacc6..3aa424fe 100644 --- a/docs/BackfillApi.md +++ b/docs/BackfillApi.md @@ -391,7 +391,7 @@ with airflow_client.client.ApiClient(configuration) as api_client: dag_id = 'dag_id_example' # str | limit = 50 # int | (optional) (default to 50) offset = 0 # int | (optional) (default to 0) - order_by = [id] # List[str] | (optional) (default to [id]) + order_by = ["id"] # List[str] | Attributes to order by, multi criteria sort is supported. Prefix with `-` for descending order. Supported attributes: `id` (optional) (default to ["id"]) try: # List Backfills @@ -412,7 +412,7 @@ Name | Type | Description | Notes **dag_id** | **str**| | **limit** | **int**| | [optional] [default to 50] **offset** | **int**| | [optional] [default to 0] - **order_by** | [**List[str]**](str.md)| | [optional] [default to [id]] + **order_by** | [**List[str]**](str.md)| Attributes to order by, multi criteria sort is supported. Prefix with `-` for descending order. Supported attributes: `id` | [optional] [default to ["id"]] ### Return type diff --git a/docs/ConnectionApi.md b/docs/ConnectionApi.md index 07e933ee..9f79a906 100644 --- a/docs/ConnectionApi.md +++ b/docs/ConnectionApi.md @@ -384,7 +384,7 @@ with airflow_client.client.ApiClient(configuration) as api_client: api_instance = airflow_client.client.ConnectionApi(api_client) limit = 50 # int | (optional) (default to 50) offset = 0 # int | (optional) (default to 0) - order_by = [id] # List[str] | (optional) (default to [id]) + order_by = ["id"] # List[str] | Attributes to order by, multi criteria sort is supported. Prefix with `-` for descending order. Supported attributes: `conn_id, conn_type, description, host, port, id, connection_id` (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) try: @@ -405,7 +405,7 @@ Name | Type | Description | Notes ------------- | ------------- | ------------- | ------------- **limit** | **int**| | [optional] [default to 50] **offset** | **int**| | [optional] [default to 0] - **order_by** | [**List[str]**](str.md)| | [optional] [default to [id]] + **order_by** | [**List[str]**](str.md)| Attributes to order by, multi criteria sort is supported. Prefix with `-` for descending order. Supported attributes: `conn_id, conn_type, description, host, port, id, connection_id` | [optional] [default to ["id"]] **connection_id_pattern** | **str**| SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). Regular expressions are **not** supported. | [optional] ### Return type diff --git a/docs/DAGApi.md b/docs/DAGApi.md index 2f3274c2..b6d59555 100644 --- a/docs/DAGApi.md +++ b/docs/DAGApi.md @@ -396,7 +396,7 @@ with airflow_client.client.ApiClient(configuration) as api_client: api_instance = airflow_client.client.DAGApi(api_client) limit = 50 # int | (optional) (default to 50) offset = 0 # int | (optional) (default to 0) - order_by = ["name"] # List[str] | (optional) (default to ["name"]) + order_by = ["name"] # List[str] | Attributes to order by, multi criteria sort is supported. Prefix with `-` for descending order. Supported attributes: `name` (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) try: @@ -417,7 +417,7 @@ Name | Type | Description | Notes ------------- | ------------- | ------------- | ------------- **limit** | **int**| | [optional] [default to 50] **offset** | **int**| | [optional] [default to 0] - **order_by** | [**List[str]**](str.md)| | [optional] [default to ["name"]] + **order_by** | [**List[str]**](str.md)| Attributes to order by, multi criteria sort is supported. Prefix with `-` for descending order. Supported attributes: `name` | [optional] [default to ["name"]] **tag_name_pattern** | **str**| SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). Regular expressions are **not** supported. | [optional] ### Return type @@ -509,7 +509,7 @@ with airflow_client.client.ApiClient(configuration) as api_client: dag_run_end_date_lte = '2013-10-20T19:20:30+01:00' # datetime | (optional) dag_run_end_date_lt = '2013-10-20T19:20:30+01:00' # datetime | (optional) dag_run_state = ['dag_run_state_example'] # List[str] | (optional) - order_by = [dag_id] # List[str] | (optional) (default to [dag_id]) + order_by = ["dag_id"] # List[str] | Attributes to order by, multi criteria sort is supported. Prefix with `-` for descending order. Supported attributes: `dag_id, dag_display_name, next_dagrun, state, start_date, last_run_state, last_run_start_date` (optional) (default to ["dag_id"]) is_favorite = True # bool | (optional) try: @@ -552,7 +552,7 @@ Name | Type | Description | Notes **dag_run_end_date_lte** | **datetime**| | [optional] **dag_run_end_date_lt** | **datetime**| | [optional] **dag_run_state** | [**List[str]**](str.md)| | [optional] - **order_by** | [**List[str]**](str.md)| | [optional] [default to [dag_id]] + **order_by** | [**List[str]**](str.md)| Attributes to order by, multi criteria sort is supported. Prefix with `-` for descending order. Supported attributes: `dag_id, dag_display_name, next_dagrun, state, start_date, last_run_state, last_run_start_date` | [optional] [default to ["dag_id"]] **is_favorite** | **bool**| | [optional] ### Return type diff --git a/docs/DAGDetailsResponse.md b/docs/DAGDetailsResponse.md index 5f607646..d04d2638 100644 --- a/docs/DAGDetailsResponse.md +++ b/docs/DAGDetailsResponse.md @@ -22,6 +22,7 @@ Name | Type | Description | Notes **fileloc** | **str** | | **has_import_errors** | **bool** | | **has_task_concurrency_limits** | **bool** | | +**is_favorite** | **bool** | | [optional] [default to False] **is_paused** | **bool** | | **is_paused_upon_creation** | **bool** | | [optional] **is_stale** | **bool** | | diff --git a/docs/DAGRunApi.md b/docs/DAGRunApi.md index fee40f2a..95e537f3 100644 --- a/docs/DAGRunApi.md +++ b/docs/DAGRunApi.md @@ -341,7 +341,7 @@ with airflow_client.client.ApiClient(configuration) as api_client: run_type = ['run_type_example'] # List[str] | (optional) state = ['state_example'] # List[str] | (optional) dag_version = [56] # List[int] | (optional) - order_by = [id] # List[str] | (optional) (default to [id]) + order_by = ["id"] # List[str] | Attributes to order by, multi criteria sort is supported. Prefix with `-` for descending order. Supported attributes: `id, state, dag_id, run_id, logical_date, run_after, start_date, end_date, updated_at, conf, duration, dag_run_id` (optional) (default to ["id"]) run_id_pattern = 'run_id_pattern_example' # str | SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). Regular expressions are **not** supported. (optional) triggering_user_name_pattern = 'triggering_user_name_pattern_example' # str | SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). Regular expressions are **not** supported. (optional) @@ -387,7 +387,7 @@ Name | Type | Description | Notes **run_type** | [**List[str]**](str.md)| | [optional] **state** | [**List[str]**](str.md)| | [optional] **dag_version** | [**List[int]**](int.md)| | [optional] - **order_by** | [**List[str]**](str.md)| | [optional] [default to [id]] + **order_by** | [**List[str]**](str.md)| Attributes to order by, multi criteria sort is supported. Prefix with `-` for descending order. Supported attributes: `id, state, dag_id, run_id, logical_date, run_after, start_date, end_date, updated_at, conf, duration, dag_run_id` | [optional] [default to ["id"]] **run_id_pattern** | **str**| SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). Regular expressions are **not** supported. | [optional] **triggering_user_name_pattern** | **str**| SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). Regular expressions are **not** supported. | [optional] diff --git a/docs/DagReportApi.md b/docs/DagReportApi.md deleted file mode 100644 index 0085a1a8..00000000 --- a/docs/DagReportApi.md +++ /dev/null @@ -1,93 +0,0 @@ -# airflow_client.client.DagReportApi - -All URIs are relative to *http://localhost* - -Method | HTTP request | Description -------------- | ------------- | ------------- -[**get_dag_reports**](DagReportApi.md#get_dag_reports) | **GET** /api/v2/dagReports | Get Dag Reports - - -# **get_dag_reports** -> object get_dag_reports(subdir) - -Get Dag Reports - -Get DAG report. - -### Example - -* OAuth Authentication (OAuth2PasswordBearer): -* Bearer Authentication (HTTPBearer): - -```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"] - -# Configure Bearer authorization: HTTPBearer -configuration = airflow_client.client.Configuration( - access_token = os.environ["BEARER_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.DagReportApi(api_client) - subdir = 'subdir_example' # str | - - try: - # Get Dag Reports - api_response = api_instance.get_dag_reports(subdir) - print("The response of DagReportApi->get_dag_reports:\n") - pprint(api_response) - except Exception as e: - print("Exception when calling DagReportApi->get_dag_reports: %s\n" % e) -``` - - - -### Parameters - - -Name | Type | Description | Notes -------------- | ------------- | ------------- | ------------- - **subdir** | **str**| | - -### Return type - -**object** - -### Authorization - -[OAuth2PasswordBearer](../README.md#OAuth2PasswordBearer), [HTTPBearer](../README.md#HTTPBearer) - -### 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 | - | -**422** | Validation Error | - | - -[[Back to top]](#) [[Back to API list]](../README.md#documentation-for-api-endpoints) [[Back to Model list]](../README.md#documentation-for-models) [[Back to README]](../README.md) - diff --git a/docs/DagVersionApi.md b/docs/DagVersionApi.md index 9368793c..a416294d 100644 --- a/docs/DagVersionApi.md +++ b/docs/DagVersionApi.md @@ -143,7 +143,7 @@ with airflow_client.client.ApiClient(configuration) as api_client: version_number = 56 # int | (optional) bundle_name = 'bundle_name_example' # str | (optional) bundle_version = 'bundle_version_example' # str | (optional) - order_by = [id] # List[str] | (optional) (default to [id]) + order_by = ["id"] # List[str] | Attributes to order by, multi criteria sort is supported. Prefix with `-` for descending order. Supported attributes: `id, version_number, bundle_name, bundle_version` (optional) (default to ["id"]) try: # Get Dag Versions @@ -167,7 +167,7 @@ Name | Type | Description | Notes **version_number** | **int**| | [optional] **bundle_name** | **str**| | [optional] **bundle_version** | **str**| | [optional] - **order_by** | [**List[str]**](str.md)| | [optional] [default to [id]] + **order_by** | [**List[str]**](str.md)| Attributes to order by, multi criteria sort is supported. Prefix with `-` for descending order. Supported attributes: `id, version_number, bundle_name, bundle_version` | [optional] [default to ["id"]] ### Return type diff --git a/docs/DagWarningApi.md b/docs/DagWarningApi.md index 70d3111e..c33c2174 100644 --- a/docs/DagWarningApi.md +++ b/docs/DagWarningApi.md @@ -52,7 +52,7 @@ with airflow_client.client.ApiClient(configuration) as api_client: warning_type = airflow_client.client.DagWarningType() # DagWarningType | (optional) limit = 50 # int | (optional) (default to 50) offset = 0 # int | (optional) (default to 0) - order_by = ["dag_id"] # List[str] | (optional) (default to ["dag_id"]) + order_by = ["dag_id"] # List[str] | Attributes to order by, multi criteria sort is supported. Prefix with `-` for descending order. Supported attributes: `dag_id, warning_type, message, timestamp` (optional) (default to ["dag_id"]) try: # List Dag Warnings @@ -74,7 +74,7 @@ Name | Type | Description | Notes **warning_type** | [**DagWarningType**](.md)| | [optional] **limit** | **int**| | [optional] [default to 50] **offset** | **int**| | [optional] [default to 0] - **order_by** | [**List[str]**](str.md)| | [optional] [default to ["dag_id"]] + **order_by** | [**List[str]**](str.md)| Attributes to order by, multi criteria sort is supported. Prefix with `-` for descending order. Supported attributes: `dag_id, warning_type, message, timestamp` | [optional] [default to ["dag_id"]] ### Return type diff --git a/docs/EventLogApi.md b/docs/EventLogApi.md index 558a1d17..28d19d2a 100644 --- a/docs/EventLogApi.md +++ b/docs/EventLogApi.md @@ -133,7 +133,7 @@ with airflow_client.client.ApiClient(configuration) as api_client: api_instance = airflow_client.client.EventLogApi(api_client) limit = 50 # int | (optional) (default to 50) offset = 0 # int | (optional) (default to 0) - order_by = [id] # List[str] | (optional) (default to [id]) + order_by = ["id"] # List[str] | Attributes to order by, multi criteria sort is supported. Prefix with `-` for descending order. Supported attributes: `id, dttm, dag_id, task_id, run_id, event, logical_date, owner, extra, when, event_log_id` (optional) (default to ["id"]) dag_id = 'dag_id_example' # str | (optional) task_id = 'task_id_example' # str | (optional) run_id = 'run_id_example' # str | (optional) @@ -169,7 +169,7 @@ Name | Type | Description | Notes ------------- | ------------- | ------------- | ------------- **limit** | **int**| | [optional] [default to 50] **offset** | **int**| | [optional] [default to 0] - **order_by** | [**List[str]**](str.md)| | [optional] [default to [id]] + **order_by** | [**List[str]**](str.md)| Attributes to order by, multi criteria sort is supported. Prefix with `-` for descending order. Supported attributes: `id, dttm, dag_id, task_id, run_id, event, logical_date, owner, extra, when, event_log_id` | [optional] [default to ["id"]] **dag_id** | **str**| | [optional] **task_id** | **str**| | [optional] **run_id** | **str**| | [optional] diff --git a/docs/EventLogResponse.md b/docs/EventLogResponse.md index 23df1147..a519020c 100644 --- a/docs/EventLogResponse.md +++ b/docs/EventLogResponse.md @@ -15,6 +15,7 @@ Name | Type | Description | Notes **map_index** | **int** | | [optional] **owner** | **str** | | [optional] **run_id** | **str** | | [optional] +**task_display_name** | **str** | | [optional] **task_id** | **str** | | [optional] **try_number** | **int** | | [optional] **when** | **datetime** | | diff --git a/docs/ImportErrorApi.md b/docs/ImportErrorApi.md index 943973a4..e08c87bd 100644 --- a/docs/ImportErrorApi.md +++ b/docs/ImportErrorApi.md @@ -135,7 +135,7 @@ with airflow_client.client.ApiClient(configuration) as api_client: api_instance = airflow_client.client.ImportErrorApi(api_client) limit = 50 # int | (optional) (default to 50) offset = 0 # int | (optional) (default to 0) - order_by = [id] # List[str] | (optional) (default to [id]) + order_by = ["id"] # List[str] | Attributes to order by, multi criteria sort is supported. Prefix with `-` for descending order. Supported attributes: `id, timestamp, filename, bundle_name, stacktrace, import_error_id` (optional) (default to ["id"]) filename_pattern = 'filename_pattern_example' # str | SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). Regular expressions are **not** supported. (optional) try: @@ -156,7 +156,7 @@ Name | Type | Description | Notes ------------- | ------------- | ------------- | ------------- **limit** | **int**| | [optional] [default to 50] **offset** | **int**| | [optional] [default to 0] - **order_by** | [**List[str]**](str.md)| | [optional] [default to [id]] + **order_by** | [**List[str]**](str.md)| Attributes to order by, multi criteria sort is supported. Prefix with `-` for descending order. Supported attributes: `id, timestamp, filename, bundle_name, stacktrace, import_error_id` | [optional] [default to ["id"]] **filename_pattern** | **str**| SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). Regular expressions are **not** supported. | [optional] ### Return type diff --git a/docs/JobApi.md b/docs/JobApi.md index f7be0f2c..9efc2e8a 100644 --- a/docs/JobApi.md +++ b/docs/JobApi.md @@ -58,7 +58,7 @@ with airflow_client.client.ApiClient(configuration) as api_client: end_date_lt = '2013-10-20T19:20:30+01:00' # datetime | (optional) limit = 50 # int | (optional) (default to 50) offset = 0 # int | (optional) (default to 0) - order_by = [id] # List[str] | (optional) (default to [id]) + order_by = ["id"] # List[str] | Attributes to order by, multi criteria sort is supported. Prefix with `-` for descending order. Supported attributes: `id, dag_id, state, job_type, start_date, end_date, latest_heartbeat, executor_class, hostname, unixname` (optional) (default to ["id"]) job_state = 'job_state_example' # str | (optional) job_type = 'job_type_example' # str | (optional) hostname = 'hostname_example' # str | (optional) @@ -91,7 +91,7 @@ Name | Type | Description | Notes **end_date_lt** | **datetime**| | [optional] **limit** | **int**| | [optional] [default to 50] **offset** | **int**| | [optional] [default to 0] - **order_by** | [**List[str]**](str.md)| | [optional] [default to [id]] + **order_by** | [**List[str]**](str.md)| Attributes to order by, multi criteria sort is supported. Prefix with `-` for descending order. Supported attributes: `id, dag_id, state, job_type, start_date, end_date, latest_heartbeat, executor_class, hostname, unixname` | [optional] [default to ["id"]] **job_state** | **str**| | [optional] **job_type** | **str**| | [optional] **hostname** | **str**| | [optional] diff --git a/docs/LoginApi.md b/docs/LoginApi.md index 12bc0744..196f047a 100644 --- a/docs/LoginApi.md +++ b/docs/LoginApi.md @@ -79,7 +79,7 @@ No authorization required [[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) # **logout** -> object logout(next=next) +> object logout() Logout @@ -104,11 +104,10 @@ configuration = airflow_client.client.Configuration( with airflow_client.client.ApiClient(configuration) as api_client: # Create an instance of the API class api_instance = airflow_client.client.LoginApi(api_client) - next = 'next_example' # str | (optional) try: # Logout - api_response = api_instance.logout(next=next) + api_response = api_instance.logout() print("The response of LoginApi->logout:\n") pprint(api_response) except Exception as e: @@ -119,10 +118,7 @@ with airflow_client.client.ApiClient(configuration) as api_client: ### Parameters - -Name | Type | Description | Notes -------------- | ------------- | ------------- | ------------- - **next** | **str**| | [optional] +This endpoint does not need any parameter. ### Return type @@ -143,7 +139,6 @@ No authorization required |-------------|-------------|------------------| **200** | Successful Response | - | **307** | Temporary Redirect | - | -**422** | Validation Error | - | [[Back to top]](#) [[Back to API list]](../README.md#documentation-for-api-endpoints) [[Back to Model list]](../README.md#documentation-for-models) [[Back to README]](../README.md) diff --git a/docs/PoolApi.md b/docs/PoolApi.md index 9d8aba97..641979fe 100644 --- a/docs/PoolApi.md +++ b/docs/PoolApi.md @@ -307,7 +307,7 @@ with airflow_client.client.ApiClient(configuration) as api_client: api_instance = airflow_client.client.PoolApi(api_client) limit = 50 # int | (optional) (default to 50) offset = 0 # int | (optional) (default to 0) - order_by = [id] # List[str] | (optional) (default to [id]) + order_by = ["id"] # List[str] | Attributes to order by, multi criteria sort is supported. Prefix with `-` for descending order. Supported attributes: `id, pool, name` (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) try: @@ -328,7 +328,7 @@ Name | Type | Description | Notes ------------- | ------------- | ------------- | ------------- **limit** | **int**| | [optional] [default to 50] **offset** | **int**| | [optional] [default to 0] - **order_by** | [**List[str]**](str.md)| | [optional] [default to [id]] + **order_by** | [**List[str]**](str.md)| Attributes to order by, multi criteria sort is supported. Prefix with `-` for descending order. Supported attributes: `id, pool, name` | [optional] [default to ["id"]] **pool_name_pattern** | **str**| SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). Regular expressions are **not** supported. | [optional] ### Return type diff --git a/docs/TaskInstanceApi.md b/docs/TaskInstanceApi.md index 991c449e..ae3c8f85 100644 --- a/docs/TaskInstanceApi.md +++ b/docs/TaskInstanceApi.md @@ -529,7 +529,7 @@ with airflow_client.client.ApiClient(configuration) as api_client: dag_run_id = 'dag_run_id_example' # str | limit = 50 # int | (optional) (default to 50) offset = 0 # int | (optional) (default to 0) - order_by = ["ti_id"] # List[str] | (optional) (default to ["ti_id"]) + order_by = ["ti_id"] # List[str] | Attributes to order by, multi criteria sort is supported. Prefix with `-` for descending order. Supported attributes: `ti_id, subject, responded_at, created_at, responded_by_user_id, responded_by_user_name, dag_id, run_id, run_after, rendered_map_index, task_instance_operator, task_instance_state` (optional) (default to ["ti_id"]) dag_id_pattern = 'dag_id_pattern_example' # str | SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). Regular expressions are **not** supported. (optional) task_id = 'task_id_example' # str | (optional) task_id_pattern = 'task_id_pattern_example' # str | SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). Regular expressions are **not** supported. (optional) @@ -565,7 +565,7 @@ Name | Type | Description | Notes **dag_run_id** | **str**| | **limit** | **int**| | [optional] [default to 50] **offset** | **int**| | [optional] [default to 0] - **order_by** | [**List[str]**](str.md)| | [optional] [default to ["ti_id"]] + **order_by** | [**List[str]**](str.md)| Attributes to order by, multi criteria sort is supported. Prefix with `-` for descending order. Supported attributes: `ti_id, subject, responded_at, created_at, responded_by_user_id, responded_by_user_name, dag_id, run_id, run_after, rendered_map_index, task_instance_operator, task_instance_state` | [optional] [default to ["ti_id"]] **dag_id_pattern** | **str**| SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). Regular expressions are **not** supported. | [optional] **task_id** | **str**| | [optional] **task_id_pattern** | **str**| SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). Regular expressions are **not** supported. | [optional] @@ -1052,7 +1052,7 @@ with airflow_client.client.ApiClient(configuration) as api_client: map_index = [56] # List[int] | (optional) limit = 50 # int | (optional) (default to 50) offset = 0 # int | (optional) (default to 0) - order_by = [map_index] # List[str] | (optional) (default to [map_index]) + order_by = ["map_index"] # List[str] | Attributes to order by, multi criteria sort is supported. Prefix with `-` for descending order. Supported attributes: `id, state, duration, start_date, end_date, map_index, try_number, logical_date, run_after, data_interval_start, data_interval_end, rendered_map_index, operator, run_after, logical_date, data_interval_start, data_interval_end` (optional) (default to ["map_index"]) try: # Get Mapped Task Instances @@ -1107,7 +1107,7 @@ Name | Type | Description | Notes **map_index** | [**List[int]**](int.md)| | [optional] **limit** | **int**| | [optional] [default to 50] **offset** | **int**| | [optional] [default to 0] - **order_by** | [**List[str]**](str.md)| | [optional] [default to [map_index]] + **order_by** | [**List[str]**](str.md)| Attributes to order by, multi criteria sort is supported. Prefix with `-` for descending order. Supported attributes: `id, state, duration, start_date, end_date, map_index, try_number, logical_date, run_after, data_interval_start, data_interval_end, rendered_map_index, operator, run_after, logical_date, data_interval_start, data_interval_end` | [optional] [default to ["map_index"]] ### Return type @@ -1670,7 +1670,7 @@ with airflow_client.client.ApiClient(configuration) as api_client: map_index = [56] # List[int] | (optional) limit = 50 # int | (optional) (default to 50) offset = 0 # int | (optional) (default to 0) - order_by = ["map_index"] # List[str] | (optional) (default to ["map_index"]) + order_by = ["map_index"] # List[str] | Attributes to order by, multi criteria sort is supported. Prefix with `-` for descending order. Supported attributes: `id, state, duration, start_date, end_date, map_index, try_number, logical_date, run_after, data_interval_start, data_interval_end, rendered_map_index, operator, logical_date, run_after, data_interval_start, data_interval_end` (optional) (default to ["map_index"]) try: # Get Task Instances @@ -1726,7 +1726,7 @@ Name | Type | Description | Notes **map_index** | [**List[int]**](int.md)| | [optional] **limit** | **int**| | [optional] [default to 50] **offset** | **int**| | [optional] [default to 0] - **order_by** | [**List[str]**](str.md)| | [optional] [default to ["map_index"]] + **order_by** | [**List[str]**](str.md)| Attributes to order by, multi criteria sort is supported. Prefix with `-` for descending order. Supported attributes: `id, state, duration, start_date, end_date, map_index, try_number, logical_date, run_after, data_interval_start, data_interval_end, rendered_map_index, operator, logical_date, run_after, data_interval_start, data_interval_end` | [optional] [default to ["map_index"]] ### Return type diff --git a/docs/VariableApi.md b/docs/VariableApi.md index d7a77765..fd74b14c 100644 --- a/docs/VariableApi.md +++ b/docs/VariableApi.md @@ -306,7 +306,7 @@ with airflow_client.client.ApiClient(configuration) as api_client: api_instance = airflow_client.client.VariableApi(api_client) limit = 50 # int | (optional) (default to 50) offset = 0 # int | (optional) (default to 0) - order_by = [id] # List[str] | (optional) (default to [id]) + order_by = ["id"] # List[str] | Attributes to order by, multi criteria sort is supported. Prefix with `-` for descending order. Supported attributes: `key, id, _val, description, is_encrypted` (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) try: @@ -327,7 +327,7 @@ Name | Type | Description | Notes ------------- | ------------- | ------------- | ------------- **limit** | **int**| | [optional] [default to 50] **offset** | **int**| | [optional] [default to 0] - **order_by** | [**List[str]**](str.md)| | [optional] [default to [id]] + **order_by** | [**List[str]**](str.md)| Attributes to order by, multi criteria sort is supported. Prefix with `-` for descending order. Supported attributes: `key, id, _val, description, is_encrypted` | [optional] [default to ["id"]] **variable_key_pattern** | **str**| SQL LIKE expression — use `%` / `_` wildcards (e.g. `%customer_%`). Regular expressions are **not** supported. | [optional] ### Return type diff --git a/pyproject.toml b/pyproject.toml index 1692d6f7..a7a22811 100644 --- a/pyproject.toml +++ b/pyproject.toml @@ -24,7 +24,8 @@ name = "apache-airflow-client" dynamic = ["version"] description = "Apache Airflow API (Stable)" readme = "README.md" -license-files.globs = ["LICENSE", "NOTICE"] +license = "Apache-2.0" +license-files = ["LICENSE", "NOTICE"] requires-python = ">=3.10" authors = [ { name = "Apache Software Foundation", email = "dev@airflow.apache.org" }, @@ -41,7 +42,6 @@ classifiers = [ "Framework :: Apache Airflow", "Intended Audience :: Developers", "Intended Audience :: System Administrators", - "License :: OSI Approved :: Apache Software License", "Programming Language :: Python :: 3.10", "Programming Language :: Python :: 3.11", "Programming Language :: Python :: 3.12", diff --git a/spec/v2.yaml b/spec/v2.yaml index 6c2522e1..45d7209d 100644 --- a/spec/v2.yaml +++ b/spec/v2.yaml @@ -114,7 +114,8 @@ components: title: Created Dagruns type: array extra: - additionalProperties: true + additionalProperties: + $ref: '#/components/schemas/JsonValue' nullable: true type: object group: @@ -171,7 +172,8 @@ components: title: Created At type: string extra: - additionalProperties: true + additionalProperties: + $ref: '#/components/schemas/JsonValue' nullable: true type: object group: @@ -1091,6 +1093,10 @@ components: has_task_concurrency_limits: title: Has Task Concurrency Limits type: boolean + is_favorite: + default: false + title: Is Favorite + type: boolean is_paused: title: Is Paused type: boolean @@ -1952,6 +1958,9 @@ components: run_id: nullable: true type: string + task_display_name: + nullable: true + type: string task_id: nullable: true type: string @@ -3843,12 +3852,18 @@ paths: default: true title: Only Active type: boolean - - in: query + - description: 'Attributes to order by, multi criteria sort is supported. Prefix + with `-` for descending order. Supported attributes: `id, name, uri, created_at, + updated_at`' + in: query name: order_by required: false schema: default: - id + description: 'Attributes to order by, multi criteria sort is supported. + Prefix with `-` for descending order. Supported attributes: `id, name, + uri, created_at, updated_at`' items: type: string title: Order By @@ -3919,12 +3934,16 @@ paths: schema: nullable: true type: string - - in: query + - description: 'Attributes to order by, multi criteria sort is supported. Prefix + with `-` for descending order. Supported attributes: `id, name`' + in: query name: order_by required: false schema: default: - id + description: 'Attributes to order by, multi criteria sort is supported. + Prefix with `-` for descending order. Supported attributes: `id, name`' items: type: string title: Order By @@ -4034,12 +4053,18 @@ paths: minimum: 0 title: Offset type: integer - - in: query + - description: 'Attributes to order by, multi criteria sort is supported. Prefix + with `-` for descending order. Supported attributes: `source_task_id, source_dag_id, + source_run_id, source_map_index, timestamp`' + in: query name: order_by required: false schema: default: - timestamp + description: 'Attributes to order by, multi criteria sort is supported. + Prefix with `-` for descending order. Supported attributes: `source_task_id, + source_dag_id, source_run_id, source_map_index, timestamp`' items: type: string title: Order By @@ -4426,13 +4451,6 @@ paths: get: description: Logout the user. operationId: logout - parameters: - - in: query - name: next - required: false - schema: - nullable: true - type: string responses: '200': content: @@ -4445,12 +4463,6 @@ paths: schema: $ref: '#/components/schemas/HTTPExceptionResponse' description: Temporary Redirect - '422': - content: - application/json: - schema: - $ref: '#/components/schemas/HTTPValidationError' - description: Validation Error summary: Logout tags: - Login @@ -4512,12 +4524,16 @@ paths: minimum: 0 title: Offset type: integer - - in: query + - description: 'Attributes to order by, multi criteria sort is supported. Prefix + with `-` for descending order. Supported attributes: `id`' + in: query name: order_by required: false schema: default: - id + description: 'Attributes to order by, multi criteria sort is supported. + Prefix with `-` for descending order. Supported attributes: `id`' items: type: string title: Order By @@ -5048,12 +5064,18 @@ paths: minimum: 0 title: Offset type: integer - - in: query + - description: 'Attributes to order by, multi criteria sort is supported. Prefix + with `-` for descending order. Supported attributes: `conn_id, conn_type, + description, host, port, id, connection_id`' + in: query name: order_by required: false schema: default: - id + description: 'Attributes to order by, multi criteria sort is supported. + Prefix with `-` for descending order. Supported attributes: `conn_id, + conn_type, description, host, port, id, connection_id`' items: type: string title: Order By @@ -5422,53 +5444,6 @@ paths: summary: Patch Connection tags: - Connection - /api/v2/dagReports: - get: - description: Get DAG report. - operationId: get_dag_reports - parameters: - - in: query - name: subdir - required: true - schema: - title: Subdir - type: string - responses: - '200': - content: - application/json: - schema: {} - 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 - '422': - content: - application/json: - schema: - $ref: '#/components/schemas/HTTPValidationError' - description: Validation Error - security: - - OAuth2PasswordBearer: [] - - HTTPBearer: [] - summary: Get Dag Reports - tags: - - DagReport /api/v2/dagSources/{dag_id}: get: description: Get source code using file token. @@ -5627,12 +5602,16 @@ paths: minimum: 0 title: Offset type: integer - - in: query + - description: 'Attributes to order by, multi criteria sort is supported. Prefix + with `-` for descending order. Supported attributes: `name`' + in: query name: order_by required: false schema: default: - name + description: 'Attributes to order by, multi criteria sort is supported. + Prefix with `-` for descending order. Supported attributes: `name`' items: type: string title: Order By @@ -5709,12 +5688,18 @@ paths: minimum: 0 title: Offset type: integer - - in: query + - description: 'Attributes to order by, multi criteria sort is supported. Prefix + with `-` for descending order. Supported attributes: `dag_id, warning_type, + message, timestamp`' + in: query name: order_by required: false schema: default: - dag_id + description: 'Attributes to order by, multi criteria sort is supported. + Prefix with `-` for descending order. Supported attributes: `dag_id, warning_type, + message, timestamp`' items: type: string title: Order By @@ -5929,12 +5914,18 @@ paths: type: string title: Dag Run State type: array - - in: query + - description: 'Attributes to order by, multi criteria sort is supported. Prefix + with `-` for descending order. Supported attributes: `dag_id, dag_display_name, + next_dagrun, state, start_date, last_run_state, last_run_start_date`' + in: query name: order_by required: false schema: default: - dag_id + description: 'Attributes to order by, multi criteria sort is supported. + Prefix with `-` for descending order. Supported attributes: `dag_id, dag_display_name, + next_dagrun, state, start_date, last_run_state, last_run_start_date`' items: type: string title: Order By @@ -6750,12 +6741,20 @@ paths: type: integer title: Dag Version type: array - - in: query + - description: 'Attributes to order by, multi criteria sort is supported. Prefix + with `-` for descending order. Supported attributes: `id, state, dag_id, + run_id, logical_date, run_after, start_date, end_date, updated_at, conf, + duration, dag_run_id`' + in: query name: order_by required: false schema: default: - id + description: 'Attributes to order by, multi criteria sort is supported. + Prefix with `-` for descending order. Supported attributes: `id, state, + dag_id, run_id, logical_date, run_after, start_date, end_date, updated_at, + conf, duration, dag_run_id`' items: type: string title: Order By @@ -7208,12 +7207,21 @@ paths: minimum: 0 title: Offset type: integer - - in: query + - description: 'Attributes to order by, multi criteria sort is supported. Prefix + with `-` for descending order. Supported attributes: `ti_id, subject, responded_at, + created_at, responded_by_user_id, responded_by_user_name, dag_id, run_id, + run_after, rendered_map_index, task_instance_operator, task_instance_state`' + in: query name: order_by required: false schema: default: - ti_id + description: 'Attributes to order by, multi criteria sort is supported. + Prefix with `-` for descending order. Supported attributes: `ti_id, subject, + responded_at, created_at, responded_by_user_id, responded_by_user_name, + dag_id, run_id, run_after, rendered_map_index, task_instance_operator, + task_instance_state`' items: type: string title: Order By @@ -7632,12 +7640,22 @@ paths: minimum: 0 title: Offset type: integer - - in: query + - description: 'Attributes to order by, multi criteria sort is supported. Prefix + with `-` for descending order. Supported attributes: `id, state, duration, + start_date, end_date, map_index, try_number, logical_date, run_after, data_interval_start, + data_interval_end, rendered_map_index, operator, logical_date, run_after, + data_interval_start, data_interval_end`' + in: query name: order_by required: false schema: default: - map_index + description: 'Attributes to order by, multi criteria sort is supported. + Prefix with `-` for descending order. Supported attributes: `id, state, + duration, start_date, end_date, map_index, try_number, logical_date, run_after, + data_interval_start, data_interval_end, rendered_map_index, operator, + logical_date, run_after, data_interval_start, data_interval_end`' items: type: string title: Order By @@ -8578,12 +8596,22 @@ paths: minimum: 0 title: Offset type: integer - - in: query + - description: 'Attributes to order by, multi criteria sort is supported. Prefix + with `-` for descending order. Supported attributes: `id, state, duration, + start_date, end_date, map_index, try_number, logical_date, run_after, data_interval_start, + data_interval_end, rendered_map_index, operator, run_after, logical_date, + data_interval_start, data_interval_end`' + in: query name: order_by required: false schema: default: - map_index + description: 'Attributes to order by, multi criteria sort is supported. + Prefix with `-` for descending order. Supported attributes: `id, state, + duration, start_date, end_date, map_index, try_number, logical_date, run_after, + data_interval_start, data_interval_end, rendered_map_index, operator, + run_after, logical_date, data_interval_start, data_interval_end`' items: type: string title: Order By @@ -10084,12 +10112,18 @@ paths: schema: nullable: true type: string - - in: query + - description: 'Attributes to order by, multi criteria sort is supported. Prefix + with `-` for descending order. Supported attributes: `id, version_number, + bundle_name, bundle_version`' + in: query name: order_by required: false schema: default: - id + description: 'Attributes to order by, multi criteria sort is supported. + Prefix with `-` for descending order. Supported attributes: `id, version_number, + bundle_name, bundle_version`' items: type: string title: Order By @@ -10474,12 +10508,18 @@ paths: minimum: 0 title: Offset type: integer - - in: query + - description: 'Attributes to order by, multi criteria sort is supported. Prefix + with `-` for descending order. Supported attributes: `id, dttm, dag_id, + task_id, run_id, event, logical_date, owner, extra, when, event_log_id`' + in: query name: order_by required: false schema: default: - id + description: 'Attributes to order by, multi criteria sort is supported. + Prefix with `-` for descending order. Supported attributes: `id, dttm, + dag_id, task_id, run_id, event, logical_date, owner, extra, when, event_log_id`' items: type: string title: Order By @@ -10695,12 +10735,18 @@ paths: minimum: 0 title: Offset type: integer - - in: query + - description: 'Attributes to order by, multi criteria sort is supported. Prefix + with `-` for descending order. Supported attributes: `id, timestamp, filename, + bundle_name, stacktrace, import_error_id`' + in: query name: order_by required: false schema: default: - id + description: 'Attributes to order by, multi criteria sort is supported. + Prefix with `-` for descending order. Supported attributes: `id, timestamp, + filename, bundle_name, stacktrace, import_error_id`' items: type: string title: Order By @@ -10875,12 +10921,20 @@ paths: minimum: 0 title: Offset type: integer - - in: query + - description: 'Attributes to order by, multi criteria sort is supported. Prefix + with `-` for descending order. Supported attributes: `id, dag_id, state, + job_type, start_date, end_date, latest_heartbeat, executor_class, hostname, + unixname`' + in: query name: order_by required: false schema: default: - id + description: 'Attributes to order by, multi criteria sort is supported. + Prefix with `-` for descending order. Supported attributes: `id, dag_id, + state, job_type, start_date, end_date, latest_heartbeat, executor_class, + hostname, unixname`' items: type: string title: Order By @@ -11106,12 +11160,17 @@ paths: minimum: 0 title: Offset type: integer - - in: query + - description: 'Attributes to order by, multi criteria sort is supported. Prefix + with `-` for descending order. Supported attributes: `id, pool, name`' + in: query name: order_by required: false schema: default: - id + description: 'Attributes to order by, multi criteria sort is supported. + Prefix with `-` for descending order. Supported attributes: `id, pool, + name`' items: type: string title: Order By @@ -11484,12 +11543,18 @@ paths: minimum: 0 title: Offset type: integer - - in: query + - description: 'Attributes to order by, multi criteria sort is supported. Prefix + with `-` for descending order. Supported attributes: `key, id, _val, description, + is_encrypted`' + in: query name: order_by required: false schema: default: - id + description: 'Attributes to order by, multi criteria sort is supported. + Prefix with `-` for descending order. Supported attributes: `key, id, + _val, description, is_encrypted`' items: type: string title: Order By diff --git a/test/test_asset_collection_response.py b/test/test_asset_collection_response.py index 8f5416e7..01451730 100644 --- a/test/test_asset_collection_response.py +++ b/test/test_asset_collection_response.py @@ -51,7 +51,9 @@ def make_instance(self, include_optional) -> AssetCollectionResponse: updated_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'), - extra = airflow_client.client.models.extra.extra(), + extra = { + 'key' : null + }, group = '', id = 56, last_asset_event = airflow_client.client.models.last_asset_event_response.LastAssetEventResponse( @@ -94,7 +96,9 @@ def make_instance(self, include_optional) -> AssetCollectionResponse: updated_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'), - extra = airflow_client.client.models.extra.extra(), + extra = { + 'key' : null + }, group = '', id = 56, last_asset_event = airflow_client.client.models.last_asset_event_response.LastAssetEventResponse( diff --git a/test/test_asset_event_collection_response.py b/test/test_asset_event_collection_response.py index 315165ca..596fe733 100644 --- a/test/test_asset_event_collection_response.py +++ b/test/test_asset_event_collection_response.py @@ -49,7 +49,9 @@ def make_instance(self, include_optional) -> AssetEventCollectionResponse: start_date = datetime.datetime.strptime('2013-10-20 19:20:30.00', '%Y-%m-%d %H:%M:%S.%f'), state = '', ) ], - extra = airflow_client.client.models.extra.extra(), + extra = { + 'key' : null + }, group = '', id = 56, name = '', @@ -78,7 +80,9 @@ def make_instance(self, include_optional) -> AssetEventCollectionResponse: start_date = datetime.datetime.strptime('2013-10-20 19:20:30.00', '%Y-%m-%d %H:%M:%S.%f'), state = '', ) ], - extra = airflow_client.client.models.extra.extra(), + extra = { + 'key' : null + }, group = '', id = 56, name = '', diff --git a/test/test_asset_event_response.py b/test/test_asset_event_response.py index 84f96357..4ee85129 100644 --- a/test/test_asset_event_response.py +++ b/test/test_asset_event_response.py @@ -47,7 +47,9 @@ def make_instance(self, include_optional) -> AssetEventResponse: start_date = datetime.datetime.strptime('2013-10-20 19:20:30.00', '%Y-%m-%d %H:%M:%S.%f'), state = '', ) ], - extra = airflow_client.client.models.extra.extra(), + extra = { + 'key' : null + }, group = '', id = 56, name = '', diff --git a/test/test_asset_response.py b/test/test_asset_response.py index a9788cfe..96936c5e 100644 --- a/test/test_asset_response.py +++ b/test/test_asset_response.py @@ -49,7 +49,9 @@ def make_instance(self, include_optional) -> AssetResponse: updated_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'), - extra = airflow_client.client.models.extra.extra(), + extra = { + 'key' : null + }, group = '', id = 56, last_asset_event = airflow_client.client.models.last_asset_event_response.LastAssetEventResponse( diff --git a/test/test_dag_details_response.py b/test/test_dag_details_response.py index 87509a85..8473cc7e 100644 --- a/test/test_dag_details_response.py +++ b/test/test_dag_details_response.py @@ -35,7 +35,7 @@ def make_instance(self, include_optional) -> DAGDetailsResponse: model = DAGDetailsResponse() if include_optional: return DAGDetailsResponse( - asset_expression = airflow_client.client.models.extra.extra(), + asset_expression = None, bundle_name = '', bundle_version = '', catchup = True, @@ -43,7 +43,7 @@ def make_instance(self, include_optional) -> DAGDetailsResponse: dag_display_name = '', dag_id = '', dag_run_timeout = '', - default_args = airflow_client.client.models.extra.extra(), + default_args = None, description = '', doc_md = '', end_date = datetime.datetime.strptime('2013-10-20 19:20:30.00', '%Y-%m-%d %H:%M:%S.%f'), @@ -51,6 +51,7 @@ def make_instance(self, include_optional) -> DAGDetailsResponse: fileloc = '', has_import_errors = True, has_task_concurrency_limits = True, + is_favorite = True, is_paused = True, is_paused_upon_creation = True, is_stale = True, @@ -80,7 +81,7 @@ def make_instance(self, include_optional) -> DAGDetailsResponse: owners = [ '' ], - params = airflow_client.client.models.extra.extra(), + params = None, relative_fileloc = '', render_template_as_native_obj = True, start_date = datetime.datetime.strptime('2013-10-20 19:20:30.00', '%Y-%m-%d %H:%M:%S.%f'), diff --git a/test/test_dag_report_api.py b/test/test_dag_report_api.py deleted file mode 100644 index 39bd169d..00000000 --- a/test/test_dag_report_api.py +++ /dev/null @@ -1,38 +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.api.dag_report_api import DagReportApi - - -class TestDagReportApi(unittest.TestCase): - """DagReportApi unit test stubs""" - - def setUp(self) -> None: - self.api = DagReportApi() - - def tearDown(self) -> None: - pass - - def test_get_dag_reports(self) -> None: - """Test case for get_dag_reports - - Get Dag Reports - """ - pass - - -if __name__ == '__main__': - unittest.main() diff --git a/test/test_dag_run_collection_response.py b/test/test_dag_run_collection_response.py index 04877f41..26f8fa17 100644 --- a/test/test_dag_run_collection_response.py +++ b/test/test_dag_run_collection_response.py @@ -38,7 +38,7 @@ def make_instance(self, include_optional) -> DAGRunCollectionResponse: dag_runs = [ airflow_client.client.models.dag_run_response.DAGRunResponse( bundle_version = '', - conf = airflow_client.client.models.extra.extra(), + conf = airflow_client.client.models.conf.conf(), dag_display_name = '', dag_id = '', dag_run_id = '', @@ -75,7 +75,7 @@ def make_instance(self, include_optional) -> DAGRunCollectionResponse: dag_runs = [ airflow_client.client.models.dag_run_response.DAGRunResponse( bundle_version = '', - conf = airflow_client.client.models.extra.extra(), + conf = airflow_client.client.models.conf.conf(), dag_display_name = '', dag_id = '', dag_run_id = '', diff --git a/test/test_dag_run_response.py b/test/test_dag_run_response.py index 7e378974..ce41ee35 100644 --- a/test/test_dag_run_response.py +++ b/test/test_dag_run_response.py @@ -36,7 +36,7 @@ def make_instance(self, include_optional) -> DAGRunResponse: if include_optional: return DAGRunResponse( bundle_version = '', - conf = airflow_client.client.models.extra.extra(), + conf = airflow_client.client.models.conf.conf(), dag_display_name = '', dag_id = '', dag_run_id = '', diff --git a/test/test_event_log_collection_response.py b/test/test_event_log_collection_response.py index 2c8cc35f..99d1a239 100644 --- a/test/test_event_log_collection_response.py +++ b/test/test_event_log_collection_response.py @@ -46,6 +46,7 @@ def make_instance(self, include_optional) -> EventLogCollectionResponse: map_index = 56, owner = '', run_id = '', + task_display_name = '', task_id = '', try_number = 56, when = datetime.datetime.strptime('2013-10-20 19:20:30.00', '%Y-%m-%d %H:%M:%S.%f'), ) @@ -65,6 +66,7 @@ def make_instance(self, include_optional) -> EventLogCollectionResponse: map_index = 56, owner = '', run_id = '', + task_display_name = '', task_id = '', try_number = 56, when = datetime.datetime.strptime('2013-10-20 19:20:30.00', '%Y-%m-%d %H:%M:%S.%f'), ) diff --git a/test/test_event_log_response.py b/test/test_event_log_response.py index 47e0e6f4..320cb7e4 100644 --- a/test/test_event_log_response.py +++ b/test/test_event_log_response.py @@ -44,6 +44,7 @@ def make_instance(self, include_optional) -> EventLogResponse: map_index = 56, owner = '', run_id = '', + task_display_name = '', task_id = '', try_number = 56, when = datetime.datetime.strptime('2013-10-20 19:20:30.00', '%Y-%m-%d %H:%M:%S.%f') diff --git a/test/test_response_clear_dag_run.py b/test/test_response_clear_dag_run.py index c7f50f8f..a036ab8e 100644 --- a/test/test_response_clear_dag_run.py +++ b/test/test_response_clear_dag_run.py @@ -97,7 +97,7 @@ def make_instance(self, include_optional) -> ResponseClearDagRun: ], total_entries = 56, bundle_version = '', - conf = airflow_client.client.models.extra.extra(), + conf = airflow_client.client.models.conf.conf(), dag_display_name = '', dag_id = '', dag_run_id = '', diff --git a/test/test_task_collection_response.py b/test/test_task_collection_response.py index 197e8e7f..1a1653ab 100644 --- a/test/test_task_collection_response.py +++ b/test/test_task_collection_response.py @@ -37,7 +37,7 @@ def make_instance(self, include_optional) -> TaskCollectionResponse: return TaskCollectionResponse( tasks = [ airflow_client.client.models.task_response.TaskResponse( - class_ref = airflow_client.client.models.extra.extra(), + class_ref = airflow_client.client.models.conf.conf(), depends_on_past = True, doc_md = '', downstream_task_ids = [ @@ -55,7 +55,7 @@ def make_instance(self, include_optional) -> TaskCollectionResponse: is_mapped = True, operator_name = '', owner = '', - params = airflow_client.client.models.extra.extra(), + params = airflow_client.client.models.conf.conf(), pool = '', pool_slots = 1.337, priority_weight = 1.337, @@ -85,7 +85,7 @@ def make_instance(self, include_optional) -> TaskCollectionResponse: return TaskCollectionResponse( tasks = [ airflow_client.client.models.task_response.TaskResponse( - class_ref = airflow_client.client.models.extra.extra(), + class_ref = airflow_client.client.models.conf.conf(), depends_on_past = True, doc_md = '', downstream_task_ids = [ @@ -103,7 +103,7 @@ def make_instance(self, include_optional) -> TaskCollectionResponse: is_mapped = True, operator_name = '', owner = '', - params = airflow_client.client.models.extra.extra(), + params = airflow_client.client.models.conf.conf(), pool = '', pool_slots = 1.337, priority_weight = 1.337, diff --git a/test/test_task_response.py b/test/test_task_response.py index 6309a986..1997500d 100644 --- a/test/test_task_response.py +++ b/test/test_task_response.py @@ -35,7 +35,7 @@ def make_instance(self, include_optional) -> TaskResponse: model = TaskResponse() if include_optional: return TaskResponse( - class_ref = airflow_client.client.models.extra.extra(), + class_ref = airflow_client.client.models.conf.conf(), depends_on_past = True, doc_md = '', downstream_task_ids = [ @@ -53,7 +53,7 @@ def make_instance(self, include_optional) -> TaskResponse: is_mapped = True, operator_name = '', owner = '', - params = airflow_client.client.models.extra.extra(), + params = airflow_client.client.models.conf.conf(), pool = '', pool_slots = 1.337, priority_weight = 1.337, diff --git a/test/test_trigger_dag_run_post_body.py b/test/test_trigger_dag_run_post_body.py index bfedbd50..81c1f272 100644 --- a/test/test_trigger_dag_run_post_body.py +++ b/test/test_trigger_dag_run_post_body.py @@ -35,7 +35,7 @@ def make_instance(self, include_optional) -> TriggerDAGRunPostBody: model = TriggerDAGRunPostBody() if include_optional: return TriggerDAGRunPostBody( - conf = airflow_client.client.models.extra.extra(), + conf = airflow_client.client.models.conf.conf(), dag_run_id = '', data_interval_end = datetime.datetime.strptime('2013-10-20 19:20:30.00', '%Y-%m-%d %H:%M:%S.%f'), data_interval_start = datetime.datetime.strptime('2013-10-20 19:20:30.00', '%Y-%m-%d %H:%M:%S.%f'), diff --git a/version.txt b/version.txt index a0cd9f0c..ff365e06 100644 --- a/version.txt +++ b/version.txt @@ -1 +1 @@ -3.1.0 \ No newline at end of file +3.1.3