Version 2.5.1 (#63)
diff --git a/CHANGELOG.md b/CHANGELOG.md
index c1597e9..19dc9ca 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 61f1e2b..62e7932 100644
--- a/airflow_client/README.md
+++ b/airflow_client/README.md
@@ -231,7 +231,7 @@
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 @@
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 @@
*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 @@
*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 c30a036..4818145 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 e9e67f8..27e30e5 100644
--- a/airflow_client/client/api/config_api.py
+++ b/airflow_client/client/api/config_api.py
@@ -57,7 +57,10 @@
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 9081d93..eeb554b 100644
--- a/airflow_client/client/api/connection_api.py
+++ b/airflow_client/client/api/connection_api.py
@@ -59,7 +59,10 @@
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 @@
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 @@
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 @@
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 @@
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 @@
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 703de52..165c6af 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 @@
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 @@
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 @@
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 @@
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 @@
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 @@
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 @@
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 @@
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 @@
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 @@
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 @@
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 @@
},
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 @@
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 d0994f8..0b10d0a 100644
--- a/airflow_client/client/api/dag_run_api.py
+++ b/airflow_client/client/api/dag_run_api.py
@@ -63,7 +63,10 @@
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 @@
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 @@
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 @@
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 @@
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 @@
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 @@
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 @@
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 @@
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 66a67da..3476e3b 100644
--- a/airflow_client/client/api/dag_warning_api.py
+++ b/airflow_client/client/api/dag_warning_api.py
@@ -57,7 +57,10 @@
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 ded6001..e2c7831 100644
--- a/airflow_client/client/api/dataset_api.py
+++ b/airflow_client/client/api/dataset_api.py
@@ -59,7 +59,10 @@
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 @@
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 @@
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 @@
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 700eed6..e2b8fc5 100644
--- a/airflow_client/client/api/event_log_api.py
+++ b/airflow_client/client/api/event_log_api.py
@@ -58,7 +58,10 @@
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 @@
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 5715a7b..8098522 100644
--- a/airflow_client/client/api/import_error_api.py
+++ b/airflow_client/client/api/import_error_api.py
@@ -58,7 +58,10 @@
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 @@
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 fc1b65e..4a665d3 100644
--- a/airflow_client/client/api/monitoring_api.py
+++ b/airflow_client/client/api/monitoring_api.py
@@ -57,7 +57,10 @@
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 @@
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 705503c..bdd3835 100644
--- a/airflow_client/client/api/permission_api.py
+++ b/airflow_client/client/api/permission_api.py
@@ -57,7 +57,10 @@
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 4051872..6c10006 100644
--- a/airflow_client/client/api/plugin_api.py
+++ b/airflow_client/client/api/plugin_api.py
@@ -57,7 +57,10 @@
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 10cf5ef..d86f7dc 100644
--- a/airflow_client/client/api/pool_api.py
+++ b/airflow_client/client/api/pool_api.py
@@ -58,7 +58,10 @@
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 @@
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 @@
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 @@
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 @@
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 de71e35..fd88eae 100644
--- a/airflow_client/client/api/provider_api.py
+++ b/airflow_client/client/api/provider_api.py
@@ -56,7 +56,10 @@
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 108d378..a33cdc4 100644
--- a/airflow_client/client/api/role_api.py
+++ b/airflow_client/client/api/role_api.py
@@ -58,7 +58,10 @@
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 @@
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 @@
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 @@
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 @@
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 6970b38..7828a84 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 @@
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 @@
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 @@
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 @@
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 @@
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 @@
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 @@
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 @@
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 @@
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 @@
},
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 @@
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 645f5a2..504ae24 100644
--- a/airflow_client/client/api/user_api.py
+++ b/airflow_client/client/api/user_api.py
@@ -60,7 +60,10 @@
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 @@
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 @@
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 @@
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 @@
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 72fcfdf..1ad1161 100644
--- a/airflow_client/client/api/variable_api.py
+++ b/airflow_client/client/api/variable_api.py
@@ -58,7 +58,10 @@
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 @@
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 @@
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 @@
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 @@
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 356931a..6eaa4c7 100644
--- a/airflow_client/client/api/x_com_api.py
+++ b/airflow_client/client/api/x_com_api.py
@@ -58,7 +58,10 @@
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 @@
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 4be4781..0352afa 100644
--- a/airflow_client/client/api_client.py
+++ b/airflow_client/client/api_client.py
@@ -94,7 +94,7 @@
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 0f04600..7c3dce8 100644
--- a/airflow_client/client/configuration.py
+++ b/airflow_client/client/configuration.py
@@ -419,7 +419,7 @@
"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 4ca530c..dca73a9 100644
--- a/airflow_client/docs/ConfigApi.md
+++ b/airflow_client/docs/ConfigApi.md
@@ -33,6 +33,7 @@
### Example
+* Basic Authentication (Basic):
```python
import time
@@ -47,9 +48,19 @@
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 @@
### 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 fb25356..10c2c08 100644
--- a/airflow_client/docs/ConnectionApi.md
+++ b/airflow_client/docs/ConnectionApi.md
@@ -38,6 +38,7 @@
### Example
+* Basic Authentication (Basic):
```python
import time
@@ -51,9 +52,19 @@
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 @@
### Authorization
-No authorization required
+[Basic](../README.md#Basic), [Kerberos](../README.md#Kerberos)
### HTTP request headers
@@ -106,6 +117,7 @@
### Example
+* Basic Authentication (Basic):
```python
import time
@@ -120,9 +132,19 @@
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 @@
### Authorization
-No authorization required
+[Basic](../README.md#Basic), [Kerberos](../README.md#Kerberos)
### HTTP request headers
@@ -175,6 +197,7 @@
### Example
+* Basic Authentication (Basic):
```python
import time
@@ -189,9 +212,19 @@
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 @@
### Authorization
-No authorization required
+[Basic](../README.md#Basic), [Kerberos](../README.md#Kerberos)
### HTTP request headers
@@ -248,6 +281,7 @@
### Example
+* Basic Authentication (Basic):
```python
import time
@@ -262,9 +296,19 @@
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 @@
### Authorization
-No authorization required
+[Basic](../README.md#Basic), [Kerberos](../README.md#Kerberos)
### HTTP request headers
@@ -333,6 +377,7 @@
### Example
+* Basic Authentication (Basic):
```python
import time
@@ -347,9 +392,19 @@
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 @@
### Authorization
-No authorization required
+[Basic](../README.md#Basic), [Kerberos](../README.md#Kerberos)
### HTTP request headers
@@ -404,6 +459,7 @@
### Example
+* Basic Authentication (Basic):
```python
import time
@@ -419,9 +475,19 @@
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 @@
### 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 5048243..6def73a 100644
--- a/airflow_client/docs/DAGApi.md
+++ b/airflow_client/docs/DAGApi.md
@@ -34,6 +34,8 @@
[**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 @@
### Example
+* Basic Authentication (Basic):
```python
import time
@@ -58,9 +61,19 @@
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 @@
### Authorization
-No authorization required
+[Basic](../README.md#Basic), [Kerberos](../README.md#Kerberos)
### HTTP request headers
@@ -116,6 +129,7 @@
### Example
+* Basic Authentication (Basic):
```python
import time
@@ -130,9 +144,19 @@
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 @@
### Authorization
-No authorization required
+[Basic](../README.md#Basic), [Kerberos](../README.md#Kerberos)
### HTTP request headers
@@ -187,6 +211,7 @@
### Example
+* Basic Authentication (Basic):
```python
import time
@@ -201,9 +226,19 @@
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 @@
### Authorization
-No authorization required
+[Basic](../README.md#Basic), [Kerberos](../README.md#Kerberos)
### HTTP request headers
@@ -258,6 +293,7 @@
### Example
+* Basic Authentication (Basic):
```python
import time
@@ -272,9 +308,19 @@
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 @@
### Authorization
-No authorization required
+[Basic](../README.md#Basic), [Kerberos](../README.md#Kerberos)
### HTTP request headers
@@ -330,6 +376,7 @@
### Example
+* Basic Authentication (Basic):
```python
import time
@@ -344,9 +391,19 @@
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 @@
### Authorization
-No authorization required
+[Basic](../README.md#Basic), [Kerberos](../README.md#Kerberos)
### HTTP request headers
@@ -410,6 +467,7 @@
### Example
+* Basic Authentication (Basic):
```python
import time
@@ -424,9 +482,19 @@
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 @@
### Authorization
-No authorization required
+[Basic](../README.md#Basic), [Kerberos](../README.md#Kerberos)
### HTTP request headers
@@ -481,6 +549,7 @@
### Example
+* Basic Authentication (Basic):
```python
import time
@@ -495,9 +564,19 @@
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 @@
### Authorization
-No authorization required
+[Basic](../README.md#Basic), [Kerberos](../README.md#Kerberos)
### HTTP request headers
@@ -561,6 +640,7 @@
### Example
+* Basic Authentication (Basic):
```python
import time
@@ -575,9 +655,19 @@
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 @@
### Authorization
-No authorization required
+[Basic](../README.md#Basic), [Kerberos](../README.md#Kerberos)
### HTTP request headers
@@ -649,6 +739,7 @@
### Example
+* Basic Authentication (Basic):
```python
import time
@@ -664,9 +755,19 @@
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 @@
### Authorization
-No authorization required
+[Basic](../README.md#Basic), [Kerberos](../README.md#Kerberos)
### HTTP request headers
@@ -748,6 +849,7 @@
### Example
+* Basic Authentication (Basic):
```python
import time
@@ -763,9 +865,19 @@
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 @@
### Authorization
-No authorization required
+[Basic](../README.md#Basic), [Kerberos](../README.md#Kerberos)
### HTTP request headers
@@ -839,6 +951,7 @@
### Example
+* Basic Authentication (Basic):
```python
import time
@@ -854,9 +967,19 @@
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 @@
### Authorization
-No authorization required
+[Basic](../README.md#Basic), [Kerberos](../README.md#Kerberos)
### HTTP request headers
@@ -914,3 +1037,189 @@
[[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 06d83da..293b6f7 100644
--- a/airflow_client/docs/DAGRunApi.md
+++ b/airflow_client/docs/DAGRunApi.md
@@ -43,6 +43,7 @@
### Example
+* Basic Authentication (Basic):
```python
import time
@@ -58,9 +59,19 @@
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 @@
### Authorization
-No authorization required
+[Basic](../README.md#Basic), [Kerberos](../README.md#Kerberos)
### HTTP request headers
@@ -120,6 +131,7 @@
### Example
+* Basic Authentication (Basic):
```python
import time
@@ -133,9 +145,19 @@
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 @@
### Authorization
-No authorization required
+[Basic](../README.md#Basic), [Kerberos](../README.md#Kerberos)
### HTTP request headers
@@ -190,6 +212,7 @@
### Example
+* Basic Authentication (Basic):
```python
import time
@@ -204,9 +227,19 @@
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 @@
### Authorization
-No authorization required
+[Basic](../README.md#Basic), [Kerberos](../README.md#Kerberos)
### HTTP request headers
@@ -263,6 +296,7 @@
### Example
+* Basic Authentication (Basic):
```python
import time
@@ -277,9 +311,19 @@
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 @@
### Authorization
-No authorization required
+[Basic](../README.md#Basic), [Kerberos](../README.md#Kerberos)
### HTTP request headers
@@ -363,6 +407,7 @@
### Example
+* Basic Authentication (Basic):
```python
import time
@@ -378,9 +423,19 @@
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 @@
### Authorization
-No authorization required
+[Basic](../README.md#Basic), [Kerberos](../README.md#Kerberos)
### HTTP request headers
@@ -451,6 +506,7 @@
### Example
+* Basic Authentication (Basic):
```python
import time
@@ -465,9 +521,19 @@
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 @@
### Authorization
-No authorization required
+[Basic](../README.md#Basic), [Kerberos](../README.md#Kerberos)
### HTTP request headers
@@ -522,6 +588,7 @@
### Example
+* Basic Authentication (Basic):
```python
import time
@@ -536,9 +603,19 @@
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 @@
### Authorization
-No authorization required
+[Basic](../README.md#Basic), [Kerberos](../README.md#Kerberos)
### HTTP request headers
@@ -604,6 +681,7 @@
### Example
+* Basic Authentication (Basic):
```python
import time
@@ -619,9 +697,19 @@
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 @@
### Authorization
-No authorization required
+[Basic](../README.md#Basic), [Kerberos](../README.md#Kerberos)
### HTTP request headers
@@ -683,6 +771,7 @@
### Example
+* Basic Authentication (Basic):
```python
import time
@@ -698,9 +787,19 @@
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 @@
### 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 a2181d7..f43d3d0 100644
--- a/airflow_client/docs/DagWarningApi.md
+++ b/airflow_client/docs/DagWarningApi.md
@@ -33,6 +33,7 @@
### Example
+* Basic Authentication (Basic):
```python
import time
@@ -47,9 +48,19 @@
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 @@
### 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 8414d69..57386ad 100644
--- a/airflow_client/docs/DatasetApi.md
+++ b/airflow_client/docs/DatasetApi.md
@@ -38,6 +38,7 @@
### Example
+* Basic Authentication (Basic):
```python
import time
@@ -52,9 +53,19 @@
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 @@
### Authorization
-No authorization required
+[Basic](../README.md#Basic), [Kerberos](../README.md#Kerberos)
### HTTP request headers
@@ -109,6 +120,7 @@
### Example
+* Basic Authentication (Basic):
```python
import time
@@ -123,9 +135,19 @@
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 @@
### Authorization
-No authorization required
+[Basic](../README.md#Basic), [Kerberos](../README.md#Kerberos)
### HTTP request headers
@@ -193,6 +215,7 @@
### Example
+* Basic Authentication (Basic):
```python
import time
@@ -207,9 +230,19 @@
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 @@
### Authorization
-No authorization required
+[Basic](../README.md#Basic), [Kerberos](../README.md#Kerberos)
### HTTP request headers
@@ -270,6 +303,7 @@
### Example
+* Basic Authentication (Basic):
```python
import time
@@ -284,9 +318,19 @@
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 @@
### 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 2bde691..b302ad2 100644
--- a/airflow_client/docs/EventLogApi.md
+++ b/airflow_client/docs/EventLogApi.md
@@ -34,6 +34,7 @@
### Example
+* Basic Authentication (Basic):
```python
import time
@@ -48,9 +49,19 @@
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 @@
### Authorization
-No authorization required
+[Basic](../README.md#Basic), [Kerberos](../README.md#Kerberos)
### HTTP request headers
@@ -105,6 +116,7 @@
### Example
+* Basic Authentication (Basic):
```python
import time
@@ -119,9 +131,19 @@
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 @@
### 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 8d0645b..095a2c0 100644
--- a/airflow_client/docs/ImportErrorApi.md
+++ b/airflow_client/docs/ImportErrorApi.md
@@ -34,6 +34,7 @@
### Example
+* Basic Authentication (Basic):
```python
import time
@@ -48,9 +49,19 @@
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 @@
### Authorization
-No authorization required
+[Basic](../README.md#Basic), [Kerberos](../README.md#Kerberos)
### HTTP request headers
@@ -103,6 +114,7 @@
### Example
+* Basic Authentication (Basic):
```python
import time
@@ -117,9 +129,19 @@
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 @@
### 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 17c6c4f..ef3166d 100644
--- a/airflow_client/docs/MonitoringApi.md
+++ b/airflow_client/docs/MonitoringApi.md
@@ -36,6 +36,7 @@
### Example
+* Basic Authentication (Basic):
```python
import time
@@ -49,9 +50,19 @@
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 @@
### Authorization
-No authorization required
+[Basic](../README.md#Basic), [Kerberos](../README.md#Kerberos)
### HTTP request headers
@@ -97,6 +108,7 @@
### Example
+* Basic Authentication (Basic):
```python
import time
@@ -110,9 +122,19 @@
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 @@
### 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 dde194d..8a94381 100644
--- a/airflow_client/docs/PermissionApi.md
+++ b/airflow_client/docs/PermissionApi.md
@@ -35,6 +35,7 @@
### Example
+* Basic Authentication (Basic):
```python
import time
@@ -49,9 +50,19 @@
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 @@
### 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 a30c824..e0aa9eb 100644
--- a/airflow_client/docs/PluginApi.md
+++ b/airflow_client/docs/PluginApi.md
@@ -35,6 +35,7 @@
### Example
+* Basic Authentication (Basic):
```python
import time
@@ -49,9 +50,19 @@
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 @@
### 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 1743415..f19fd27 100644
--- a/airflow_client/docs/PoolApi.md
+++ b/airflow_client/docs/PoolApi.md
@@ -37,6 +37,7 @@
### Example
+* Basic Authentication (Basic):
```python
import time
@@ -50,9 +51,19 @@
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 @@
### Authorization
-No authorization required
+[Basic](../README.md#Basic), [Kerberos](../README.md#Kerberos)
### HTTP request headers
@@ -105,6 +116,7 @@
### Example
+* Basic Authentication (Basic):
```python
import time
@@ -119,9 +131,19 @@
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 @@
### Authorization
-No authorization required
+[Basic](../README.md#Basic), [Kerberos](../README.md#Kerberos)
### HTTP request headers
@@ -174,6 +196,7 @@
### Example
+* Basic Authentication (Basic):
```python
import time
@@ -188,9 +211,19 @@
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 @@
### Authorization
-No authorization required
+[Basic](../README.md#Basic), [Kerberos](../README.md#Kerberos)
### HTTP request headers
@@ -247,6 +280,7 @@
### Example
+* Basic Authentication (Basic):
```python
import time
@@ -261,9 +295,19 @@
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 @@
### Authorization
-No authorization required
+[Basic](../README.md#Basic), [Kerberos](../README.md#Kerberos)
### HTTP request headers
@@ -337,6 +381,7 @@
### Example
+* Basic Authentication (Basic):
```python
import time
@@ -351,9 +396,19 @@
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 @@
### 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 db95a58..4da287c 100644
--- a/airflow_client/docs/ProviderApi.md
+++ b/airflow_client/docs/ProviderApi.md
@@ -35,6 +35,7 @@
### Example
+* Basic Authentication (Basic):
```python
import time
@@ -48,9 +49,19 @@
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 @@
### 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 77bfe51..85e0f48 100644
--- a/airflow_client/docs/RoleApi.md
+++ b/airflow_client/docs/RoleApi.md
@@ -39,6 +39,7 @@
### Example
+* Basic Authentication (Basic):
```python
import time
@@ -52,9 +53,19 @@
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 @@
### Authorization
-No authorization required
+[Basic](../README.md#Basic), [Kerberos](../README.md#Kerberos)
### HTTP request headers
@@ -109,6 +120,7 @@
### Example
+* Basic Authentication (Basic):
```python
import time
@@ -123,9 +135,19 @@
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 @@
### Authorization
-No authorization required
+[Basic](../README.md#Basic), [Kerberos](../README.md#Kerberos)
### HTTP request headers
@@ -180,6 +202,7 @@
### Example
+* Basic Authentication (Basic):
```python
import time
@@ -194,9 +217,19 @@
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 @@
### Authorization
-No authorization required
+[Basic](../README.md#Basic), [Kerberos](../README.md#Kerberos)
### HTTP request headers
@@ -255,6 +288,7 @@
### Example
+* Basic Authentication (Basic):
```python
import time
@@ -269,9 +303,19 @@
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 @@
### Authorization
-No authorization required
+[Basic](../README.md#Basic), [Kerberos](../README.md#Kerberos)
### HTTP request headers
@@ -354,6 +398,7 @@
### Example
+* Basic Authentication (Basic):
```python
import time
@@ -368,9 +413,19 @@
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 @@
### 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 569a639..de655d3 100644
--- a/airflow_client/docs/TaskInstanceApi.md
+++ b/airflow_client/docs/TaskInstanceApi.md
@@ -32,8 +32,6 @@
[**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 @@
### Example
+* Basic Authentication (Basic):
```python
import time
@@ -59,9 +58,19 @@
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 @@
### Authorization
-No authorization required
+[Basic](../README.md#Basic), [Kerberos](../README.md#Kerberos)
### HTTP request headers
@@ -120,6 +129,7 @@
### Example
+* Basic Authentication (Basic):
```python
import time
@@ -134,9 +144,19 @@
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 @@
### Authorization
-No authorization required
+[Basic](../README.md#Basic), [Kerberos](../README.md#Kerberos)
### HTTP request headers
@@ -213,6 +233,7 @@
### Example
+* Basic Authentication (Basic):
```python
import time
@@ -227,9 +248,19 @@
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 @@
### Authorization
-No authorization required
+[Basic](../README.md#Basic), [Kerberos](../README.md#Kerberos)
### HTTP request headers
@@ -290,6 +321,7 @@
### Example
+* Basic Authentication (Basic):
```python
import time
@@ -304,9 +336,19 @@
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 @@
### Authorization
-No authorization required
+[Basic](../README.md#Basic), [Kerberos](../README.md#Kerberos)
### HTTP request headers
@@ -406,6 +448,7 @@
### Example
+* Basic Authentication (Basic):
```python
import time
@@ -420,9 +463,19 @@
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 @@
### Authorization
-No authorization required
+[Basic](../README.md#Basic), [Kerberos](../README.md#Kerberos)
### HTTP request headers
@@ -481,6 +534,7 @@
### Example
+* Basic Authentication (Basic):
```python
import time
@@ -495,9 +549,19 @@
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 @@
### Authorization
-No authorization required
+[Basic](../README.md#Basic), [Kerberos](../README.md#Kerberos)
### HTTP request headers
@@ -594,6 +658,7 @@
### Example
+* Basic Authentication (Basic):
```python
import time
@@ -609,9 +674,19 @@
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 @@
### Authorization
-No authorization required
+[Basic](../README.md#Basic), [Kerberos](../README.md#Kerberos)
### HTTP request headers
@@ -687,6 +762,7 @@
### Example
+* Basic Authentication (Basic):
```python
import time
@@ -702,9 +778,19 @@
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 @@
### Authorization
-No authorization required
+[Basic](../README.md#Basic), [Kerberos](../README.md#Kerberos)
### HTTP request headers
@@ -779,6 +865,7 @@
### Example
+* Basic Authentication (Basic):
```python
import time
@@ -794,9 +881,19 @@
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 @@
### Authorization
-No authorization required
+[Basic](../README.md#Basic), [Kerberos](../README.md#Kerberos)
### HTTP request headers
@@ -851,167 +948,3 @@
[[Back to top]](#) [[Back to API list]](../README.md#documentation-for-api-endpoints) [[Back to Model list]](../README.md#documentation-for-models) [[Back to README]](../README.md)
-# **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 9dbe522..07a6711 100644
--- a/airflow_client/docs/UserApi.md
+++ b/airflow_client/docs/UserApi.md
@@ -39,6 +39,7 @@
### Example
+* Basic Authentication (Basic):
```python
import time
@@ -52,9 +53,19 @@
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 @@
### Authorization
-No authorization required
+[Basic](../README.md#Basic), [Kerberos](../README.md#Kerberos)
### HTTP request headers
@@ -109,6 +120,7 @@
### Example
+* Basic Authentication (Basic):
```python
import time
@@ -123,9 +135,19 @@
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 @@
### Authorization
-No authorization required
+[Basic](../README.md#Basic), [Kerberos](../README.md#Kerberos)
### HTTP request headers
@@ -180,6 +202,7 @@
### Example
+* Basic Authentication (Basic):
```python
import time
@@ -194,9 +217,19 @@
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 @@
### Authorization
-No authorization required
+[Basic](../README.md#Basic), [Kerberos](../README.md#Kerberos)
### HTTP request headers
@@ -255,6 +288,7 @@
### Example
+* Basic Authentication (Basic):
```python
import time
@@ -270,9 +304,19 @@
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 @@
### Authorization
-No authorization required
+[Basic](../README.md#Basic), [Kerberos](../README.md#Kerberos)
### HTTP request headers
@@ -343,6 +387,7 @@
### Example
+* Basic Authentication (Basic):
```python
import time
@@ -357,9 +402,19 @@
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 @@
### 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 d5a4333..f8c099e 100644
--- a/airflow_client/docs/VariableApi.md
+++ b/airflow_client/docs/VariableApi.md
@@ -37,6 +37,7 @@
### Example
+* Basic Authentication (Basic):
```python
import time
@@ -50,9 +51,19 @@
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 @@
### Authorization
-No authorization required
+[Basic](../README.md#Basic), [Kerberos](../README.md#Kerberos)
### HTTP request headers
@@ -107,6 +118,7 @@
### Example
+* Basic Authentication (Basic):
```python
import time
@@ -121,9 +133,19 @@
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 @@
### Authorization
-No authorization required
+[Basic](../README.md#Basic), [Kerberos](../README.md#Kerberos)
### HTTP request headers
@@ -178,6 +200,7 @@
### Example
+* Basic Authentication (Basic):
```python
import time
@@ -192,9 +215,19 @@
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 @@
### Authorization
-No authorization required
+[Basic](../README.md#Basic), [Kerberos](../README.md#Kerberos)
### HTTP request headers
@@ -253,6 +286,7 @@
### Example
+* Basic Authentication (Basic):
```python
import time
@@ -267,9 +301,19 @@
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 @@
### Authorization
-No authorization required
+[Basic](../README.md#Basic), [Kerberos](../README.md#Kerberos)
### HTTP request headers
@@ -338,6 +382,7 @@
### Example
+* Basic Authentication (Basic):
```python
import time
@@ -352,9 +397,19 @@
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 @@
### 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 05c2f3a..aa1f7df 100644
--- a/airflow_client/docs/XComApi.md
+++ b/airflow_client/docs/XComApi.md
@@ -36,6 +36,7 @@
### Example
+* Basic Authentication (Basic):
```python
import time
@@ -50,9 +51,19 @@
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 @@
### Authorization
-No authorization required
+[Basic](../README.md#Basic), [Kerberos](../README.md#Kerberos)
### HTTP request headers
@@ -121,6 +132,7 @@
### Example
+* Basic Authentication (Basic):
```python
import time
@@ -135,9 +147,19 @@
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 @@
### 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 24d7a5d..48675e9 100644
--- a/airflow_client/test/test_dag_api.py
+++ b/airflow_client/test/test_dag_api.py
@@ -118,6 +118,20 @@
"""
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 f1a433b..b18b130 100644
--- a/airflow_client/test/test_task_instance_api.py
+++ b/airflow_client/test/test_task_instance_api.py
@@ -104,20 +104,6 @@
"""
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 d9c3921..61d3723 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"]),
)
