Version 2.5.1 (#63)

apache · Jan 29, 2023 · f1b6e33 · f1b6e33
1 parent 38dfb51
commit f1b6e33
Show file tree

Hide file tree

Showing 44 changed files with 1,771 additions and 708 deletions.
diff --git a/CHANGELOG.md b/CHANGELOG.md
@@ -17,6 +17,22 @@
  under the License.
  -->
 
+# v2.5.1
+
+Apache Airflow API version: 2.5.1
+
+### Major changes:
+
+- NA
+
+### Major fixes:
+
+- Fix authentication issues by regenerating the client with proper security schemas
+
+### New API supported:
+
+- NA
+
 # v2.5.0
 
 Apache Airflow API version: 2.5.x

diff --git a/airflow_client/README.md b/airflow_client/README.md
@@ -231,7 +231,7 @@ fulfilling the request.
 This Python package is automatically generated by the [OpenAPI Generator](https://openapi-generator.tech) project:
 
 - API version: 2.5.0
-- Package version: 2.3.0
+- Package version: 2.5.1
 - Build package: org.openapitools.codegen.languages.PythonClientCodegen
 For more information, please visit [https://airflow.apache.org](https://airflow.apache.org)
 
@@ -286,6 +286,16 @@ configuration = client.Configuration(
     host = "http://localhost/api/v1"
 )
 
+# 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.
+
+# Configure HTTP basic authorization: Basic
+configuration = client.Configuration(
+    username = 'YOUR_USERNAME',
+    password = 'YOUR_PASSWORD'
+)
 
 
 # Enter a context with an instance of the API client
@@ -325,6 +335,8 @@ Class | Method | HTTP request | Description
 *DAGApi* | [**patch_dags**](docs/DAGApi.md#patch_dags) | **PATCH** /dags | Update DAGs
 *DAGApi* | [**post_clear_task_instances**](docs/DAGApi.md#post_clear_task_instances) | **POST** /dags/{dag_id}/clearTaskInstances | Clear a set of task instances
 *DAGApi* | [**post_set_task_instances_state**](docs/DAGApi.md#post_set_task_instances_state) | **POST** /dags/{dag_id}/updateTaskInstancesState | Set a state of task instances
+*DAGApi* | [**set_mapped_task_instance_note**](docs/DAGApi.md#set_mapped_task_instance_note) | **PATCH** /dags/{dag_id}/dagRuns/{dag_run_id}/taskInstances/{task_id}/{map_index}/setNote | Update the TaskInstance note.
+*DAGApi* | [**set_task_instance_note**](docs/DAGApi.md#set_task_instance_note) | **PATCH** /dags/{dag_id}/dagRuns/{dag_run_id}/taskInstances/{task_id}/setNote | Update the TaskInstance note.
 *DAGRunApi* | [**clear_dag_run**](docs/DAGRunApi.md#clear_dag_run) | **POST** /dags/{dag_id}/dagRuns/{dag_run_id}/clear | Clear a DAG run
 *DAGRunApi* | [**delete_dag_run**](docs/DAGRunApi.md#delete_dag_run) | **DELETE** /dags/{dag_id}/dagRuns/{dag_run_id} | Delete a DAG run
 *DAGRunApi* | [**get_dag_run**](docs/DAGRunApi.md#get_dag_run) | **GET** /dags/{dag_id}/dagRuns/{dag_run_id} | Get a DAG run
@@ -367,8 +379,6 @@ Class | Method | HTTP request | Description
 *TaskInstanceApi* | [**get_task_instances_batch**](docs/TaskInstanceApi.md#get_task_instances_batch) | **POST** /dags/~/dagRuns/~/taskInstances/list | List task instances (batch)
 *TaskInstanceApi* | [**patch_mapped_task_instance**](docs/TaskInstanceApi.md#patch_mapped_task_instance) | **PATCH** /dags/{dag_id}/dagRuns/{dag_run_id}/taskInstances/{task_id}/{map_index} | Updates the state of a mapped task instance
 *TaskInstanceApi* | [**patch_task_instance**](docs/TaskInstanceApi.md#patch_task_instance) | **PATCH** /dags/{dag_id}/dagRuns/{dag_run_id}/taskInstances/{task_id} | Updates the state of a task instance
-*TaskInstanceApi* | [**set_mapped_task_instance_note**](docs/TaskInstanceApi.md#set_mapped_task_instance_note) | **PATCH** /dags/{dag_id}/dagRuns/{dag_run_id}/taskInstances/{task_id}/{map_index}/setNote | Update the TaskInstance note.
-*TaskInstanceApi* | [**set_task_instance_note**](docs/TaskInstanceApi.md#set_task_instance_note) | **PATCH** /dags/{dag_id}/dagRuns/{dag_run_id}/taskInstances/{task_id}/setNote | Update the TaskInstance note.
 *UserApi* | [**delete_user**](docs/UserApi.md#delete_user) | **DELETE** /users/{username} | Delete a user
 *UserApi* | [**get_user**](docs/UserApi.md#get_user) | **GET** /users/{username} | Get a user
 *UserApi* | [**get_users**](docs/UserApi.md#get_users) | **GET** /users | List users

diff --git a/airflow_client/client/__init__.py b/airflow_client/client/__init__.py
@@ -28,7 +28,7 @@
 """
 
 
-__version__ = "2.3.0"
+__version__ = "2.5.1"
 
 # import ApiClient
 from airflow_client.client.api_client import ApiClient

diff --git a/airflow_client/client/api/config_api.py b/airflow_client/client/api/config_api.py
@@ -57,7 +57,10 @@ def __init__(self, api_client=None):
         self.get_config_endpoint = _Endpoint(
             settings={
                 'response_type': (Config,),
-                'auth': [],
+                'auth': [
+                    'Basic',
+                    'Kerberos'
+                ],
                 'endpoint_path': '/config',
                 'operation_id': 'get_config',
                 'http_method': 'GET',

diff --git a/airflow_client/client/api/connection_api.py b/airflow_client/client/api/connection_api.py
@@ -59,7 +59,10 @@ def __init__(self, api_client=None):
         self.delete_connection_endpoint = _Endpoint(
             settings={
                 'response_type': None,
-                'auth': [],
+                'auth': [
+                    'Basic',
+                    'Kerberos'
+                ],
                 'endpoint_path': '/connections/{connection_id}',
                 'operation_id': 'delete_connection',
                 'http_method': 'DELETE',
@@ -108,7 +111,10 @@ def __init__(self, api_client=None):
         self.get_connection_endpoint = _Endpoint(
             settings={
                 'response_type': (Connection,),
-                'auth': [],
+                'auth': [
+                    'Basic',
+                    'Kerberos'
+                ],
                 'endpoint_path': '/connections/{connection_id}',
                 'operation_id': 'get_connection',
                 'http_method': 'GET',
@@ -157,7 +163,10 @@ def __init__(self, api_client=None):
         self.get_connections_endpoint = _Endpoint(
             settings={
                 'response_type': (ConnectionCollection,),
-                'auth': [],
+                'auth': [
+                    'Basic',
+                    'Kerberos'
+                ],
                 'endpoint_path': '/connections',
                 'operation_id': 'get_connections',
                 'http_method': 'GET',
@@ -219,7 +228,10 @@ def __init__(self, api_client=None):
         self.patch_connection_endpoint = _Endpoint(
             settings={
                 'response_type': (Connection,),
-                'auth': [],
+                'auth': [
+                    'Basic',
+                    'Kerberos'
+                ],
                 'endpoint_path': '/connections/{connection_id}',
                 'operation_id': 'patch_connection',
                 'http_method': 'PATCH',
@@ -281,7 +293,10 @@ def __init__(self, api_client=None):
         self.post_connection_endpoint = _Endpoint(
             settings={
                 'response_type': (Connection,),
-                'auth': [],
+                'auth': [
+                    'Basic',
+                    'Kerberos'
+                ],
                 'endpoint_path': '/connections',
                 'operation_id': 'post_connection',
                 'http_method': 'POST',
@@ -331,7 +346,10 @@ def __init__(self, api_client=None):
         self.test_connection_endpoint = _Endpoint(
             settings={
                 'response_type': (ConnectionTest,),
-                'auth': [],
+                'auth': [
+                    'Basic',
+                    'Kerberos'
+                ],
                 'endpoint_path': '/connections/test',
                 'operation_id': 'test_connection',
                 'http_method': 'POST',