From f1b6e336fb7c94dc81b09a40264fb7502c6e1504 Mon Sep 17 00:00:00 2001 From: Pierre Jeambrun Date: Sun, 29 Jan 2023 15:37:02 +0100 Subject: [PATCH] Version 2.5.1 (#63) --- CHANGELOG.md | 16 + airflow_client/README.md | 16 +- airflow_client/client/__init__.py | 2 +- airflow_client/client/api/config_api.py | 5 +- airflow_client/client/api/connection_api.py | 30 +- airflow_client/client/api/dag_api.py | 365 +++++++++++++++++- airflow_client/client/api/dag_run_api.py | 45 ++- airflow_client/client/api/dag_warning_api.py | 5 +- airflow_client/client/api/dataset_api.py | 20 +- airflow_client/client/api/event_log_api.py | 10 +- airflow_client/client/api/import_error_api.py | 10 +- airflow_client/client/api/monitoring_api.py | 10 +- airflow_client/client/api/permission_api.py | 5 +- airflow_client/client/api/plugin_api.py | 5 +- airflow_client/client/api/pool_api.py | 25 +- airflow_client/client/api/provider_api.py | 5 +- airflow_client/client/api/role_api.py | 25 +- .../client/api/task_instance_api.py | 348 ++--------------- airflow_client/client/api/user_api.py | 25 +- airflow_client/client/api/variable_api.py | 25 +- airflow_client/client/api/x_com_api.py | 10 +- airflow_client/client/api_client.py | 2 +- airflow_client/client/configuration.py | 2 +- airflow_client/docs/ConfigApi.md | 15 +- airflow_client/docs/ConnectionApi.md | 90 ++++- airflow_client/docs/DAGApi.md | 353 +++++++++++++++-- airflow_client/docs/DAGRunApi.md | 135 ++++++- airflow_client/docs/DagWarningApi.md | 15 +- airflow_client/docs/DatasetApi.md | 60 ++- airflow_client/docs/EventLogApi.md | 30 +- airflow_client/docs/ImportErrorApi.md | 30 +- airflow_client/docs/MonitoringApi.md | 30 +- airflow_client/docs/PermissionApi.md | 15 +- airflow_client/docs/PluginApi.md | 15 +- airflow_client/docs/PoolApi.md | 75 +++- airflow_client/docs/ProviderApi.md | 15 +- airflow_client/docs/RoleApi.md | 75 +++- airflow_client/docs/TaskInstanceApi.md | 301 ++++++--------- airflow_client/docs/UserApi.md | 75 +++- airflow_client/docs/VariableApi.md | 75 +++- airflow_client/docs/XComApi.md | 30 +- airflow_client/test/test_dag_api.py | 14 + airflow_client/test/test_task_instance_api.py | 14 - setup.py | 6 +- 44 files changed, 1771 insertions(+), 708 deletions(-) diff --git a/CHANGELOG.md b/CHANGELOG.md index c1597e94..19dc9ca1 100644 --- 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 index 61f1e2b5..62e79327 100644 --- 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 index c30a0363..48181458 100644 --- 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 index e9e67f85..27e30e59 100644 --- 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 index 9081d93f..eeb554b0 100644 --- 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', diff --git a/airflow_client/client/api/dag_api.py b/airflow_client/client/api/dag_api.py index 703de520..165c6af6 100644 --- a/airflow_client/client/api/dag_api.py +++ b/airflow_client/client/api/dag_api.py @@ -45,8 +45,10 @@ from airflow_client.client.model.dag_detail import DAGDetail from airflow_client.client.model.error import Error from airflow_client.client.model.inline_response2001 import InlineResponse2001 +from airflow_client.client.model.set_task_instance_note import SetTaskInstanceNote from airflow_client.client.model.task import Task from airflow_client.client.model.task_collection import TaskCollection +from airflow_client.client.model.task_instance import TaskInstance from airflow_client.client.model.task_instance_reference_collection import TaskInstanceReferenceCollection from airflow_client.client.model.update_task_instances_state import UpdateTaskInstancesState @@ -65,7 +67,10 @@ def __init__(self, api_client=None): self.delete_dag_endpoint = _Endpoint( settings={ 'response_type': None, - 'auth': [], + 'auth': [ + 'Basic', + 'Kerberos' + ], 'endpoint_path': '/dags/{dag_id}', 'operation_id': 'delete_dag', 'http_method': 'DELETE', @@ -114,7 +119,10 @@ def __init__(self, api_client=None): self.get_dag_endpoint = _Endpoint( settings={ 'response_type': (DAG,), - 'auth': [], + 'auth': [ + 'Basic', + 'Kerberos' + ], 'endpoint_path': '/dags/{dag_id}', 'operation_id': 'get_dag', 'http_method': 'GET', @@ -163,7 +171,10 @@ def __init__(self, api_client=None): self.get_dag_details_endpoint = _Endpoint( settings={ 'response_type': (DAGDetail,), - 'auth': [], + 'auth': [ + 'Basic', + 'Kerberos' + ], 'endpoint_path': '/dags/{dag_id}/details', 'operation_id': 'get_dag_details', 'http_method': 'GET', @@ -212,7 +223,10 @@ def __init__(self, api_client=None): self.get_dag_source_endpoint = _Endpoint( settings={ 'response_type': (InlineResponse2001,), - 'auth': [], + 'auth': [ + 'Basic', + 'Kerberos' + ], 'endpoint_path': '/dagSources/{file_token}', 'operation_id': 'get_dag_source', 'http_method': 'GET', @@ -262,7 +276,10 @@ def __init__(self, api_client=None): self.get_dags_endpoint = _Endpoint( settings={ 'response_type': (DAGCollection,), - 'auth': [], + 'auth': [ + 'Basic', + 'Kerberos' + ], 'endpoint_path': '/dags', 'operation_id': 'get_dags', 'http_method': 'GET', @@ -340,7 +357,10 @@ def __init__(self, api_client=None): self.get_task_endpoint = _Endpoint( settings={ 'response_type': (Task,), - 'auth': [], + 'auth': [ + 'Basic', + 'Kerberos' + ], 'endpoint_path': '/dags/{dag_id}/tasks/{task_id}', 'operation_id': 'get_task', 'http_method': 'GET', @@ -395,7 +415,10 @@ def __init__(self, api_client=None): self.get_tasks_endpoint = _Endpoint( settings={ 'response_type': (TaskCollection,), - 'auth': [], + 'auth': [ + 'Basic', + 'Kerberos' + ], 'endpoint_path': '/dags/{dag_id}/tasks', 'operation_id': 'get_tasks', 'http_method': 'GET', @@ -449,7 +472,10 @@ def __init__(self, api_client=None): self.patch_dag_endpoint = _Endpoint( settings={ 'response_type': (DAG,), - 'auth': [], + 'auth': [ + 'Basic', + 'Kerberos' + ], 'endpoint_path': '/dags/{dag_id}', 'operation_id': 'patch_dag', 'http_method': 'PATCH', @@ -511,7 +537,10 @@ def __init__(self, api_client=None): self.patch_dags_endpoint = _Endpoint( settings={ 'response_type': (DAGCollection,), - 'auth': [], + 'auth': [ + 'Basic', + 'Kerberos' + ], 'endpoint_path': '/dags', 'operation_id': 'patch_dags', 'http_method': 'PATCH', @@ -599,7 +628,10 @@ def __init__(self, api_client=None): self.post_clear_task_instances_endpoint = _Endpoint( settings={ 'response_type': (TaskInstanceReferenceCollection,), - 'auth': [], + 'auth': [ + 'Basic', + 'Kerberos' + ], 'endpoint_path': '/dags/{dag_id}/clearTaskInstances', 'operation_id': 'post_clear_task_instances', 'http_method': 'POST', @@ -655,7 +687,10 @@ def __init__(self, api_client=None): self.post_set_task_instances_state_endpoint = _Endpoint( settings={ 'response_type': (TaskInstanceReferenceCollection,), - 'auth': [], + 'auth': [ + 'Basic', + 'Kerberos' + ], 'endpoint_path': '/dags/{dag_id}/updateTaskInstancesState', 'operation_id': 'post_set_task_instances_state', 'http_method': 'POST', @@ -708,6 +743,154 @@ def __init__(self, api_client=None): }, api_client=api_client ) + self.set_mapped_task_instance_note_endpoint = _Endpoint( + settings={ + 'response_type': (TaskInstance,), + 'auth': [ + 'Basic', + 'Kerberos' + ], + 'endpoint_path': '/dags/{dag_id}/dagRuns/{dag_run_id}/taskInstances/{task_id}/{map_index}/setNote', + 'operation_id': 'set_mapped_task_instance_note', + 'http_method': 'PATCH', + 'servers': None, + }, + params_map={ + 'all': [ + 'dag_id', + 'dag_run_id', + 'task_id', + 'map_index', + 'set_task_instance_note', + ], + 'required': [ + 'dag_id', + 'dag_run_id', + 'task_id', + 'map_index', + 'set_task_instance_note', + ], + 'nullable': [ + ], + 'enum': [ + ], + 'validation': [ + ] + }, + root_map={ + 'validations': { + }, + 'allowed_values': { + }, + 'openapi_types': { + 'dag_id': + (str,), + 'dag_run_id': + (str,), + 'task_id': + (str,), + 'map_index': + (int,), + 'set_task_instance_note': + (SetTaskInstanceNote,), + }, + 'attribute_map': { + 'dag_id': 'dag_id', + 'dag_run_id': 'dag_run_id', + 'task_id': 'task_id', + 'map_index': 'map_index', + }, + 'location_map': { + 'dag_id': 'path', + 'dag_run_id': 'path', + 'task_id': 'path', + 'map_index': 'path', + 'set_task_instance_note': 'body', + }, + 'collection_format_map': { + } + }, + headers_map={ + 'accept': [ + 'application/json' + ], + 'content_type': [ + 'application/json' + ] + }, + api_client=api_client + ) + self.set_task_instance_note_endpoint = _Endpoint( + settings={ + 'response_type': (TaskInstance,), + 'auth': [ + 'Basic', + 'Kerberos' + ], + 'endpoint_path': '/dags/{dag_id}/dagRuns/{dag_run_id}/taskInstances/{task_id}/setNote', + 'operation_id': 'set_task_instance_note', + 'http_method': 'PATCH', + 'servers': None, + }, + params_map={ + 'all': [ + 'dag_id', + 'dag_run_id', + 'task_id', + 'set_task_instance_note', + ], + 'required': [ + 'dag_id', + 'dag_run_id', + 'task_id', + 'set_task_instance_note', + ], + 'nullable': [ + ], + 'enum': [ + ], + 'validation': [ + ] + }, + root_map={ + 'validations': { + }, + 'allowed_values': { + }, + 'openapi_types': { + 'dag_id': + (str,), + 'dag_run_id': + (str,), + 'task_id': + (str,), + 'set_task_instance_note': + (SetTaskInstanceNote,), + }, + 'attribute_map': { + 'dag_id': 'dag_id', + 'dag_run_id': 'dag_run_id', + 'task_id': 'task_id', + }, + 'location_map': { + 'dag_id': 'path', + 'dag_run_id': 'path', + 'task_id': 'path', + 'set_task_instance_note': 'body', + }, + 'collection_format_map': { + } + }, + headers_map={ + 'accept': [ + 'application/json' + ], + 'content_type': [ + 'application/json' + ] + }, + api_client=api_client + ) def delete_dag( self, @@ -1460,3 +1643,163 @@ def post_set_task_instances_state( update_task_instances_state return self.post_set_task_instances_state_endpoint.call_with_http_info(**kwargs) + def set_mapped_task_instance_note( + self, + dag_id, + dag_run_id, + task_id, + map_index, + set_task_instance_note, + **kwargs + ): + """Update the TaskInstance note. # noqa: E501 + + Update the manual user note of a mapped Task Instance. *New in version 2.5.0* # noqa: E501 + This method makes a synchronous HTTP request by default. To make an + asynchronous HTTP request, please pass async_req=True + + >>> thread = api.set_mapped_task_instance_note(dag_id, dag_run_id, task_id, map_index, set_task_instance_note, async_req=True) + >>> result = thread.get() + + Args: + dag_id (str): The DAG ID. + dag_run_id (str): The DAG run ID. + task_id (str): The task ID. + map_index (int): The map index. + set_task_instance_note (SetTaskInstanceNote): Parameters of set Task Instance note. + + Keyword Args: + _return_http_data_only (bool): response data without head status + code and headers. Default is True. + _preload_content (bool): if False, the urllib3.HTTPResponse object + will be returned without reading/decoding response data. + Default is True. + _request_timeout (int/float/tuple): 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. + Default is None. + _check_input_type (bool): specifies if type checking + should be done one the data sent to the server. + Default is True. + _check_return_type (bool): specifies if type checking + should be done one the data received from the server. + Default is True. + _host_index (int/None): specifies the index of the server + that we want to use. + Default is read from the configuration. + async_req (bool): execute request asynchronously + + Returns: + TaskInstance + If the method is called asynchronously, returns the request + thread. + """ + kwargs['async_req'] = kwargs.get( + 'async_req', False + ) + kwargs['_return_http_data_only'] = kwargs.get( + '_return_http_data_only', True + ) + kwargs['_preload_content'] = kwargs.get( + '_preload_content', True + ) + kwargs['_request_timeout'] = kwargs.get( + '_request_timeout', None + ) + kwargs['_check_input_type'] = kwargs.get( + '_check_input_type', True + ) + kwargs['_check_return_type'] = kwargs.get( + '_check_return_type', True + ) + kwargs['_host_index'] = kwargs.get('_host_index') + kwargs['dag_id'] = \ + dag_id + kwargs['dag_run_id'] = \ + dag_run_id + kwargs['task_id'] = \ + task_id + kwargs['map_index'] = \ + map_index + kwargs['set_task_instance_note'] = \ + set_task_instance_note + return self.set_mapped_task_instance_note_endpoint.call_with_http_info(**kwargs) + + def set_task_instance_note( + self, + dag_id, + dag_run_id, + task_id, + set_task_instance_note, + **kwargs + ): + """Update the TaskInstance note. # noqa: E501 + + Update the manual user note of a non-mapped Task Instance. *New in version 2.5.0* # noqa: E501 + This method makes a synchronous HTTP request by default. To make an + asynchronous HTTP request, please pass async_req=True + + >>> thread = api.set_task_instance_note(dag_id, dag_run_id, task_id, set_task_instance_note, async_req=True) + >>> result = thread.get() + + Args: + dag_id (str): The DAG ID. + dag_run_id (str): The DAG run ID. + task_id (str): The task ID. + set_task_instance_note (SetTaskInstanceNote): Parameters of set Task Instance note. + + Keyword Args: + _return_http_data_only (bool): response data without head status + code and headers. Default is True. + _preload_content (bool): if False, the urllib3.HTTPResponse object + will be returned without reading/decoding response data. + Default is True. + _request_timeout (int/float/tuple): 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. + Default is None. + _check_input_type (bool): specifies if type checking + should be done one the data sent to the server. + Default is True. + _check_return_type (bool): specifies if type checking + should be done one the data received from the server. + Default is True. + _host_index (int/None): specifies the index of the server + that we want to use. + Default is read from the configuration. + async_req (bool): execute request asynchronously + + Returns: + TaskInstance + If the method is called asynchronously, returns the request + thread. + """ + kwargs['async_req'] = kwargs.get( + 'async_req', False + ) + kwargs['_return_http_data_only'] = kwargs.get( + '_return_http_data_only', True + ) + kwargs['_preload_content'] = kwargs.get( + '_preload_content', True + ) + kwargs['_request_timeout'] = kwargs.get( + '_request_timeout', None + ) + kwargs['_check_input_type'] = kwargs.get( + '_check_input_type', True + ) + kwargs['_check_return_type'] = kwargs.get( + '_check_return_type', True + ) + kwargs['_host_index'] = kwargs.get('_host_index') + kwargs['dag_id'] = \ + dag_id + kwargs['dag_run_id'] = \ + dag_run_id + kwargs['task_id'] = \ + task_id + kwargs['set_task_instance_note'] = \ + set_task_instance_note + return self.set_task_instance_note_endpoint.call_with_http_info(**kwargs) + diff --git a/airflow_client/client/api/dag_run_api.py b/airflow_client/client/api/dag_run_api.py index d0994f8f..0b10d0a5 100644 --- a/airflow_client/client/api/dag_run_api.py +++ b/airflow_client/client/api/dag_run_api.py @@ -63,7 +63,10 @@ def __init__(self, api_client=None): self.clear_dag_run_endpoint = _Endpoint( settings={ 'response_type': (DAGRun,), - 'auth': [], + 'auth': [ + 'Basic', + 'Kerberos' + ], 'endpoint_path': '/dags/{dag_id}/dagRuns/{dag_run_id}/clear', 'operation_id': 'clear_dag_run', 'http_method': 'POST', @@ -125,7 +128,10 @@ def __init__(self, api_client=None): self.delete_dag_run_endpoint = _Endpoint( settings={ 'response_type': None, - 'auth': [], + 'auth': [ + 'Basic', + 'Kerberos' + ], 'endpoint_path': '/dags/{dag_id}/dagRuns/{dag_run_id}', 'operation_id': 'delete_dag_run', 'http_method': 'DELETE', @@ -180,7 +186,10 @@ def __init__(self, api_client=None): self.get_dag_run_endpoint = _Endpoint( settings={ 'response_type': (DAGRun,), - 'auth': [], + 'auth': [ + 'Basic', + 'Kerberos' + ], 'endpoint_path': '/dags/{dag_id}/dagRuns/{dag_run_id}', 'operation_id': 'get_dag_run', 'http_method': 'GET', @@ -235,7 +244,10 @@ def __init__(self, api_client=None): self.get_dag_runs_endpoint = _Endpoint( settings={ 'response_type': (DAGRunCollection,), - 'auth': [], + 'auth': [ + 'Basic', + 'Kerberos' + ], 'endpoint_path': '/dags/{dag_id}/dagRuns', 'operation_id': 'get_dag_runs', 'http_method': 'GET', @@ -340,7 +352,10 @@ def __init__(self, api_client=None): self.get_dag_runs_batch_endpoint = _Endpoint( settings={ 'response_type': (DAGRunCollection,), - 'auth': [], + 'auth': [ + 'Basic', + 'Kerberos' + ], 'endpoint_path': '/dags/~/dagRuns/list', 'operation_id': 'get_dag_runs_batch', 'http_method': 'POST', @@ -390,7 +405,10 @@ def __init__(self, api_client=None): self.get_upstream_dataset_events_endpoint = _Endpoint( settings={ 'response_type': (DatasetEventCollection,), - 'auth': [], + 'auth': [ + 'Basic', + 'Kerberos' + ], 'endpoint_path': '/dags/{dag_id}/dagRuns/{dag_run_id}/upstreamDatasetEvents', 'operation_id': 'get_upstream_dataset_events', 'http_method': 'GET', @@ -445,7 +463,10 @@ def __init__(self, api_client=None): self.post_dag_run_endpoint = _Endpoint( settings={ 'response_type': (DAGRun,), - 'auth': [], + 'auth': [ + 'Basic', + 'Kerberos' + ], 'endpoint_path': '/dags/{dag_id}/dagRuns', 'operation_id': 'post_dag_run', 'http_method': 'POST', @@ -501,7 +522,10 @@ def __init__(self, api_client=None): self.set_dag_run_note_endpoint = _Endpoint( settings={ 'response_type': (DAGRun,), - 'auth': [], + 'auth': [ + 'Basic', + 'Kerberos' + ], 'endpoint_path': '/dags/{dag_id}/dagRuns/{dag_run_id}/setNote', 'operation_id': 'set_dag_run_note', 'http_method': 'PATCH', @@ -563,7 +587,10 @@ def __init__(self, api_client=None): self.update_dag_run_state_endpoint = _Endpoint( settings={ 'response_type': (DAGRun,), - 'auth': [], + 'auth': [ + 'Basic', + 'Kerberos' + ], 'endpoint_path': '/dags/{dag_id}/dagRuns/{dag_run_id}', 'operation_id': 'update_dag_run_state', 'http_method': 'PATCH', diff --git a/airflow_client/client/api/dag_warning_api.py b/airflow_client/client/api/dag_warning_api.py index 66a67da8..3476e3b4 100644 --- a/airflow_client/client/api/dag_warning_api.py +++ b/airflow_client/client/api/dag_warning_api.py @@ -57,7 +57,10 @@ def __init__(self, api_client=None): self.get_dag_warnings_endpoint = _Endpoint( settings={ 'response_type': (DagWarningCollection,), - 'auth': [], + 'auth': [ + 'Basic', + 'Kerberos' + ], 'endpoint_path': '/dagWarnings', 'operation_id': 'get_dag_warnings', 'http_method': 'GET', diff --git a/airflow_client/client/api/dataset_api.py b/airflow_client/client/api/dataset_api.py index ded60018..e2c7831b 100644 --- a/airflow_client/client/api/dataset_api.py +++ b/airflow_client/client/api/dataset_api.py @@ -59,7 +59,10 @@ def __init__(self, api_client=None): self.get_dataset_endpoint = _Endpoint( settings={ 'response_type': (Dataset,), - 'auth': [], + 'auth': [ + 'Basic', + 'Kerberos' + ], 'endpoint_path': '/datasets/{uri}', 'operation_id': 'get_dataset', 'http_method': 'GET', @@ -108,7 +111,10 @@ def __init__(self, api_client=None): self.get_dataset_events_endpoint = _Endpoint( settings={ 'response_type': (DatasetEventCollection,), - 'auth': [], + 'auth': [ + 'Basic', + 'Kerberos' + ], 'endpoint_path': '/datasets/events', 'operation_id': 'get_dataset_events', 'http_method': 'GET', @@ -195,7 +201,10 @@ def __init__(self, api_client=None): self.get_datasets_endpoint = _Endpoint( settings={ 'response_type': (DatasetCollection,), - 'auth': [], + 'auth': [ + 'Basic', + 'Kerberos' + ], 'endpoint_path': '/datasets', 'operation_id': 'get_datasets', 'http_method': 'GET', @@ -262,7 +271,10 @@ def __init__(self, api_client=None): self.get_upstream_dataset_events_endpoint = _Endpoint( settings={ 'response_type': (DatasetEventCollection,), - 'auth': [], + 'auth': [ + 'Basic', + 'Kerberos' + ], 'endpoint_path': '/dags/{dag_id}/dagRuns/{dag_run_id}/upstreamDatasetEvents', 'operation_id': 'get_upstream_dataset_events', 'http_method': 'GET', diff --git a/airflow_client/client/api/event_log_api.py b/airflow_client/client/api/event_log_api.py index 700eed64..e2b8fc51 100644 --- a/airflow_client/client/api/event_log_api.py +++ b/airflow_client/client/api/event_log_api.py @@ -58,7 +58,10 @@ def __init__(self, api_client=None): self.get_event_log_endpoint = _Endpoint( settings={ 'response_type': (EventLog,), - 'auth': [], + 'auth': [ + 'Basic', + 'Kerberos' + ], 'endpoint_path': '/eventLogs/{event_log_id}', 'operation_id': 'get_event_log', 'http_method': 'GET', @@ -107,7 +110,10 @@ def __init__(self, api_client=None): self.get_event_logs_endpoint = _Endpoint( settings={ 'response_type': (EventLogCollection,), - 'auth': [], + 'auth': [ + 'Basic', + 'Kerberos' + ], 'endpoint_path': '/eventLogs', 'operation_id': 'get_event_logs', 'http_method': 'GET', diff --git a/airflow_client/client/api/import_error_api.py b/airflow_client/client/api/import_error_api.py index 5715a7bc..80985223 100644 --- a/airflow_client/client/api/import_error_api.py +++ b/airflow_client/client/api/import_error_api.py @@ -58,7 +58,10 @@ def __init__(self, api_client=None): self.get_import_error_endpoint = _Endpoint( settings={ 'response_type': (ImportError,), - 'auth': [], + 'auth': [ + 'Basic', + 'Kerberos' + ], 'endpoint_path': '/importErrors/{import_error_id}', 'operation_id': 'get_import_error', 'http_method': 'GET', @@ -107,7 +110,10 @@ def __init__(self, api_client=None): self.get_import_errors_endpoint = _Endpoint( settings={ 'response_type': (ImportErrorCollection,), - 'auth': [], + 'auth': [ + 'Basic', + 'Kerberos' + ], 'endpoint_path': '/importErrors', 'operation_id': 'get_import_errors', 'http_method': 'GET', diff --git a/airflow_client/client/api/monitoring_api.py b/airflow_client/client/api/monitoring_api.py index fc1b65e3..4a665d30 100644 --- a/airflow_client/client/api/monitoring_api.py +++ b/airflow_client/client/api/monitoring_api.py @@ -57,7 +57,10 @@ def __init__(self, api_client=None): self.get_health_endpoint = _Endpoint( settings={ 'response_type': (HealthInfo,), - 'auth': [], + 'auth': [ + 'Basic', + 'Kerberos' + ], 'endpoint_path': '/health', 'operation_id': 'get_health', 'http_method': 'GET', @@ -99,7 +102,10 @@ def __init__(self, api_client=None): self.get_version_endpoint = _Endpoint( settings={ 'response_type': (VersionInfo,), - 'auth': [], + 'auth': [ + 'Basic', + 'Kerberos' + ], 'endpoint_path': '/version', 'operation_id': 'get_version', 'http_method': 'GET', diff --git a/airflow_client/client/api/permission_api.py b/airflow_client/client/api/permission_api.py index 705503c2..bdd38359 100644 --- a/airflow_client/client/api/permission_api.py +++ b/airflow_client/client/api/permission_api.py @@ -57,7 +57,10 @@ def __init__(self, api_client=None): self.get_permissions_endpoint = _Endpoint( settings={ 'response_type': (ActionCollection,), - 'auth': [], + 'auth': [ + 'Basic', + 'Kerberos' + ], 'endpoint_path': '/permissions', 'operation_id': 'get_permissions', 'http_method': 'GET', diff --git a/airflow_client/client/api/plugin_api.py b/airflow_client/client/api/plugin_api.py index 40518724..6c100069 100644 --- a/airflow_client/client/api/plugin_api.py +++ b/airflow_client/client/api/plugin_api.py @@ -57,7 +57,10 @@ def __init__(self, api_client=None): self.get_plugins_endpoint = _Endpoint( settings={ 'response_type': (PluginCollection,), - 'auth': [], + 'auth': [ + 'Basic', + 'Kerberos' + ], 'endpoint_path': '/plugins', 'operation_id': 'get_plugins', 'http_method': 'GET', diff --git a/airflow_client/client/api/pool_api.py b/airflow_client/client/api/pool_api.py index 10cf5efd..d86f7dc8 100644 --- a/airflow_client/client/api/pool_api.py +++ b/airflow_client/client/api/pool_api.py @@ -58,7 +58,10 @@ def __init__(self, api_client=None): self.delete_pool_endpoint = _Endpoint( settings={ 'response_type': None, - 'auth': [], + 'auth': [ + 'Basic', + 'Kerberos' + ], 'endpoint_path': '/pools/{pool_name}', 'operation_id': 'delete_pool', 'http_method': 'DELETE', @@ -107,7 +110,10 @@ def __init__(self, api_client=None): self.get_pool_endpoint = _Endpoint( settings={ 'response_type': (Pool,), - 'auth': [], + 'auth': [ + 'Basic', + 'Kerberos' + ], 'endpoint_path': '/pools/{pool_name}', 'operation_id': 'get_pool', 'http_method': 'GET', @@ -156,7 +162,10 @@ def __init__(self, api_client=None): self.get_pools_endpoint = _Endpoint( settings={ 'response_type': (PoolCollection,), - 'auth': [], + 'auth': [ + 'Basic', + 'Kerberos' + ], 'endpoint_path': '/pools', 'operation_id': 'get_pools', 'http_method': 'GET', @@ -218,7 +227,10 @@ def __init__(self, api_client=None): self.patch_pool_endpoint = _Endpoint( settings={ 'response_type': (Pool,), - 'auth': [], + 'auth': [ + 'Basic', + 'Kerberos' + ], 'endpoint_path': '/pools/{pool_name}', 'operation_id': 'patch_pool', 'http_method': 'PATCH', @@ -280,7 +292,10 @@ def __init__(self, api_client=None): self.post_pool_endpoint = _Endpoint( settings={ 'response_type': (Pool,), - 'auth': [], + 'auth': [ + 'Basic', + 'Kerberos' + ], 'endpoint_path': '/pools', 'operation_id': 'post_pool', 'http_method': 'POST', diff --git a/airflow_client/client/api/provider_api.py b/airflow_client/client/api/provider_api.py index de71e35e..fd88eae0 100644 --- a/airflow_client/client/api/provider_api.py +++ b/airflow_client/client/api/provider_api.py @@ -56,7 +56,10 @@ def __init__(self, api_client=None): self.get_providers_endpoint = _Endpoint( settings={ 'response_type': (bool, date, datetime, dict, float, int, list, str, none_type,), - 'auth': [], + 'auth': [ + 'Basic', + 'Kerberos' + ], 'endpoint_path': '/providers', 'operation_id': 'get_providers', 'http_method': 'GET', diff --git a/airflow_client/client/api/role_api.py b/airflow_client/client/api/role_api.py index 108d3787..a33cdc4c 100644 --- a/airflow_client/client/api/role_api.py +++ b/airflow_client/client/api/role_api.py @@ -58,7 +58,10 @@ def __init__(self, api_client=None): self.delete_role_endpoint = _Endpoint( settings={ 'response_type': None, - 'auth': [], + 'auth': [ + 'Basic', + 'Kerberos' + ], 'endpoint_path': '/roles/{role_name}', 'operation_id': 'delete_role', 'http_method': 'DELETE', @@ -107,7 +110,10 @@ def __init__(self, api_client=None): self.get_role_endpoint = _Endpoint( settings={ 'response_type': (Role,), - 'auth': [], + 'auth': [ + 'Basic', + 'Kerberos' + ], 'endpoint_path': '/roles/{role_name}', 'operation_id': 'get_role', 'http_method': 'GET', @@ -156,7 +162,10 @@ def __init__(self, api_client=None): self.get_roles_endpoint = _Endpoint( settings={ 'response_type': (RoleCollection,), - 'auth': [], + 'auth': [ + 'Basic', + 'Kerberos' + ], 'endpoint_path': '/roles', 'operation_id': 'get_roles', 'http_method': 'GET', @@ -218,7 +227,10 @@ def __init__(self, api_client=None): self.patch_role_endpoint = _Endpoint( settings={ 'response_type': (Role,), - 'auth': [], + 'auth': [ + 'Basic', + 'Kerberos' + ], 'endpoint_path': '/roles/{role_name}', 'operation_id': 'patch_role', 'http_method': 'PATCH', @@ -280,7 +292,10 @@ def __init__(self, api_client=None): self.post_role_endpoint = _Endpoint( settings={ 'response_type': (Role,), - 'auth': [], + 'auth': [ + 'Basic', + 'Kerberos' + ], 'endpoint_path': '/roles', 'operation_id': 'post_role', 'http_method': 'POST', diff --git a/airflow_client/client/api/task_instance_api.py b/airflow_client/client/api/task_instance_api.py index 6970b38d..7828a849 100644 --- a/airflow_client/client/api/task_instance_api.py +++ b/airflow_client/client/api/task_instance_api.py @@ -43,7 +43,6 @@ from airflow_client.client.model.extra_link_collection import ExtraLinkCollection from airflow_client.client.model.inline_response200 import InlineResponse200 from airflow_client.client.model.list_task_instance_form import ListTaskInstanceForm -from airflow_client.client.model.set_task_instance_note import SetTaskInstanceNote from airflow_client.client.model.task_instance import TaskInstance from airflow_client.client.model.task_instance_collection import TaskInstanceCollection from airflow_client.client.model.task_instance_reference import TaskInstanceReference @@ -64,7 +63,10 @@ def __init__(self, api_client=None): self.get_extra_links_endpoint = _Endpoint( settings={ 'response_type': (ExtraLinkCollection,), - 'auth': [], + 'auth': [ + 'Basic', + 'Kerberos' + ], 'endpoint_path': '/dags/{dag_id}/dagRuns/{dag_run_id}/taskInstances/{task_id}/links', 'operation_id': 'get_extra_links', 'http_method': 'GET', @@ -125,7 +127,10 @@ def __init__(self, api_client=None): self.get_log_endpoint = _Endpoint( settings={ 'response_type': (InlineResponse200,), - 'auth': [], + 'auth': [ + 'Basic', + 'Kerberos' + ], 'endpoint_path': '/dags/{dag_id}/dagRuns/{dag_run_id}/taskInstances/{task_id}/logs/{task_try_number}', 'operation_id': 'get_log', 'http_method': 'GET', @@ -208,7 +213,10 @@ def __init__(self, api_client=None): self.get_mapped_task_instance_endpoint = _Endpoint( settings={ 'response_type': (TaskInstance,), - 'auth': [], + 'auth': [ + 'Basic', + 'Kerberos' + ], 'endpoint_path': '/dags/{dag_id}/dagRuns/{dag_run_id}/taskInstances/{task_id}/{map_index}', 'operation_id': 'get_mapped_task_instance', 'http_method': 'GET', @@ -275,7 +283,10 @@ def __init__(self, api_client=None): self.get_mapped_task_instances_endpoint = _Endpoint( settings={ 'response_type': (TaskInstanceCollection,), - 'auth': [], + 'auth': [ + 'Basic', + 'Kerberos' + ], 'endpoint_path': '/dags/{dag_id}/dagRuns/{dag_run_id}/taskInstances/{task_id}/listMapped', 'operation_id': 'get_mapped_task_instances', 'http_method': 'GET', @@ -414,7 +425,10 @@ def __init__(self, api_client=None): self.get_task_instance_endpoint = _Endpoint( settings={ 'response_type': (TaskInstance,), - 'auth': [], + 'auth': [ + 'Basic', + 'Kerberos' + ], 'endpoint_path': '/dags/{dag_id}/dagRuns/{dag_run_id}/taskInstances/{task_id}', 'operation_id': 'get_task_instance', 'http_method': 'GET', @@ -475,7 +489,10 @@ def __init__(self, api_client=None): self.get_task_instances_endpoint = _Endpoint( settings={ 'response_type': (TaskInstanceCollection,), - 'auth': [], + 'auth': [ + 'Basic', + 'Kerberos' + ], 'endpoint_path': '/dags/{dag_id}/dagRuns/{dag_run_id}/taskInstances', 'operation_id': 'get_task_instances', 'http_method': 'GET', @@ -603,7 +620,10 @@ def __init__(self, api_client=None): self.get_task_instances_batch_endpoint = _Endpoint( settings={ 'response_type': (TaskInstanceCollection,), - 'auth': [], + 'auth': [ + 'Basic', + 'Kerberos' + ], 'endpoint_path': '/dags/~/dagRuns/~/taskInstances/list', 'operation_id': 'get_task_instances_batch', 'http_method': 'POST', @@ -653,7 +673,10 @@ def __init__(self, api_client=None): self.patch_mapped_task_instance_endpoint = _Endpoint( settings={ 'response_type': (TaskInstanceReference,), - 'auth': [], + 'auth': [ + 'Basic', + 'Kerberos' + ], 'endpoint_path': '/dags/{dag_id}/dagRuns/{dag_run_id}/taskInstances/{task_id}/{map_index}', 'operation_id': 'patch_mapped_task_instance', 'http_method': 'PATCH', @@ -726,7 +749,10 @@ def __init__(self, api_client=None): self.patch_task_instance_endpoint = _Endpoint( settings={ 'response_type': (TaskInstanceReference,), - 'auth': [], + 'auth': [ + 'Basic', + 'Kerberos' + ], 'endpoint_path': '/dags/{dag_id}/dagRuns/{dag_run_id}/taskInstances/{task_id}', 'operation_id': 'patch_task_instance', 'http_method': 'PATCH', @@ -791,148 +817,6 @@ def __init__(self, api_client=None): }, api_client=api_client ) - self.set_mapped_task_instance_note_endpoint = _Endpoint( - settings={ - 'response_type': (TaskInstance,), - 'auth': [], - 'endpoint_path': '/dags/{dag_id}/dagRuns/{dag_run_id}/taskInstances/{task_id}/{map_index}/setNote', - 'operation_id': 'set_mapped_task_instance_note', - 'http_method': 'PATCH', - 'servers': None, - }, - params_map={ - 'all': [ - 'dag_id', - 'dag_run_id', - 'task_id', - 'map_index', - 'set_task_instance_note', - ], - 'required': [ - 'dag_id', - 'dag_run_id', - 'task_id', - 'map_index', - 'set_task_instance_note', - ], - 'nullable': [ - ], - 'enum': [ - ], - 'validation': [ - ] - }, - root_map={ - 'validations': { - }, - 'allowed_values': { - }, - 'openapi_types': { - 'dag_id': - (str,), - 'dag_run_id': - (str,), - 'task_id': - (str,), - 'map_index': - (int,), - 'set_task_instance_note': - (SetTaskInstanceNote,), - }, - 'attribute_map': { - 'dag_id': 'dag_id', - 'dag_run_id': 'dag_run_id', - 'task_id': 'task_id', - 'map_index': 'map_index', - }, - 'location_map': { - 'dag_id': 'path', - 'dag_run_id': 'path', - 'task_id': 'path', - 'map_index': 'path', - 'set_task_instance_note': 'body', - }, - 'collection_format_map': { - } - }, - headers_map={ - 'accept': [ - 'application/json' - ], - 'content_type': [ - 'application/json' - ] - }, - api_client=api_client - ) - self.set_task_instance_note_endpoint = _Endpoint( - settings={ - 'response_type': (TaskInstance,), - 'auth': [], - 'endpoint_path': '/dags/{dag_id}/dagRuns/{dag_run_id}/taskInstances/{task_id}/setNote', - 'operation_id': 'set_task_instance_note', - 'http_method': 'PATCH', - 'servers': None, - }, - params_map={ - 'all': [ - 'dag_id', - 'dag_run_id', - 'task_id', - 'set_task_instance_note', - ], - 'required': [ - 'dag_id', - 'dag_run_id', - 'task_id', - 'set_task_instance_note', - ], - 'nullable': [ - ], - 'enum': [ - ], - 'validation': [ - ] - }, - root_map={ - 'validations': { - }, - 'allowed_values': { - }, - 'openapi_types': { - 'dag_id': - (str,), - 'dag_run_id': - (str,), - 'task_id': - (str,), - 'set_task_instance_note': - (SetTaskInstanceNote,), - }, - 'attribute_map': { - 'dag_id': 'dag_id', - 'dag_run_id': 'dag_run_id', - 'task_id': 'task_id', - }, - 'location_map': { - 'dag_id': 'path', - 'dag_run_id': 'path', - 'task_id': 'path', - 'set_task_instance_note': 'body', - }, - 'collection_format_map': { - } - }, - headers_map={ - 'accept': [ - 'application/json' - ], - 'content_type': [ - 'application/json' - ] - }, - api_client=api_client - ) def get_extra_links( self, @@ -1634,163 +1518,3 @@ def patch_task_instance( update_task_instance return self.patch_task_instance_endpoint.call_with_http_info(**kwargs) - def set_mapped_task_instance_note( - self, - dag_id, - dag_run_id, - task_id, - map_index, - set_task_instance_note, - **kwargs - ): - """Update the TaskInstance note. # noqa: E501 - - Update the manual user note of a mapped Task Instance. *New in version 2.5.0* # noqa: E501 - This method makes a synchronous HTTP request by default. To make an - asynchronous HTTP request, please pass async_req=True - - >>> thread = api.set_mapped_task_instance_note(dag_id, dag_run_id, task_id, map_index, set_task_instance_note, async_req=True) - >>> result = thread.get() - - Args: - dag_id (str): The DAG ID. - dag_run_id (str): The DAG run ID. - task_id (str): The task ID. - map_index (int): The map index. - set_task_instance_note (SetTaskInstanceNote): Parameters of set Task Instance note. - - Keyword Args: - _return_http_data_only (bool): response data without head status - code and headers. Default is True. - _preload_content (bool): if False, the urllib3.HTTPResponse object - will be returned without reading/decoding response data. - Default is True. - _request_timeout (int/float/tuple): 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. - Default is None. - _check_input_type (bool): specifies if type checking - should be done one the data sent to the server. - Default is True. - _check_return_type (bool): specifies if type checking - should be done one the data received from the server. - Default is True. - _host_index (int/None): specifies the index of the server - that we want to use. - Default is read from the configuration. - async_req (bool): execute request asynchronously - - Returns: - TaskInstance - If the method is called asynchronously, returns the request - thread. - """ - kwargs['async_req'] = kwargs.get( - 'async_req', False - ) - kwargs['_return_http_data_only'] = kwargs.get( - '_return_http_data_only', True - ) - kwargs['_preload_content'] = kwargs.get( - '_preload_content', True - ) - kwargs['_request_timeout'] = kwargs.get( - '_request_timeout', None - ) - kwargs['_check_input_type'] = kwargs.get( - '_check_input_type', True - ) - kwargs['_check_return_type'] = kwargs.get( - '_check_return_type', True - ) - kwargs['_host_index'] = kwargs.get('_host_index') - kwargs['dag_id'] = \ - dag_id - kwargs['dag_run_id'] = \ - dag_run_id - kwargs['task_id'] = \ - task_id - kwargs['map_index'] = \ - map_index - kwargs['set_task_instance_note'] = \ - set_task_instance_note - return self.set_mapped_task_instance_note_endpoint.call_with_http_info(**kwargs) - - def set_task_instance_note( - self, - dag_id, - dag_run_id, - task_id, - set_task_instance_note, - **kwargs - ): - """Update the TaskInstance note. # noqa: E501 - - Update the manual user note of a non-mapped Task Instance. *New in version 2.5.0* # noqa: E501 - This method makes a synchronous HTTP request by default. To make an - asynchronous HTTP request, please pass async_req=True - - >>> thread = api.set_task_instance_note(dag_id, dag_run_id, task_id, set_task_instance_note, async_req=True) - >>> result = thread.get() - - Args: - dag_id (str): The DAG ID. - dag_run_id (str): The DAG run ID. - task_id (str): The task ID. - set_task_instance_note (SetTaskInstanceNote): Parameters of set Task Instance note. - - Keyword Args: - _return_http_data_only (bool): response data without head status - code and headers. Default is True. - _preload_content (bool): if False, the urllib3.HTTPResponse object - will be returned without reading/decoding response data. - Default is True. - _request_timeout (int/float/tuple): 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. - Default is None. - _check_input_type (bool): specifies if type checking - should be done one the data sent to the server. - Default is True. - _check_return_type (bool): specifies if type checking - should be done one the data received from the server. - Default is True. - _host_index (int/None): specifies the index of the server - that we want to use. - Default is read from the configuration. - async_req (bool): execute request asynchronously - - Returns: - TaskInstance - If the method is called asynchronously, returns the request - thread. - """ - kwargs['async_req'] = kwargs.get( - 'async_req', False - ) - kwargs['_return_http_data_only'] = kwargs.get( - '_return_http_data_only', True - ) - kwargs['_preload_content'] = kwargs.get( - '_preload_content', True - ) - kwargs['_request_timeout'] = kwargs.get( - '_request_timeout', None - ) - kwargs['_check_input_type'] = kwargs.get( - '_check_input_type', True - ) - kwargs['_check_return_type'] = kwargs.get( - '_check_return_type', True - ) - kwargs['_host_index'] = kwargs.get('_host_index') - kwargs['dag_id'] = \ - dag_id - kwargs['dag_run_id'] = \ - dag_run_id - kwargs['task_id'] = \ - task_id - kwargs['set_task_instance_note'] = \ - set_task_instance_note - return self.set_task_instance_note_endpoint.call_with_http_info(**kwargs) - diff --git a/airflow_client/client/api/user_api.py b/airflow_client/client/api/user_api.py index 645f5a26..504ae241 100644 --- a/airflow_client/client/api/user_api.py +++ b/airflow_client/client/api/user_api.py @@ -60,7 +60,10 @@ def __init__(self, api_client=None): self.delete_user_endpoint = _Endpoint( settings={ 'response_type': None, - 'auth': [], + 'auth': [ + 'Basic', + 'Kerberos' + ], 'endpoint_path': '/users/{username}', 'operation_id': 'delete_user', 'http_method': 'DELETE', @@ -109,7 +112,10 @@ def __init__(self, api_client=None): self.get_user_endpoint = _Endpoint( settings={ 'response_type': (UserCollectionItem,), - 'auth': [], + 'auth': [ + 'Basic', + 'Kerberos' + ], 'endpoint_path': '/users/{username}', 'operation_id': 'get_user', 'http_method': 'GET', @@ -158,7 +164,10 @@ def __init__(self, api_client=None): self.get_users_endpoint = _Endpoint( settings={ 'response_type': (UserCollection,), - 'auth': [], + 'auth': [ + 'Basic', + 'Kerberos' + ], 'endpoint_path': '/users', 'operation_id': 'get_users', 'http_method': 'GET', @@ -220,7 +229,10 @@ def __init__(self, api_client=None): self.patch_user_endpoint = _Endpoint( settings={ 'response_type': (Role,), - 'auth': [], + 'auth': [ + 'Basic', + 'Kerberos' + ], 'endpoint_path': '/users/{username}', 'operation_id': 'patch_user', 'http_method': 'PATCH', @@ -282,7 +294,10 @@ def __init__(self, api_client=None): self.post_user_endpoint = _Endpoint( settings={ 'response_type': (User,), - 'auth': [], + 'auth': [ + 'Basic', + 'Kerberos' + ], 'endpoint_path': '/users', 'operation_id': 'post_user', 'http_method': 'POST', diff --git a/airflow_client/client/api/variable_api.py b/airflow_client/client/api/variable_api.py index 72fcfdf7..1ad11615 100644 --- a/airflow_client/client/api/variable_api.py +++ b/airflow_client/client/api/variable_api.py @@ -58,7 +58,10 @@ def __init__(self, api_client=None): self.delete_variable_endpoint = _Endpoint( settings={ 'response_type': None, - 'auth': [], + 'auth': [ + 'Basic', + 'Kerberos' + ], 'endpoint_path': '/variables/{variable_key}', 'operation_id': 'delete_variable', 'http_method': 'DELETE', @@ -107,7 +110,10 @@ def __init__(self, api_client=None): self.get_variable_endpoint = _Endpoint( settings={ 'response_type': (Variable,), - 'auth': [], + 'auth': [ + 'Basic', + 'Kerberos' + ], 'endpoint_path': '/variables/{variable_key}', 'operation_id': 'get_variable', 'http_method': 'GET', @@ -156,7 +162,10 @@ def __init__(self, api_client=None): self.get_variables_endpoint = _Endpoint( settings={ 'response_type': (VariableCollection,), - 'auth': [], + 'auth': [ + 'Basic', + 'Kerberos' + ], 'endpoint_path': '/variables', 'operation_id': 'get_variables', 'http_method': 'GET', @@ -218,7 +227,10 @@ def __init__(self, api_client=None): self.patch_variable_endpoint = _Endpoint( settings={ 'response_type': (Variable,), - 'auth': [], + 'auth': [ + 'Basic', + 'Kerberos' + ], 'endpoint_path': '/variables/{variable_key}', 'operation_id': 'patch_variable', 'http_method': 'PATCH', @@ -280,7 +292,10 @@ def __init__(self, api_client=None): self.post_variables_endpoint = _Endpoint( settings={ 'response_type': (Variable,), - 'auth': [], + 'auth': [ + 'Basic', + 'Kerberos' + ], 'endpoint_path': '/variables', 'operation_id': 'post_variables', 'http_method': 'POST', diff --git a/airflow_client/client/api/x_com_api.py b/airflow_client/client/api/x_com_api.py index 356931ad..6eaa4c7b 100644 --- a/airflow_client/client/api/x_com_api.py +++ b/airflow_client/client/api/x_com_api.py @@ -58,7 +58,10 @@ def __init__(self, api_client=None): self.get_xcom_entries_endpoint = _Endpoint( settings={ 'response_type': (XComCollection,), - 'auth': [], + 'auth': [ + 'Basic', + 'Kerberos' + ], 'endpoint_path': '/dags/{dag_id}/dagRuns/{dag_run_id}/taskInstances/{task_id}/xcomEntries', 'operation_id': 'get_xcom_entries', 'http_method': 'GET', @@ -134,7 +137,10 @@ def __init__(self, api_client=None): self.get_xcom_entry_endpoint = _Endpoint( settings={ 'response_type': (XCom,), - 'auth': [], + 'auth': [ + 'Basic', + 'Kerberos' + ], 'endpoint_path': '/dags/{dag_id}/dagRuns/{dag_run_id}/taskInstances/{task_id}/xcomEntries/{xcom_key}', 'operation_id': 'get_xcom_entry', 'http_method': 'GET', diff --git a/airflow_client/client/api_client.py b/airflow_client/client/api_client.py index 4be47810..0352afaa 100644 --- a/airflow_client/client/api_client.py +++ b/airflow_client/client/api_client.py @@ -94,7 +94,7 @@ def __init__(self, configuration=None, header_name=None, header_value=None, self.default_headers[header_name] = header_value self.cookie = cookie # Set default User-Agent. - self.user_agent = 'OpenAPI-Generator/2.3.0/python' + self.user_agent = 'OpenAPI-Generator/2.5.1/python' def __enter__(self): return self diff --git a/airflow_client/client/configuration.py b/airflow_client/client/configuration.py index 0f046005..7c3dce85 100644 --- a/airflow_client/client/configuration.py +++ b/airflow_client/client/configuration.py @@ -419,7 +419,7 @@ def to_debug_report(self): "OS: {env}\n"\ "Python Version: {pyversion}\n"\ "Version of the API: 2.5.0\n"\ - "SDK Package Version: 2.3.0".\ + "SDK Package Version: 2.5.1".\ format(env=sys.platform, pyversion=sys.version) def get_host_settings(self): diff --git a/airflow_client/docs/ConfigApi.md b/airflow_client/docs/ConfigApi.md index 4ca530c8..dca73a99 100644 --- a/airflow_client/docs/ConfigApi.md +++ b/airflow_client/docs/ConfigApi.md @@ -33,6 +33,7 @@ Get current configuration ### Example +* Basic Authentication (Basic): ```python import time @@ -47,9 +48,19 @@ 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 -with client.ApiClient() as api_client: +with client.ApiClient(configuration) as api_client: # Create an instance of the API class api_instance = config_api.ConfigApi(api_client) @@ -72,7 +83,7 @@ This endpoint does not need any parameter. ### Authorization -No authorization required +[Basic](../README.md#Basic), [Kerberos](../README.md#Kerberos) ### HTTP request headers diff --git a/airflow_client/docs/ConnectionApi.md b/airflow_client/docs/ConnectionApi.md index fb253562..10c2c08f 100644 --- a/airflow_client/docs/ConnectionApi.md +++ b/airflow_client/docs/ConnectionApi.md @@ -38,6 +38,7 @@ Delete a connection ### Example +* Basic Authentication (Basic): ```python import time @@ -51,9 +52,19 @@ 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 -with client.ApiClient() as api_client: +with client.ApiClient(configuration) as api_client: # Create an instance of the API class api_instance = connection_api.ConnectionApi(api_client) connection_id = "connection_id_example" # str | The connection ID. @@ -79,7 +90,7 @@ void (empty response body) ### Authorization -No authorization required +[Basic](../README.md#Basic), [Kerberos](../README.md#Kerberos) ### HTTP request headers @@ -106,6 +117,7 @@ Get a connection ### Example +* Basic Authentication (Basic): ```python import time @@ -120,9 +132,19 @@ 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 -with client.ApiClient() as api_client: +with client.ApiClient(configuration) as api_client: # Create an instance of the API class api_instance = connection_api.ConnectionApi(api_client) connection_id = "connection_id_example" # str | The connection ID. @@ -149,7 +171,7 @@ Name | Type | Description | Notes ### Authorization -No authorization required +[Basic](../README.md#Basic), [Kerberos](../README.md#Kerberos) ### HTTP request headers @@ -175,6 +197,7 @@ List connections ### Example +* Basic Authentication (Basic): ```python import time @@ -189,9 +212,19 @@ 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 -with client.ApiClient() as api_client: +with client.ApiClient(configuration) as api_client: # Create an instance of the API class api_instance = connection_api.ConnectionApi(api_client) limit = 100 # int | The numbers of items to return. (optional) if omitted the server will use the default value of 100 @@ -223,7 +256,7 @@ Name | Type | Description | Notes ### Authorization -No authorization required +[Basic](../README.md#Basic), [Kerberos](../README.md#Kerberos) ### HTTP request headers @@ -248,6 +281,7 @@ Update a connection ### Example +* Basic Authentication (Basic): ```python import time @@ -262,9 +296,19 @@ 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 -with client.ApiClient() as api_client: +with client.ApiClient(configuration) as api_client: # Create an instance of the API class api_instance = connection_api.ConnectionApi(api_client) connection_id = "connection_id_example" # str | The connection ID. @@ -306,7 +350,7 @@ Name | Type | Description | Notes ### Authorization -No authorization required +[Basic](../README.md#Basic), [Kerberos](../README.md#Kerberos) ### HTTP request headers @@ -333,6 +377,7 @@ Create a connection ### Example +* Basic Authentication (Basic): ```python import time @@ -347,9 +392,19 @@ 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 -with client.ApiClient() as api_client: +with client.ApiClient(configuration) as api_client: # Create an instance of the API class api_instance = connection_api.ConnectionApi(api_client) connection = Connection(None) # Connection | @@ -376,7 +431,7 @@ Name | Type | Description | Notes ### Authorization -No authorization required +[Basic](../README.md#Basic), [Kerberos](../README.md#Kerberos) ### HTTP request headers @@ -404,6 +459,7 @@ Test a connection. *New in version 2.2.0* ### Example +* Basic Authentication (Basic): ```python import time @@ -419,9 +475,19 @@ 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 -with client.ApiClient() as api_client: +with client.ApiClient(configuration) as api_client: # Create an instance of the API class api_instance = connection_api.ConnectionApi(api_client) connection = Connection(None) # Connection | @@ -448,7 +514,7 @@ Name | Type | Description | Notes ### Authorization -No authorization required +[Basic](../README.md#Basic), [Kerberos](../README.md#Kerberos) ### HTTP request headers diff --git a/airflow_client/docs/DAGApi.md b/airflow_client/docs/DAGApi.md index 5048243b..6def73a9 100644 --- a/airflow_client/docs/DAGApi.md +++ b/airflow_client/docs/DAGApi.md @@ -34,6 +34,8 @@ Method | HTTP request | Description [**patch_dags**](DAGApi.md#patch_dags) | **PATCH** /dags | Update DAGs [**post_clear_task_instances**](DAGApi.md#post_clear_task_instances) | **POST** /dags/{dag_id}/clearTaskInstances | Clear a set of task instances [**post_set_task_instances_state**](DAGApi.md#post_set_task_instances_state) | **POST** /dags/{dag_id}/updateTaskInstancesState | Set a state of task instances +[**set_mapped_task_instance_note**](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. +[**set_task_instance_note**](DAGApi.md#set_task_instance_note) | **PATCH** /dags/{dag_id}/dagRuns/{dag_run_id}/taskInstances/{task_id}/setNote | Update the TaskInstance note. # **delete_dag** @@ -45,6 +47,7 @@ Deletes all metadata related to the DAG, including finished DAG Runs and Tasks. ### Example +* Basic Authentication (Basic): ```python import time @@ -58,9 +61,19 @@ 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 -with client.ApiClient() as api_client: +with client.ApiClient(configuration) as api_client: # Create an instance of the API class api_instance = dag_api.DAGApi(api_client) dag_id = "dag_id_example" # str | The DAG ID. @@ -86,7 +99,7 @@ void (empty response body) ### Authorization -No authorization required +[Basic](../README.md#Basic), [Kerberos](../README.md#Kerberos) ### HTTP request headers @@ -116,6 +129,7 @@ Presents only information available in database (DAGModel). If you need detailed ### Example +* Basic Authentication (Basic): ```python import time @@ -130,9 +144,19 @@ 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 -with client.ApiClient() as api_client: +with client.ApiClient(configuration) as api_client: # Create an instance of the API class api_instance = dag_api.DAGApi(api_client) dag_id = "dag_id_example" # str | The DAG ID. @@ -159,7 +183,7 @@ Name | Type | Description | Notes ### Authorization -No authorization required +[Basic](../README.md#Basic), [Kerberos](../README.md#Kerberos) ### HTTP request headers @@ -187,6 +211,7 @@ The response contains many DAG attributes, so the response can be large. If poss ### Example +* Basic Authentication (Basic): ```python import time @@ -201,9 +226,19 @@ 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 -with client.ApiClient() as api_client: +with client.ApiClient(configuration) as api_client: # Create an instance of the API class api_instance = dag_api.DAGApi(api_client) dag_id = "dag_id_example" # str | The DAG ID. @@ -230,7 +265,7 @@ Name | Type | Description | Notes ### Authorization -No authorization required +[Basic](../README.md#Basic), [Kerberos](../README.md#Kerberos) ### HTTP request headers @@ -258,6 +293,7 @@ Get a source code using file token. ### Example +* Basic Authentication (Basic): ```python import time @@ -272,9 +308,19 @@ 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 -with client.ApiClient() as api_client: +with client.ApiClient(configuration) as api_client: # Create an instance of the API class api_instance = dag_api.DAGApi(api_client) file_token = "file_token_example" # str | The key containing the encrypted path to the file. Encryption and decryption take place only on the server. This prevents the client from reading an non-DAG file. This also ensures API extensibility, because the format of encrypted data may change. @@ -301,7 +347,7 @@ Name | Type | Description | Notes ### Authorization -No authorization required +[Basic](../README.md#Basic), [Kerberos](../README.md#Kerberos) ### HTTP request headers @@ -330,6 +376,7 @@ List DAGs in the database. `dag_id_pattern` can be set to match dags of a specif ### Example +* Basic Authentication (Basic): ```python import time @@ -344,9 +391,19 @@ 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 -with client.ApiClient() as api_client: +with client.ApiClient(configuration) as api_client: # Create an instance of the API class api_instance = dag_api.DAGApi(api_client) limit = 100 # int | The numbers of items to return. (optional) if omitted the server will use the default value of 100 @@ -386,7 +443,7 @@ Name | Type | Description | Notes ### Authorization -No authorization required +[Basic](../README.md#Basic), [Kerberos](../README.md#Kerberos) ### HTTP request headers @@ -410,6 +467,7 @@ Get simplified representation of a task ### Example +* Basic Authentication (Basic): ```python import time @@ -424,9 +482,19 @@ 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 -with client.ApiClient() as api_client: +with client.ApiClient(configuration) as api_client: # Create an instance of the API class api_instance = dag_api.DAGApi(api_client) dag_id = "dag_id_example" # str | The DAG ID. @@ -455,7 +523,7 @@ Name | Type | Description | Notes ### Authorization -No authorization required +[Basic](../README.md#Basic), [Kerberos](../README.md#Kerberos) ### HTTP request headers @@ -481,6 +549,7 @@ Get tasks for DAG ### Example +* Basic Authentication (Basic): ```python import time @@ -495,9 +564,19 @@ 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 -with client.ApiClient() as api_client: +with client.ApiClient(configuration) as api_client: # Create an instance of the API class api_instance = dag_api.DAGApi(api_client) dag_id = "dag_id_example" # str | The DAG ID. @@ -535,7 +614,7 @@ Name | Type | Description | Notes ### Authorization -No authorization required +[Basic](../README.md#Basic), [Kerberos](../README.md#Kerberos) ### HTTP request headers @@ -561,6 +640,7 @@ Update a DAG ### Example +* Basic Authentication (Basic): ```python import time @@ -575,9 +655,19 @@ 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 -with client.ApiClient() as api_client: +with client.ApiClient(configuration) as api_client: # Create an instance of the API class api_instance = dag_api.DAGApi(api_client) dag_id = "dag_id_example" # str | The DAG ID. @@ -621,7 +711,7 @@ Name | Type | Description | Notes ### Authorization -No authorization required +[Basic](../README.md#Basic), [Kerberos](../README.md#Kerberos) ### HTTP request headers @@ -649,6 +739,7 @@ Update DAGs of a given dag_id_pattern using UpdateMask. This endpoint allows spe ### Example +* Basic Authentication (Basic): ```python import time @@ -664,9 +755,19 @@ 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 -with client.ApiClient() as api_client: +with client.ApiClient(configuration) as api_client: # Create an instance of the API class api_instance = dag_api.DAGApi(api_client) dag_id_pattern = "dag_id_pattern_example" # str | If set, only update DAGs with dag_ids matching this pattern. @@ -720,7 +821,7 @@ Name | Type | Description | Notes ### Authorization -No authorization required +[Basic](../README.md#Basic), [Kerberos](../README.md#Kerberos) ### HTTP request headers @@ -748,6 +849,7 @@ Clears a set of task instances associated with the DAG for a specified date rang ### Example +* Basic Authentication (Basic): ```python import time @@ -763,9 +865,19 @@ 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 -with client.ApiClient() as api_client: +with client.ApiClient(configuration) as api_client: # Create an instance of the API class api_instance = dag_api.DAGApi(api_client) dag_id = "dag_id_example" # str | The DAG ID. @@ -811,7 +923,7 @@ Name | Type | Description | Notes ### Authorization -No authorization required +[Basic](../README.md#Basic), [Kerberos](../README.md#Kerberos) ### HTTP request headers @@ -839,6 +951,7 @@ Updates the state for multiple task instances simultaneously. ### Example +* Basic Authentication (Basic): ```python import time @@ -854,9 +967,19 @@ 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 -with client.ApiClient() as api_client: +with client.ApiClient(configuration) as api_client: # Create an instance of the API class api_instance = dag_api.DAGApi(api_client) dag_id = "dag_id_example" # str | The DAG ID. @@ -895,7 +1018,7 @@ Name | Type | Description | Notes ### Authorization -No authorization required +[Basic](../README.md#Basic), [Kerberos](../README.md#Kerberos) ### HTTP request headers @@ -914,3 +1037,189 @@ 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) +# **set_mapped_task_instance_note** +> TaskInstance set_mapped_task_instance_note(dag_id, dag_run_id, task_id, map_index, set_task_instance_note) + +Update the TaskInstance note. + +Update the manual user note of a mapped Task Instance. *New in version 2.5.0* + +### Example + +* Basic Authentication (Basic): + +```python +import time +import airflow_client.client +from airflow_client.client.api import dag_api +from airflow_client.client.model.set_task_instance_note import SetTaskInstanceNote +from airflow_client.client.model.task_instance import TaskInstance +from airflow_client.client.model.error import Error +from pprint import pprint +# Defining the host is optional and defaults to http://localhost/api/v1 +# See configuration.py for a list of all supported configuration parameters. +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 +with client.ApiClient(configuration) as api_client: + # Create an instance of the API class + api_instance = dag_api.DAGApi(api_client) + dag_id = "dag_id_example" # str | The DAG ID. + dag_run_id = "dag_run_id_example" # str | The DAG run ID. + task_id = "task_id_example" # str | The task ID. + map_index = 1 # int | The map index. + set_task_instance_note = SetTaskInstanceNote( + note="note_example", + ) # SetTaskInstanceNote | Parameters of set Task Instance note. + + # example passing only required values which don't have defaults set + try: + # Update the TaskInstance note. + api_response = api_instance.set_mapped_task_instance_note(dag_id, dag_run_id, task_id, map_index, set_task_instance_note) + pprint(api_response) + except client.ApiException as e: + print("Exception when calling DAGApi->set_mapped_task_instance_note: %s\n" % e) +``` + + +### Parameters + +Name | Type | Description | Notes +------------- | ------------- | ------------- | ------------- + **dag_id** | **str**| The DAG ID. | + **dag_run_id** | **str**| The DAG run ID. | + **task_id** | **str**| The task ID. | + **map_index** | **int**| The map index. | + **set_task_instance_note** | [**SetTaskInstanceNote**](SetTaskInstanceNote.md)| Parameters of set Task Instance note. | + +### Return type + +[**TaskInstance**](TaskInstance.md) + +### Authorization + +[Basic](../README.md#Basic), [Kerberos](../README.md#Kerberos) + +### HTTP request headers + + - **Content-Type**: application/json + - **Accept**: application/json + + +### HTTP response details + +| Status code | Description | Response headers | +|-------------|-------------|------------------| +**200** | Success. | - | +**400** | Client specified an invalid argument. | - | +**401** | Request not authenticated due to missing, invalid, authentication info. | - | +**403** | Client does not have sufficient permission. | - | +**404** | A specified resource is not found. | - | + +[[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) + +# **set_task_instance_note** +> TaskInstance set_task_instance_note(dag_id, dag_run_id, task_id, set_task_instance_note) + +Update the TaskInstance note. + +Update the manual user note of a non-mapped Task Instance. *New in version 2.5.0* + +### Example + +* Basic Authentication (Basic): + +```python +import time +import airflow_client.client +from airflow_client.client.api import dag_api +from airflow_client.client.model.set_task_instance_note import SetTaskInstanceNote +from airflow_client.client.model.task_instance import TaskInstance +from airflow_client.client.model.error import Error +from pprint import pprint +# Defining the host is optional and defaults to http://localhost/api/v1 +# See configuration.py for a list of all supported configuration parameters. +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 +with client.ApiClient(configuration) as api_client: + # Create an instance of the API class + api_instance = dag_api.DAGApi(api_client) + dag_id = "dag_id_example" # str | The DAG ID. + dag_run_id = "dag_run_id_example" # str | The DAG run ID. + task_id = "task_id_example" # str | The task ID. + set_task_instance_note = SetTaskInstanceNote( + note="note_example", + ) # SetTaskInstanceNote | Parameters of set Task Instance note. + + # example passing only required values which don't have defaults set + try: + # Update the TaskInstance note. + api_response = api_instance.set_task_instance_note(dag_id, dag_run_id, task_id, set_task_instance_note) + pprint(api_response) + except client.ApiException as e: + print("Exception when calling DAGApi->set_task_instance_note: %s\n" % e) +``` + + +### Parameters + +Name | Type | Description | Notes +------------- | ------------- | ------------- | ------------- + **dag_id** | **str**| The DAG ID. | + **dag_run_id** | **str**| The DAG run ID. | + **task_id** | **str**| The task ID. | + **set_task_instance_note** | [**SetTaskInstanceNote**](SetTaskInstanceNote.md)| Parameters of set Task Instance note. | + +### Return type + +[**TaskInstance**](TaskInstance.md) + +### Authorization + +[Basic](../README.md#Basic), [Kerberos](../README.md#Kerberos) + +### HTTP request headers + + - **Content-Type**: application/json + - **Accept**: application/json + + +### HTTP response details + +| Status code | Description | Response headers | +|-------------|-------------|------------------| +**200** | Success. | - | +**400** | Client specified an invalid argument. | - | +**401** | Request not authenticated due to missing, invalid, authentication info. | - | +**403** | Client does not have sufficient permission. | - | +**404** | A specified resource is not found. | - | + +[[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/airflow_client/docs/DAGRunApi.md b/airflow_client/docs/DAGRunApi.md index 06d83da8..293b6f72 100644 --- a/airflow_client/docs/DAGRunApi.md +++ b/airflow_client/docs/DAGRunApi.md @@ -43,6 +43,7 @@ Clear a DAG run. *New in version 2.4.0* ### Example +* Basic Authentication (Basic): ```python import time @@ -58,9 +59,19 @@ 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 -with client.ApiClient() as api_client: +with client.ApiClient(configuration) as api_client: # Create an instance of the API class api_instance = dag_run_api.DAGRunApi(api_client) dag_id = "dag_id_example" # str | The DAG ID. @@ -93,7 +104,7 @@ Name | Type | Description | Notes ### Authorization -No authorization required +[Basic](../README.md#Basic), [Kerberos](../README.md#Kerberos) ### HTTP request headers @@ -120,6 +131,7 @@ Delete a DAG run ### Example +* Basic Authentication (Basic): ```python import time @@ -133,9 +145,19 @@ 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 -with client.ApiClient() as api_client: +with client.ApiClient(configuration) as api_client: # Create an instance of the API class api_instance = dag_run_api.DAGRunApi(api_client) dag_id = "dag_id_example" # str | The DAG ID. @@ -163,7 +185,7 @@ void (empty response body) ### Authorization -No authorization required +[Basic](../README.md#Basic), [Kerberos](../README.md#Kerberos) ### HTTP request headers @@ -190,6 +212,7 @@ Get a DAG run ### Example +* Basic Authentication (Basic): ```python import time @@ -204,9 +227,19 @@ 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 -with client.ApiClient() as api_client: +with client.ApiClient(configuration) as api_client: # Create an instance of the API class api_instance = dag_run_api.DAGRunApi(api_client) dag_id = "dag_id_example" # str | The DAG ID. @@ -235,7 +268,7 @@ Name | Type | Description | Notes ### Authorization -No authorization required +[Basic](../README.md#Basic), [Kerberos](../README.md#Kerberos) ### HTTP request headers @@ -263,6 +296,7 @@ This endpoint allows specifying `~` as the dag_id to retrieve DAG runs for all D ### Example +* Basic Authentication (Basic): ```python import time @@ -277,9 +311,19 @@ 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 -with client.ApiClient() as api_client: +with client.ApiClient(configuration) as api_client: # Create an instance of the API class api_instance = dag_run_api.DAGRunApi(api_client) dag_id = "dag_id_example" # str | The DAG ID. @@ -337,7 +381,7 @@ Name | Type | Description | Notes ### Authorization -No authorization required +[Basic](../README.md#Basic), [Kerberos](../README.md#Kerberos) ### HTTP request headers @@ -363,6 +407,7 @@ This endpoint is a POST to allow filtering across a large number of DAG IDs, whe ### Example +* Basic Authentication (Basic): ```python import time @@ -378,9 +423,19 @@ 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 -with client.ApiClient() as api_client: +with client.ApiClient(configuration) as api_client: # Create an instance of the API class api_instance = dag_run_api.DAGRunApi(api_client) list_dag_runs_form = ListDagRunsForm( @@ -423,7 +478,7 @@ Name | Type | Description | Notes ### Authorization -No authorization required +[Basic](../README.md#Basic), [Kerberos](../README.md#Kerberos) ### HTTP request headers @@ -451,6 +506,7 @@ Get datasets for a dag run. *New in version 2.4.0* ### Example +* Basic Authentication (Basic): ```python import time @@ -465,9 +521,19 @@ 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 -with client.ApiClient() as api_client: +with client.ApiClient(configuration) as api_client: # Create an instance of the API class api_instance = dag_run_api.DAGRunApi(api_client) dag_id = "dag_id_example" # str | The DAG ID. @@ -496,7 +562,7 @@ Name | Type | Description | Notes ### Authorization -No authorization required +[Basic](../README.md#Basic), [Kerberos](../README.md#Kerberos) ### HTTP request headers @@ -522,6 +588,7 @@ Trigger a new DAG run ### Example +* Basic Authentication (Basic): ```python import time @@ -536,9 +603,19 @@ 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 -with client.ApiClient() as api_client: +with client.ApiClient(configuration) as api_client: # Create an instance of the API class api_instance = dag_run_api.DAGRunApi(api_client) dag_id = "dag_id_example" # str | The DAG ID. @@ -574,7 +651,7 @@ Name | Type | Description | Notes ### Authorization -No authorization required +[Basic](../README.md#Basic), [Kerberos](../README.md#Kerberos) ### HTTP request headers @@ -604,6 +681,7 @@ Update the manual user note of a DagRun. *New in version 2.5.0* ### Example +* Basic Authentication (Basic): ```python import time @@ -619,9 +697,19 @@ 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 -with client.ApiClient() as api_client: +with client.ApiClient(configuration) as api_client: # Create an instance of the API class api_instance = dag_run_api.DAGRunApi(api_client) dag_id = "dag_id_example" # str | The DAG ID. @@ -654,7 +742,7 @@ Name | Type | Description | Notes ### Authorization -No authorization required +[Basic](../README.md#Basic), [Kerberos](../README.md#Kerberos) ### HTTP request headers @@ -683,6 +771,7 @@ Modify a DAG run. *New in version 2.2.0* ### Example +* Basic Authentication (Basic): ```python import time @@ -698,9 +787,19 @@ 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 -with client.ApiClient() as api_client: +with client.ApiClient(configuration) as api_client: # Create an instance of the API class api_instance = dag_run_api.DAGRunApi(api_client) dag_id = "dag_id_example" # str | The DAG ID. @@ -733,7 +832,7 @@ Name | Type | Description | Notes ### Authorization -No authorization required +[Basic](../README.md#Basic), [Kerberos](../README.md#Kerberos) ### HTTP request headers diff --git a/airflow_client/docs/DagWarningApi.md b/airflow_client/docs/DagWarningApi.md index a2181d7d..f43d3d00 100644 --- a/airflow_client/docs/DagWarningApi.md +++ b/airflow_client/docs/DagWarningApi.md @@ -33,6 +33,7 @@ List dag warnings ### Example +* Basic Authentication (Basic): ```python import time @@ -47,9 +48,19 @@ 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 -with client.ApiClient() as api_client: +with client.ApiClient(configuration) as api_client: # Create an instance of the API class api_instance = dag_warning_api.DagWarningApi(api_client) dag_id = "dag_id_example" # str | If set, only return DAG warnings with this dag_id. (optional) @@ -85,7 +96,7 @@ Name | Type | Description | Notes ### Authorization -No authorization required +[Basic](../README.md#Basic), [Kerberos](../README.md#Kerberos) ### HTTP request headers diff --git a/airflow_client/docs/DatasetApi.md b/airflow_client/docs/DatasetApi.md index 8414d692..57386ad2 100644 --- a/airflow_client/docs/DatasetApi.md +++ b/airflow_client/docs/DatasetApi.md @@ -38,6 +38,7 @@ Get a dataset by uri. ### Example +* Basic Authentication (Basic): ```python import time @@ -52,9 +53,19 @@ 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 -with client.ApiClient() as api_client: +with client.ApiClient(configuration) as api_client: # Create an instance of the API class api_instance = dataset_api.DatasetApi(api_client) uri = "uri_example" # str | The encoded Dataset URI @@ -81,7 +92,7 @@ Name | Type | Description | Notes ### Authorization -No authorization required +[Basic](../README.md#Basic), [Kerberos](../README.md#Kerberos) ### HTTP request headers @@ -109,6 +120,7 @@ Get dataset events ### Example +* Basic Authentication (Basic): ```python import time @@ -123,9 +135,19 @@ 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 -with client.ApiClient() as api_client: +with client.ApiClient(configuration) as api_client: # Create an instance of the API class api_instance = dataset_api.DatasetApi(api_client) limit = 100 # int | The numbers of items to return. (optional) if omitted the server will use the default value of 100 @@ -167,7 +189,7 @@ Name | Type | Description | Notes ### Authorization -No authorization required +[Basic](../README.md#Basic), [Kerberos](../README.md#Kerberos) ### HTTP request headers @@ -193,6 +215,7 @@ List datasets ### Example +* Basic Authentication (Basic): ```python import time @@ -207,9 +230,19 @@ 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 -with client.ApiClient() as api_client: +with client.ApiClient(configuration) as api_client: # Create an instance of the API class api_instance = dataset_api.DatasetApi(api_client) limit = 100 # int | The numbers of items to return. (optional) if omitted the server will use the default value of 100 @@ -243,7 +276,7 @@ Name | Type | Description | Notes ### Authorization -No authorization required +[Basic](../README.md#Basic), [Kerberos](../README.md#Kerberos) ### HTTP request headers @@ -270,6 +303,7 @@ Get datasets for a dag run. *New in version 2.4.0* ### Example +* Basic Authentication (Basic): ```python import time @@ -284,9 +318,19 @@ 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 -with client.ApiClient() as api_client: +with client.ApiClient(configuration) as api_client: # Create an instance of the API class api_instance = dataset_api.DatasetApi(api_client) dag_id = "dag_id_example" # str | The DAG ID. @@ -315,7 +359,7 @@ Name | Type | Description | Notes ### Authorization -No authorization required +[Basic](../README.md#Basic), [Kerberos](../README.md#Kerberos) ### HTTP request headers diff --git a/airflow_client/docs/EventLogApi.md b/airflow_client/docs/EventLogApi.md index 2bde691d..b302ad29 100644 --- a/airflow_client/docs/EventLogApi.md +++ b/airflow_client/docs/EventLogApi.md @@ -34,6 +34,7 @@ Get a log entry ### Example +* Basic Authentication (Basic): ```python import time @@ -48,9 +49,19 @@ 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 -with client.ApiClient() as api_client: +with client.ApiClient(configuration) as api_client: # Create an instance of the API class api_instance = event_log_api.EventLogApi(api_client) event_log_id = 1 # int | The event log ID. @@ -77,7 +88,7 @@ Name | Type | Description | Notes ### Authorization -No authorization required +[Basic](../README.md#Basic), [Kerberos](../README.md#Kerberos) ### HTTP request headers @@ -105,6 +116,7 @@ List log entries from event log. ### Example +* Basic Authentication (Basic): ```python import time @@ -119,9 +131,19 @@ 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 -with client.ApiClient() as api_client: +with client.ApiClient(configuration) as api_client: # Create an instance of the API class api_instance = event_log_api.EventLogApi(api_client) limit = 100 # int | The numbers of items to return. (optional) if omitted the server will use the default value of 100 @@ -153,7 +175,7 @@ Name | Type | Description | Notes ### Authorization -No authorization required +[Basic](../README.md#Basic), [Kerberos](../README.md#Kerberos) ### HTTP request headers diff --git a/airflow_client/docs/ImportErrorApi.md b/airflow_client/docs/ImportErrorApi.md index 8d0645b1..095a2c06 100644 --- a/airflow_client/docs/ImportErrorApi.md +++ b/airflow_client/docs/ImportErrorApi.md @@ -34,6 +34,7 @@ Get an import error ### Example +* Basic Authentication (Basic): ```python import time @@ -48,9 +49,19 @@ 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 -with client.ApiClient() as api_client: +with client.ApiClient(configuration) as api_client: # Create an instance of the API class api_instance = import_error_api.ImportErrorApi(api_client) import_error_id = 1 # int | The import error ID. @@ -77,7 +88,7 @@ Name | Type | Description | Notes ### Authorization -No authorization required +[Basic](../README.md#Basic), [Kerberos](../README.md#Kerberos) ### HTTP request headers @@ -103,6 +114,7 @@ List import errors ### Example +* Basic Authentication (Basic): ```python import time @@ -117,9 +129,19 @@ 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 -with client.ApiClient() as api_client: +with client.ApiClient(configuration) as api_client: # Create an instance of the API class api_instance = import_error_api.ImportErrorApi(api_client) limit = 100 # int | The numbers of items to return. (optional) if omitted the server will use the default value of 100 @@ -151,7 +173,7 @@ Name | Type | Description | Notes ### Authorization -No authorization required +[Basic](../README.md#Basic), [Kerberos](../README.md#Kerberos) ### HTTP request headers diff --git a/airflow_client/docs/MonitoringApi.md b/airflow_client/docs/MonitoringApi.md index 17c6c4f2..ef3166d1 100644 --- a/airflow_client/docs/MonitoringApi.md +++ b/airflow_client/docs/MonitoringApi.md @@ -36,6 +36,7 @@ Get the status of Airflow's metadatabase and scheduler. It includes info about m ### Example +* Basic Authentication (Basic): ```python import time @@ -49,9 +50,19 @@ 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 -with client.ApiClient() as api_client: +with client.ApiClient(configuration) as api_client: # Create an instance of the API class api_instance = monitoring_api.MonitoringApi(api_client) @@ -74,7 +85,7 @@ This endpoint does not need any parameter. ### Authorization -No authorization required +[Basic](../README.md#Basic), [Kerberos](../README.md#Kerberos) ### HTTP request headers @@ -97,6 +108,7 @@ Get version information ### Example +* Basic Authentication (Basic): ```python import time @@ -110,9 +122,19 @@ 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 -with client.ApiClient() as api_client: +with client.ApiClient(configuration) as api_client: # Create an instance of the API class api_instance = monitoring_api.MonitoringApi(api_client) @@ -135,7 +157,7 @@ This endpoint does not need any parameter. ### Authorization -No authorization required +[Basic](../README.md#Basic), [Kerberos](../README.md#Kerberos) ### HTTP request headers diff --git a/airflow_client/docs/PermissionApi.md b/airflow_client/docs/PermissionApi.md index dde194d8..8a94381d 100644 --- a/airflow_client/docs/PermissionApi.md +++ b/airflow_client/docs/PermissionApi.md @@ -35,6 +35,7 @@ Get a list of permissions. *New in version 2.1.0* ### Example +* Basic Authentication (Basic): ```python import time @@ -49,9 +50,19 @@ 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 -with client.ApiClient() as api_client: +with client.ApiClient(configuration) as api_client: # Create an instance of the API class api_instance = permission_api.PermissionApi(api_client) limit = 100 # int | The numbers of items to return. (optional) if omitted the server will use the default value of 100 @@ -81,7 +92,7 @@ Name | Type | Description | Notes ### Authorization -No authorization required +[Basic](../README.md#Basic), [Kerberos](../README.md#Kerberos) ### HTTP request headers diff --git a/airflow_client/docs/PluginApi.md b/airflow_client/docs/PluginApi.md index a30c824e..e0aa9eb7 100644 --- a/airflow_client/docs/PluginApi.md +++ b/airflow_client/docs/PluginApi.md @@ -35,6 +35,7 @@ Get a list of loaded plugins. *New in version 2.1.0* ### Example +* Basic Authentication (Basic): ```python import time @@ -49,9 +50,19 @@ 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 -with client.ApiClient() as api_client: +with client.ApiClient(configuration) as api_client: # Create an instance of the API class api_instance = plugin_api.PluginApi(api_client) limit = 100 # int | The numbers of items to return. (optional) if omitted the server will use the default value of 100 @@ -81,7 +92,7 @@ Name | Type | Description | Notes ### Authorization -No authorization required +[Basic](../README.md#Basic), [Kerberos](../README.md#Kerberos) ### HTTP request headers diff --git a/airflow_client/docs/PoolApi.md b/airflow_client/docs/PoolApi.md index 17434158..f19fd278 100644 --- a/airflow_client/docs/PoolApi.md +++ b/airflow_client/docs/PoolApi.md @@ -37,6 +37,7 @@ Delete a pool ### Example +* Basic Authentication (Basic): ```python import time @@ -50,9 +51,19 @@ 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 -with client.ApiClient() as api_client: +with client.ApiClient(configuration) as api_client: # Create an instance of the API class api_instance = pool_api.PoolApi(api_client) pool_name = "pool_name_example" # str | The pool name. @@ -78,7 +89,7 @@ void (empty response body) ### Authorization -No authorization required +[Basic](../README.md#Basic), [Kerberos](../README.md#Kerberos) ### HTTP request headers @@ -105,6 +116,7 @@ Get a pool ### Example +* Basic Authentication (Basic): ```python import time @@ -119,9 +131,19 @@ 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 -with client.ApiClient() as api_client: +with client.ApiClient(configuration) as api_client: # Create an instance of the API class api_instance = pool_api.PoolApi(api_client) pool_name = "pool_name_example" # str | The pool name. @@ -148,7 +170,7 @@ Name | Type | Description | Notes ### Authorization -No authorization required +[Basic](../README.md#Basic), [Kerberos](../README.md#Kerberos) ### HTTP request headers @@ -174,6 +196,7 @@ List pools ### Example +* Basic Authentication (Basic): ```python import time @@ -188,9 +211,19 @@ 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 -with client.ApiClient() as api_client: +with client.ApiClient(configuration) as api_client: # Create an instance of the API class api_instance = pool_api.PoolApi(api_client) limit = 100 # int | The numbers of items to return. (optional) if omitted the server will use the default value of 100 @@ -222,7 +255,7 @@ Name | Type | Description | Notes ### Authorization -No authorization required +[Basic](../README.md#Basic), [Kerberos](../README.md#Kerberos) ### HTTP request headers @@ -247,6 +280,7 @@ Update a pool ### Example +* Basic Authentication (Basic): ```python import time @@ -261,9 +295,19 @@ 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 -with client.ApiClient() as api_client: +with client.ApiClient(configuration) as api_client: # Create an instance of the API class api_instance = pool_api.PoolApi(api_client) pool_name = "pool_name_example" # str | The pool name. @@ -309,7 +353,7 @@ Name | Type | Description | Notes ### Authorization -No authorization required +[Basic](../README.md#Basic), [Kerberos](../README.md#Kerberos) ### HTTP request headers @@ -337,6 +381,7 @@ Create a pool ### Example +* Basic Authentication (Basic): ```python import time @@ -351,9 +396,19 @@ 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 -with client.ApiClient() as api_client: +with client.ApiClient(configuration) as api_client: # Create an instance of the API class api_instance = pool_api.PoolApi(api_client) pool = Pool( @@ -384,7 +439,7 @@ Name | Type | Description | Notes ### Authorization -No authorization required +[Basic](../README.md#Basic), [Kerberos](../README.md#Kerberos) ### HTTP request headers diff --git a/airflow_client/docs/ProviderApi.md b/airflow_client/docs/ProviderApi.md index db95a589..4da287c0 100644 --- a/airflow_client/docs/ProviderApi.md +++ b/airflow_client/docs/ProviderApi.md @@ -35,6 +35,7 @@ Get a list of providers. *New in version 2.1.0* ### Example +* Basic Authentication (Basic): ```python import time @@ -48,9 +49,19 @@ 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 -with client.ApiClient() as api_client: +with client.ApiClient(configuration) as api_client: # Create an instance of the API class api_instance = provider_api.ProviderApi(api_client) @@ -73,7 +84,7 @@ This endpoint does not need any parameter. ### Authorization -No authorization required +[Basic](../README.md#Basic), [Kerberos](../README.md#Kerberos) ### HTTP request headers diff --git a/airflow_client/docs/RoleApi.md b/airflow_client/docs/RoleApi.md index 77bfe51d..85e0f48f 100644 --- a/airflow_client/docs/RoleApi.md +++ b/airflow_client/docs/RoleApi.md @@ -39,6 +39,7 @@ Delete a role. *New in version 2.1.0* ### Example +* Basic Authentication (Basic): ```python import time @@ -52,9 +53,19 @@ 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 -with client.ApiClient() as api_client: +with client.ApiClient(configuration) as api_client: # Create an instance of the API class api_instance = role_api.RoleApi(api_client) role_name = "role_name_example" # str | The role name @@ -80,7 +91,7 @@ void (empty response body) ### Authorization -No authorization required +[Basic](../README.md#Basic), [Kerberos](../README.md#Kerberos) ### HTTP request headers @@ -109,6 +120,7 @@ Get a role. *New in version 2.1.0* ### Example +* Basic Authentication (Basic): ```python import time @@ -123,9 +135,19 @@ 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 -with client.ApiClient() as api_client: +with client.ApiClient(configuration) as api_client: # Create an instance of the API class api_instance = role_api.RoleApi(api_client) role_name = "role_name_example" # str | The role name @@ -152,7 +174,7 @@ Name | Type | Description | Notes ### Authorization -No authorization required +[Basic](../README.md#Basic), [Kerberos](../README.md#Kerberos) ### HTTP request headers @@ -180,6 +202,7 @@ Get a list of roles. *New in version 2.1.0* ### Example +* Basic Authentication (Basic): ```python import time @@ -194,9 +217,19 @@ 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 -with client.ApiClient() as api_client: +with client.ApiClient(configuration) as api_client: # Create an instance of the API class api_instance = role_api.RoleApi(api_client) limit = 100 # int | The numbers of items to return. (optional) if omitted the server will use the default value of 100 @@ -228,7 +261,7 @@ Name | Type | Description | Notes ### Authorization -No authorization required +[Basic](../README.md#Basic), [Kerberos](../README.md#Kerberos) ### HTTP request headers @@ -255,6 +288,7 @@ Update a role. *New in version 2.1.0* ### Example +* Basic Authentication (Basic): ```python import time @@ -269,9 +303,19 @@ 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 -with client.ApiClient() as api_client: +with client.ApiClient(configuration) as api_client: # Create an instance of the API class api_instance = role_api.RoleApi(api_client) role_name = "role_name_example" # str | The role name @@ -325,7 +369,7 @@ Name | Type | Description | Notes ### Authorization -No authorization required +[Basic](../README.md#Basic), [Kerberos](../README.md#Kerberos) ### HTTP request headers @@ -354,6 +398,7 @@ Create a new role. *New in version 2.1.0* ### Example +* Basic Authentication (Basic): ```python import time @@ -368,9 +413,19 @@ 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 -with client.ApiClient() as api_client: +with client.ApiClient(configuration) as api_client: # Create an instance of the API class api_instance = role_api.RoleApi(api_client) role = Role( @@ -409,7 +464,7 @@ Name | Type | Description | Notes ### Authorization -No authorization required +[Basic](../README.md#Basic), [Kerberos](../README.md#Kerberos) ### HTTP request headers diff --git a/airflow_client/docs/TaskInstanceApi.md b/airflow_client/docs/TaskInstanceApi.md index 569a639e..de655d3b 100644 --- a/airflow_client/docs/TaskInstanceApi.md +++ b/airflow_client/docs/TaskInstanceApi.md @@ -32,8 +32,6 @@ Method | HTTP request | Description [**get_task_instances_batch**](TaskInstanceApi.md#get_task_instances_batch) | **POST** /dags/~/dagRuns/~/taskInstances/list | List task instances (batch) [**patch_mapped_task_instance**](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 [**patch_task_instance**](TaskInstanceApi.md#patch_task_instance) | **PATCH** /dags/{dag_id}/dagRuns/{dag_run_id}/taskInstances/{task_id} | Updates the state of a task instance -[**set_mapped_task_instance_note**](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. -[**set_task_instance_note**](TaskInstanceApi.md#set_task_instance_note) | **PATCH** /dags/{dag_id}/dagRuns/{dag_run_id}/taskInstances/{task_id}/setNote | Update the TaskInstance note. # **get_extra_links** @@ -45,6 +43,7 @@ List extra links for task instance. ### Example +* Basic Authentication (Basic): ```python import time @@ -59,9 +58,19 @@ 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 -with client.ApiClient() as api_client: +with client.ApiClient(configuration) as api_client: # Create an instance of the API class api_instance = task_instance_api.TaskInstanceApi(api_client) dag_id = "dag_id_example" # str | The DAG ID. @@ -92,7 +101,7 @@ Name | Type | Description | Notes ### Authorization -No authorization required +[Basic](../README.md#Basic), [Kerberos](../README.md#Kerberos) ### HTTP request headers @@ -120,6 +129,7 @@ Get logs for a specific task instance and its try number. ### Example +* Basic Authentication (Basic): ```python import time @@ -134,9 +144,19 @@ 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 -with client.ApiClient() as api_client: +with client.ApiClient(configuration) as api_client: # Create an instance of the API class api_instance = task_instance_api.TaskInstanceApi(api_client) dag_id = "dag_id_example" # str | The DAG ID. @@ -184,7 +204,7 @@ Name | Type | Description | Notes ### Authorization -No authorization required +[Basic](../README.md#Basic), [Kerberos](../README.md#Kerberos) ### HTTP request headers @@ -213,6 +233,7 @@ Get details of a mapped task instance. *New in version 2.3.0* ### Example +* Basic Authentication (Basic): ```python import time @@ -227,9 +248,19 @@ 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 -with client.ApiClient() as api_client: +with client.ApiClient(configuration) as api_client: # Create an instance of the API class api_instance = task_instance_api.TaskInstanceApi(api_client) dag_id = "dag_id_example" # str | The DAG ID. @@ -262,7 +293,7 @@ Name | Type | Description | Notes ### Authorization -No authorization required +[Basic](../README.md#Basic), [Kerberos](../README.md#Kerberos) ### HTTP request headers @@ -290,6 +321,7 @@ Get details of all mapped task instances. *New in version 2.3.0* ### Example +* Basic Authentication (Basic): ```python import time @@ -304,9 +336,19 @@ 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 -with client.ApiClient() as api_client: +with client.ApiClient(configuration) as api_client: # Create an instance of the API class api_instance = task_instance_api.TaskInstanceApi(api_client) dag_id = "dag_id_example" # str | The DAG ID. @@ -380,7 +422,7 @@ Name | Type | Description | Notes ### Authorization -No authorization required +[Basic](../README.md#Basic), [Kerberos](../README.md#Kerberos) ### HTTP request headers @@ -406,6 +448,7 @@ Get a task instance ### Example +* Basic Authentication (Basic): ```python import time @@ -420,9 +463,19 @@ 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 -with client.ApiClient() as api_client: +with client.ApiClient(configuration) as api_client: # Create an instance of the API class api_instance = task_instance_api.TaskInstanceApi(api_client) dag_id = "dag_id_example" # str | The DAG ID. @@ -453,7 +506,7 @@ Name | Type | Description | Notes ### Authorization -No authorization required +[Basic](../README.md#Basic), [Kerberos](../README.md#Kerberos) ### HTTP request headers @@ -481,6 +534,7 @@ This endpoint allows specifying `~` as the dag_id, dag_run_id to retrieve DAG ru ### Example +* Basic Authentication (Basic): ```python import time @@ -495,9 +549,19 @@ 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 -with client.ApiClient() as api_client: +with client.ApiClient(configuration) as api_client: # Create an instance of the API class api_instance = task_instance_api.TaskInstanceApi(api_client) dag_id = "dag_id_example" # str | The DAG ID. @@ -567,7 +631,7 @@ Name | Type | Description | Notes ### Authorization -No authorization required +[Basic](../README.md#Basic), [Kerberos](../README.md#Kerberos) ### HTTP request headers @@ -594,6 +658,7 @@ List task instances from all DAGs and DAG runs. This endpoint is a POST to allow ### Example +* Basic Authentication (Basic): ```python import time @@ -609,9 +674,19 @@ 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 -with client.ApiClient() as api_client: +with client.ApiClient(configuration) as api_client: # Create an instance of the API class api_instance = task_instance_api.TaskInstanceApi(api_client) list_task_instance_form = ListTaskInstanceForm( @@ -659,7 +734,7 @@ Name | Type | Description | Notes ### Authorization -No authorization required +[Basic](../README.md#Basic), [Kerberos](../README.md#Kerberos) ### HTTP request headers @@ -687,6 +762,7 @@ Updates the state for single mapped task instance. *New in version 2.5.0* ### Example +* Basic Authentication (Basic): ```python import time @@ -702,9 +778,19 @@ 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 -with client.ApiClient() as api_client: +with client.ApiClient(configuration) as api_client: # Create an instance of the API class api_instance = task_instance_api.TaskInstanceApi(api_client) dag_id = "dag_id_example" # str | The DAG ID. @@ -751,7 +837,7 @@ Name | Type | Description | Notes ### Authorization -No authorization required +[Basic](../README.md#Basic), [Kerberos](../README.md#Kerberos) ### HTTP request headers @@ -779,6 +865,7 @@ Updates the state for single task instance. *New in version 2.5.0* ### Example +* Basic Authentication (Basic): ```python import time @@ -794,9 +881,19 @@ 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 -with client.ApiClient() as api_client: +with client.ApiClient(configuration) as api_client: # Create an instance of the API class api_instance = task_instance_api.TaskInstanceApi(api_client) dag_id = "dag_id_example" # str | The DAG ID. @@ -832,7 +929,7 @@ Name | Type | Description | Notes ### Authorization -No authorization required +[Basic](../README.md#Basic), [Kerberos](../README.md#Kerberos) ### HTTP request headers @@ -851,167 +948,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) -# **set_mapped_task_instance_note** -> TaskInstance set_mapped_task_instance_note(dag_id, dag_run_id, task_id, map_index, set_task_instance_note) - -Update the TaskInstance note. - -Update the manual user note of a mapped Task Instance. *New in version 2.5.0* - -### Example - - -```python -import time -import airflow_client.client -from airflow_client.client.api import task_instance_api -from airflow_client.client.model.set_task_instance_note import SetTaskInstanceNote -from airflow_client.client.model.task_instance import TaskInstance -from airflow_client.client.model.error import Error -from pprint import pprint -# Defining the host is optional and defaults to http://localhost/api/v1 -# See configuration.py for a list of all supported configuration parameters. -configuration = client.Configuration( - host = "http://localhost/api/v1" -) - - -# Enter a context with an instance of the API client -with client.ApiClient() as api_client: - # Create an instance of the API class - api_instance = task_instance_api.TaskInstanceApi(api_client) - dag_id = "dag_id_example" # str | The DAG ID. - dag_run_id = "dag_run_id_example" # str | The DAG run ID. - task_id = "task_id_example" # str | The task ID. - map_index = 1 # int | The map index. - set_task_instance_note = SetTaskInstanceNote( - note="note_example", - ) # SetTaskInstanceNote | Parameters of set Task Instance note. - - # example passing only required values which don't have defaults set - try: - # Update the TaskInstance note. - api_response = api_instance.set_mapped_task_instance_note(dag_id, dag_run_id, task_id, map_index, set_task_instance_note) - pprint(api_response) - except client.ApiException as e: - print("Exception when calling TaskInstanceApi->set_mapped_task_instance_note: %s\n" % e) -``` - - -### Parameters - -Name | Type | Description | Notes -------------- | ------------- | ------------- | ------------- - **dag_id** | **str**| The DAG ID. | - **dag_run_id** | **str**| The DAG run ID. | - **task_id** | **str**| The task ID. | - **map_index** | **int**| The map index. | - **set_task_instance_note** | [**SetTaskInstanceNote**](SetTaskInstanceNote.md)| Parameters of set Task Instance note. | - -### Return type - -[**TaskInstance**](TaskInstance.md) - -### Authorization - -No authorization required - -### HTTP request headers - - - **Content-Type**: application/json - - **Accept**: application/json - - -### HTTP response details - -| Status code | Description | Response headers | -|-------------|-------------|------------------| -**200** | Success. | - | -**400** | Client specified an invalid argument. | - | -**401** | Request not authenticated due to missing, invalid, authentication info. | - | -**403** | Client does not have sufficient permission. | - | -**404** | A specified resource is not found. | - | - -[[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) - -# **set_task_instance_note** -> TaskInstance set_task_instance_note(dag_id, dag_run_id, task_id, set_task_instance_note) - -Update the TaskInstance note. - -Update the manual user note of a non-mapped Task Instance. *New in version 2.5.0* - -### Example - - -```python -import time -import airflow_client.client -from airflow_client.client.api import task_instance_api -from airflow_client.client.model.set_task_instance_note import SetTaskInstanceNote -from airflow_client.client.model.task_instance import TaskInstance -from airflow_client.client.model.error import Error -from pprint import pprint -# Defining the host is optional and defaults to http://localhost/api/v1 -# See configuration.py for a list of all supported configuration parameters. -configuration = client.Configuration( - host = "http://localhost/api/v1" -) - - -# Enter a context with an instance of the API client -with client.ApiClient() as api_client: - # Create an instance of the API class - api_instance = task_instance_api.TaskInstanceApi(api_client) - dag_id = "dag_id_example" # str | The DAG ID. - dag_run_id = "dag_run_id_example" # str | The DAG run ID. - task_id = "task_id_example" # str | The task ID. - set_task_instance_note = SetTaskInstanceNote( - note="note_example", - ) # SetTaskInstanceNote | Parameters of set Task Instance note. - - # example passing only required values which don't have defaults set - try: - # Update the TaskInstance note. - api_response = api_instance.set_task_instance_note(dag_id, dag_run_id, task_id, set_task_instance_note) - pprint(api_response) - except client.ApiException as e: - print("Exception when calling TaskInstanceApi->set_task_instance_note: %s\n" % e) -``` - - -### Parameters - -Name | Type | Description | Notes -------------- | ------------- | ------------- | ------------- - **dag_id** | **str**| The DAG ID. | - **dag_run_id** | **str**| The DAG run ID. | - **task_id** | **str**| The task ID. | - **set_task_instance_note** | [**SetTaskInstanceNote**](SetTaskInstanceNote.md)| Parameters of set Task Instance note. | - -### Return type - -[**TaskInstance**](TaskInstance.md) - -### Authorization - -No authorization required - -### HTTP request headers - - - **Content-Type**: application/json - - **Accept**: application/json - - -### HTTP response details - -| Status code | Description | Response headers | -|-------------|-------------|------------------| -**200** | Success. | - | -**400** | Client specified an invalid argument. | - | -**401** | Request not authenticated due to missing, invalid, authentication info. | - | -**403** | Client does not have sufficient permission. | - | -**404** | A specified resource is not found. | - | - -[[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/airflow_client/docs/UserApi.md b/airflow_client/docs/UserApi.md index 9dbe522c..07a6711c 100644 --- a/airflow_client/docs/UserApi.md +++ b/airflow_client/docs/UserApi.md @@ -39,6 +39,7 @@ Delete a user with a specific username. *New in version 2.2.0* ### Example +* Basic Authentication (Basic): ```python import time @@ -52,9 +53,19 @@ 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 -with client.ApiClient() as api_client: +with client.ApiClient(configuration) as api_client: # Create an instance of the API class api_instance = user_api.UserApi(api_client) username = "username_example" # str | The username of the user. *New in version 2.1.0* @@ -80,7 +91,7 @@ void (empty response body) ### Authorization -No authorization required +[Basic](../README.md#Basic), [Kerberos](../README.md#Kerberos) ### HTTP request headers @@ -109,6 +120,7 @@ Get a user with a specific username. *New in version 2.1.0* ### Example +* Basic Authentication (Basic): ```python import time @@ -123,9 +135,19 @@ 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 -with client.ApiClient() as api_client: +with client.ApiClient(configuration) as api_client: # Create an instance of the API class api_instance = user_api.UserApi(api_client) username = "username_example" # str | The username of the user. *New in version 2.1.0* @@ -152,7 +174,7 @@ Name | Type | Description | Notes ### Authorization -No authorization required +[Basic](../README.md#Basic), [Kerberos](../README.md#Kerberos) ### HTTP request headers @@ -180,6 +202,7 @@ Get a list of users. *New in version 2.1.0* ### Example +* Basic Authentication (Basic): ```python import time @@ -194,9 +217,19 @@ 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 -with client.ApiClient() as api_client: +with client.ApiClient(configuration) as api_client: # Create an instance of the API class api_instance = user_api.UserApi(api_client) limit = 100 # int | The numbers of items to return. (optional) if omitted the server will use the default value of 100 @@ -228,7 +261,7 @@ Name | Type | Description | Notes ### Authorization -No authorization required +[Basic](../README.md#Basic), [Kerberos](../README.md#Kerberos) ### HTTP request headers @@ -255,6 +288,7 @@ Update fields for a user. *New in version 2.2.0* ### Example +* Basic Authentication (Basic): ```python import time @@ -270,9 +304,19 @@ 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 -with client.ApiClient() as api_client: +with client.ApiClient(configuration) as api_client: # Create an instance of the API class api_instance = user_api.UserApi(api_client) username = "username_example" # str | The username of the user. *New in version 2.1.0* @@ -314,7 +358,7 @@ Name | Type | Description | Notes ### Authorization -No authorization required +[Basic](../README.md#Basic), [Kerberos](../README.md#Kerberos) ### HTTP request headers @@ -343,6 +387,7 @@ Create a new user with unique username and email. *New in version 2.2.0* ### Example +* Basic Authentication (Basic): ```python import time @@ -357,9 +402,19 @@ 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 -with client.ApiClient() as api_client: +with client.ApiClient(configuration) as api_client: # Create an instance of the API class api_instance = user_api.UserApi(api_client) user = User() # User | @@ -386,7 +441,7 @@ Name | Type | Description | Notes ### Authorization -No authorization required +[Basic](../README.md#Basic), [Kerberos](../README.md#Kerberos) ### HTTP request headers diff --git a/airflow_client/docs/VariableApi.md b/airflow_client/docs/VariableApi.md index d5a43339..f8c099e1 100644 --- a/airflow_client/docs/VariableApi.md +++ b/airflow_client/docs/VariableApi.md @@ -37,6 +37,7 @@ Delete a variable ### Example +* Basic Authentication (Basic): ```python import time @@ -50,9 +51,19 @@ 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 -with client.ApiClient() as api_client: +with client.ApiClient(configuration) as api_client: # Create an instance of the API class api_instance = variable_api.VariableApi(api_client) variable_key = "variable_key_example" # str | The variable Key. @@ -78,7 +89,7 @@ void (empty response body) ### Authorization -No authorization required +[Basic](../README.md#Basic), [Kerberos](../README.md#Kerberos) ### HTTP request headers @@ -107,6 +118,7 @@ Get a variable by key. ### Example +* Basic Authentication (Basic): ```python import time @@ -121,9 +133,19 @@ 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 -with client.ApiClient() as api_client: +with client.ApiClient(configuration) as api_client: # Create an instance of the API class api_instance = variable_api.VariableApi(api_client) variable_key = "variable_key_example" # str | The variable Key. @@ -150,7 +172,7 @@ Name | Type | Description | Notes ### Authorization -No authorization required +[Basic](../README.md#Basic), [Kerberos](../README.md#Kerberos) ### HTTP request headers @@ -178,6 +200,7 @@ The collection does not contain data. To get data, you must get a single entity. ### Example +* Basic Authentication (Basic): ```python import time @@ -192,9 +215,19 @@ 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 -with client.ApiClient() as api_client: +with client.ApiClient(configuration) as api_client: # Create an instance of the API class api_instance = variable_api.VariableApi(api_client) limit = 100 # int | The numbers of items to return. (optional) if omitted the server will use the default value of 100 @@ -226,7 +259,7 @@ Name | Type | Description | Notes ### Authorization -No authorization required +[Basic](../README.md#Basic), [Kerberos](../README.md#Kerberos) ### HTTP request headers @@ -253,6 +286,7 @@ Update a variable by key. ### Example +* Basic Authentication (Basic): ```python import time @@ -267,9 +301,19 @@ 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 -with client.ApiClient() as api_client: +with client.ApiClient(configuration) as api_client: # Create an instance of the API class api_instance = variable_api.VariableApi(api_client) variable_key = "variable_key_example" # str | The variable Key. @@ -311,7 +355,7 @@ Name | Type | Description | Notes ### Authorization -No authorization required +[Basic](../README.md#Basic), [Kerberos](../README.md#Kerberos) ### HTTP request headers @@ -338,6 +382,7 @@ Create a variable ### Example +* Basic Authentication (Basic): ```python import time @@ -352,9 +397,19 @@ 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 -with client.ApiClient() as api_client: +with client.ApiClient(configuration) as api_client: # Create an instance of the API class api_instance = variable_api.VariableApi(api_client) variable = Variable(None) # Variable | @@ -381,7 +436,7 @@ Name | Type | Description | Notes ### Authorization -No authorization required +[Basic](../README.md#Basic), [Kerberos](../README.md#Kerberos) ### HTTP request headers diff --git a/airflow_client/docs/XComApi.md b/airflow_client/docs/XComApi.md index 05c2f3ad..aa1f7df9 100644 --- a/airflow_client/docs/XComApi.md +++ b/airflow_client/docs/XComApi.md @@ -36,6 +36,7 @@ This endpoint allows specifying `~` as the dag_id, dag_run_id, task_id to retrie ### Example +* Basic Authentication (Basic): ```python import time @@ -50,9 +51,19 @@ 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 -with client.ApiClient() as api_client: +with client.ApiClient(configuration) as api_client: # Create an instance of the API class api_instance = x_com_api.XComApi(api_client) dag_id = "dag_id_example" # str | The DAG ID. @@ -96,7 +107,7 @@ Name | Type | Description | Notes ### Authorization -No authorization required +[Basic](../README.md#Basic), [Kerberos](../README.md#Kerberos) ### HTTP request headers @@ -121,6 +132,7 @@ Get an XCom entry ### Example +* Basic Authentication (Basic): ```python import time @@ -135,9 +147,19 @@ 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 -with client.ApiClient() as api_client: +with client.ApiClient(configuration) as api_client: # Create an instance of the API class api_instance = x_com_api.XComApi(api_client) dag_id = "dag_id_example" # str | The DAG ID. @@ -181,7 +203,7 @@ Name | Type | Description | Notes ### Authorization -No authorization required +[Basic](../README.md#Basic), [Kerberos](../README.md#Kerberos) ### HTTP request headers diff --git a/airflow_client/test/test_dag_api.py b/airflow_client/test/test_dag_api.py index 24d7a5d8..48675e9b 100644 --- a/airflow_client/test/test_dag_api.py +++ b/airflow_client/test/test_dag_api.py @@ -118,6 +118,20 @@ def test_post_set_task_instances_state(self): """ pass + def test_set_mapped_task_instance_note(self): + """Test case for set_mapped_task_instance_note + + Update the TaskInstance note. # noqa: E501 + """ + pass + + def test_set_task_instance_note(self): + """Test case for set_task_instance_note + + Update the TaskInstance note. # noqa: E501 + """ + pass + if __name__ == '__main__': unittest.main() diff --git a/airflow_client/test/test_task_instance_api.py b/airflow_client/test/test_task_instance_api.py index f1a433b6..b18b1309 100644 --- a/airflow_client/test/test_task_instance_api.py +++ b/airflow_client/test/test_task_instance_api.py @@ -104,20 +104,6 @@ def test_patch_task_instance(self): """ pass - def test_set_mapped_task_instance_note(self): - """Test case for set_mapped_task_instance_note - - Update the TaskInstance note. # noqa: E501 - """ - pass - - def test_set_task_instance_note(self): - """Test case for set_task_instance_note - - Update the TaskInstance note. # noqa: E501 - """ - pass - if __name__ == '__main__': unittest.main() diff --git a/setup.py b/setup.py index d9c3921a..61d37238 100644 --- a/setup.py +++ b/setup.py @@ -25,7 +25,7 @@ from setuptools import find_packages, setup # noqa: H301 -VERSION = "2.5.0" +VERSION = "2.5.1" # To install the library, run the following # # python setup.py install @@ -41,7 +41,7 @@ setup( version=VERSION, keywords=["OpenAPI", "OpenAPI-Generator", "Apache Airflow API (Stable)"], - download_url=('https://archive.apache.org/dist/airflow/clients/python/' + VERSION), + download_url=("https://archive.apache.org/dist/airflow/clients/python/" + VERSION), install_requires=REQUIRES, - packages=find_packages(exclude=["test", "tests"]) + packages=find_packages(exclude=["test", "tests"]), )