This is an automated email from the ASF dual-hosted git repository.
ephraimanierobi pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/airflow-client-python.git
The following commit(s) were added to refs/heads/main by this push:
new f8859b0 Update Python Client to 3.1.4rc1 (#141)
f8859b0 is described below
commit f8859b08bb72b2cbf5d78189155fe910971a7fd5
Author: Ephraim Anierobi <[email protected]>
AuthorDate: Thu Dec 11 17:44:19 2025 +0100
Update Python Client to 3.1.4rc1 (#141)
---
CHANGELOG.md | 7 +
airflow_client/client/__init__.py | 2 +-
airflow_client/client/api/login_api.py | 268 ---------------------------------
airflow_client/client/api_client.py | 2 +-
airflow_client/client/configuration.py | 2 +-
docs/LoginApi.md | 70 ---------
pyproject.toml | 9 +-
spec/v2.yaml | 32 ----
test/test_login_api.py | 7 -
version.txt | 2 +-
10 files changed, 18 insertions(+), 383 deletions(-)
diff --git a/CHANGELOG.md b/CHANGELOG.md
index e0d7a18..095211f 100644
--- a/CHANGELOG.md
+++ b/CHANGELOG.md
@@ -17,6 +17,13 @@
under the License.
-->
+# v3.1.4
+
+## Bug Fixes:
+
+ - Update refresh token flow
([#55506](https://github.com/apache/airflow/pull/55506))
+ - Patch pools should have an optional description
([#58066](https://github.com/apache/airflow/pull/58066))
+
# v3.1.3
## New Features:
diff --git a/airflow_client/client/__init__.py
b/airflow_client/client/__init__.py
index 25c3d1a..b47b50a 100644
--- a/airflow_client/client/__init__.py
+++ b/airflow_client/client/__init__.py
@@ -14,7 +14,7 @@
""" # noqa: E501
-__version__ = "3.1.3"
+__version__ = "3.1.4"
# import apis into sdk package
from airflow_client.client.api.asset_api import AssetApi
diff --git a/airflow_client/client/api/login_api.py
b/airflow_client/client/api/login_api.py
index 80fc67e..21ad044 100644
--- a/airflow_client/client/api/login_api.py
+++ b/airflow_client/client/api/login_api.py
@@ -551,271 +551,3 @@ class LoginApi:
)
-
-
- @validate_call
- def refresh(
- self,
- next: Optional[StrictStr] = None,
- _request_timeout: Union[
- None,
- Annotated[StrictFloat, Field(gt=0)],
- Tuple[
- Annotated[StrictFloat, Field(gt=0)],
- Annotated[StrictFloat, Field(gt=0)]
- ]
- ] = None,
- _request_auth: Optional[Dict[StrictStr, Any]] = None,
- _content_type: Optional[StrictStr] = None,
- _headers: Optional[Dict[StrictStr, Any]] = None,
- _host_index: Annotated[StrictInt, Field(ge=0, le=0)] = 0,
- ) -> object:
- """Refresh
-
- Refresh the authentication token.
-
- :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
- (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._refresh_serialize(
- next=next,
- _request_auth=_request_auth,
- _content_type=_content_type,
- _headers=_headers,
- _host_index=_host_index
- )
-
- _response_types_map: Dict[str, Optional[str]] = {
- '200': "object",
- '307': "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 refresh_with_http_info(
- self,
- next: Optional[StrictStr] = None,
- _request_timeout: Union[
- None,
- Annotated[StrictFloat, Field(gt=0)],
- Tuple[
- Annotated[StrictFloat, Field(gt=0)],
- Annotated[StrictFloat, Field(gt=0)]
- ]
- ] = None,
- _request_auth: Optional[Dict[StrictStr, Any]] = None,
- _content_type: Optional[StrictStr] = None,
- _headers: Optional[Dict[StrictStr, Any]] = None,
- _host_index: Annotated[StrictInt, Field(ge=0, le=0)] = 0,
- ) -> ApiResponse[object]:
- """Refresh
-
- Refresh the authentication token.
-
- :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
- (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._refresh_serialize(
- next=next,
- _request_auth=_request_auth,
- _content_type=_content_type,
- _headers=_headers,
- _host_index=_host_index
- )
-
- _response_types_map: Dict[str, Optional[str]] = {
- '200': "object",
- '307': "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 refresh_without_preload_content(
- self,
- next: Optional[StrictStr] = None,
- _request_timeout: Union[
- None,
- Annotated[StrictFloat, Field(gt=0)],
- Tuple[
- Annotated[StrictFloat, Field(gt=0)],
- Annotated[StrictFloat, Field(gt=0)]
- ]
- ] = None,
- _request_auth: Optional[Dict[StrictStr, Any]] = None,
- _content_type: Optional[StrictStr] = None,
- _headers: Optional[Dict[StrictStr, Any]] = None,
- _host_index: Annotated[StrictInt, Field(ge=0, le=0)] = 0,
- ) -> RESTResponseType:
- """Refresh
-
- Refresh the authentication token.
-
- :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
- (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._refresh_serialize(
- next=next,
- _request_auth=_request_auth,
- _content_type=_content_type,
- _headers=_headers,
- _host_index=_host_index
- )
-
- _response_types_map: Dict[str, Optional[str]] = {
- '200': "object",
- '307': "HTTPExceptionResponse",
- '422': "HTTPValidationError",
- }
- response_data = self.api_client.call_api(
- *_param,
- _request_timeout=_request_timeout
- )
- return response_data.response
-
-
- def _refresh_serialize(
- self,
- next,
- _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 next is not None:
-
- _query_params.append(('next', next))
-
- # 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] = [
- ]
-
- return self.api_client.param_serialize(
- method='GET',
- resource_path='/api/v2/auth/refresh',
- 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_client.py
b/airflow_client/client/api_client.py
index 777d338..a6404fb 100644
--- a/airflow_client/client/api_client.py
+++ b/airflow_client/client/api_client.py
@@ -90,7 +90,7 @@ class ApiClient:
self.default_headers[header_name] = header_value
self.cookie = cookie
# Set default User-Agent.
- self.user_agent = 'OpenAPI-Generator/3.1.3/python'
+ self.user_agent = 'OpenAPI-Generator/3.1.4/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 74ddce9..c815c17 100644
--- a/airflow_client/client/configuration.py
+++ b/airflow_client/client/configuration.py
@@ -518,7 +518,7 @@ class Configuration:
"OS: {env}\n"\
"Python Version: {pyversion}\n"\
"Version of the API: 2\n"\
- "SDK Package Version: 3.1.3".\
+ "SDK Package Version: 3.1.4".\
format(env=sys.platform, pyversion=sys.version)
def get_host_settings(self) -> List[HostSetting]:
diff --git a/docs/LoginApi.md b/docs/LoginApi.md
index 196f047..1f6b9b4 100644
--- a/docs/LoginApi.md
+++ b/docs/LoginApi.md
@@ -6,7 +6,6 @@ Method | HTTP request | Description
------------- | ------------- | -------------
[**login**](LoginApi.md#login) | **GET** /api/v2/auth/login | Login
[**logout**](LoginApi.md#logout) | **GET** /api/v2/auth/logout | Logout
-[**refresh**](LoginApi.md#refresh) | **GET** /api/v2/auth/refresh | Refresh
# **login**
@@ -142,72 +141,3 @@ 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)
-# **refresh**
-> object refresh(next=next)
-
-Refresh
-
-Refresh the authentication token.
-
-### Example
-
-
-```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";
-)
-
-
-# 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.LoginApi(api_client)
- next = 'next_example' # str | (optional)
-
- try:
- # Refresh
- api_response = api_instance.refresh(next=next)
- print("The response of LoginApi->refresh:\n")
- pprint(api_response)
- except Exception as e:
- print("Exception when calling LoginApi->refresh: %s\n" % e)
-```
-
-
-
-### Parameters
-
-
-Name | Type | Description | Notes
-------------- | ------------- | ------------- | -------------
- **next** | **str**| | [optional]
-
-### Return type
-
-**object**
-
-### Authorization
-
-No authorization required
-
-### HTTP request headers
-
- - **Content-Type**: Not defined
- - **Accept**: application/json
-
-### HTTP response details
-
-| Status code | Description | Response headers |
-|-------------|-------------|------------------|
-**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/pyproject.toml b/pyproject.toml
index a7a2281..59593b1 100644
--- a/pyproject.toml
+++ b/pyproject.toml
@@ -102,9 +102,14 @@ include = [
"/airflow_client",
]
-[tool.pytest.ini_options]
+[tool.pytest]
# make sure that pytest.ini is not read from pyproject.toml in paraent
directories
-addopts = "--color=yes --cov-config=pyproject.toml --cov=airflow_client"
+addopts = [
+ "--color=yes",
+ "--cov-config=pyproject.toml",
+ "--cov=airflow_client",
+]
+
norecursedirs = [
]
log_level = "INFO"
diff --git a/spec/v2.yaml b/spec/v2.yaml
index 45d7209..53702b1 100644
--- a/spec/v2.yaml
+++ b/spec/v2.yaml
@@ -4466,38 +4466,6 @@ paths:
summary: Logout
tags:
- Login
- /api/v2/auth/refresh:
- get:
- description: Refresh the authentication token.
- operationId: refresh
- parameters:
- - in: query
- name: next
- required: false
- schema:
- nullable: true
- type: string
- responses:
- '200':
- content:
- application/json:
- schema: {}
- description: Successful Response
- '307':
- content:
- application/json:
- schema:
- $ref: '#/components/schemas/HTTPExceptionResponse'
- description: Temporary Redirect
- '422':
- content:
- application/json:
- schema:
- $ref: '#/components/schemas/HTTPValidationError'
- description: Validation Error
- summary: Refresh
- tags:
- - Login
/api/v2/backfills:
get:
operationId: list_backfills
diff --git a/test/test_login_api.py b/test/test_login_api.py
index 007e38c..d52ea08 100644
--- a/test/test_login_api.py
+++ b/test/test_login_api.py
@@ -40,13 +40,6 @@ class TestLoginApi(unittest.TestCase):
"""
pass
- def test_refresh(self) -> None:
- """Test case for refresh
-
- Refresh
- """
- pass
-
if __name__ == '__main__':
unittest.main()
diff --git a/version.txt b/version.txt
index ff365e0..0aec50e 100644
--- a/version.txt
+++ b/version.txt
@@ -1 +1 @@
-3.1.3
+3.1.4
