🔐 Sid Gifari File Manager Pro
v8.0.5 | 2026-08-08 17:54:14 | PHP 8.2.32
📂
/ (Root)
/
opt
/
alt
/
python38
/
lib
/
python3.8
/
site-packages
/
influxdb_client
/
service
/
__pycache__
📍 /opt/alt/python38/lib/python3.8/site-packages/influxdb_client/service/__pycache__
🔄 Refresh
✏️
Editing: tasks_service.cpython-38.pyc
Read Only
U w�i�= � @ s8 d Z ddlmZ ddlZddlmZ G dd� de�ZdS )a InfluxDB OSS API Service. The InfluxDB v2 API provides a programmatic interface for all interactions with InfluxDB. Access the InfluxDB API using the `/api/v2/` endpoint. # noqa: E501 OpenAPI spec version: 2.0.0 Generated by: https://openapi-generator.tech � )�absolute_importN)� _BaseServicec s� e Zd ZdZd�� fdd� Zdd� Zdd� Zd d � Zd d � Zd d� Z dd� Z dd� Z dd� Z dd� Z dd� Zdd� Zdd � Zd d � Zd d � Zd!d"� Zd#d$� Zd%d&� Zd'd(� Zd)d*� Zd+d,� Zd-d.� Zd/d0� Zd1d2� Zd3d4� Z d5d6� Z d7d8� Z d9d:� Z d;d<� Z d=d>� Z!d?d@� Z"dAdB� Z#dCdD� Z$dEdF� Z%dGdH� Z&dIdJ� Z'dKdL� Z(dMdN� Z)dOdP� Z*dQdR� Z+dSdT� Z,dUdV� Z-dWdX� Z.dYdZ� Z/d[d\� Z0d]d^� Z1d_d`� Z2dadb� Z3dcdd� Z4dedf� Z5dgdh� Z6didj� Z7dkdl� Z8dmdn� Z9dodp� Z:dqdr� Z;dsdt� Z<dudv� Z=dwdx� Z>dydz� Z?d{d|� Z@d}d~� ZAdd�� ZBd�d�� ZCd�d�� ZDd�d�� ZEd�d�� ZFd�d�� ZGd�d�� ZHd�d�� ZId�d�� ZJd�d�� ZKd�d�� ZLd�d�� ZMd�d�� ZNd�d�� ZOd�d�� ZPd�d�� ZQd�d�� ZRd�d�� ZSd�d�� ZTd�d�� ZUd�d�� ZVd�d�� ZWd�d�� ZX� ZYS )�� TasksServicez�NOTE: This class is auto generated by OpenAPI Generator. Ref: https://openapi-generator.tech Do not edit the class manually. Nc s t � �|� dS )z.TasksService - a operation defined in OpenAPI.N)�super�__init__)�self� api_client�� __class__� �V/opt/alt/python38/lib/python3.8/site-packages/influxdb_client/service/tasks_service.pyr s zTasksService.__init__c K s6 d|d< |� d�r | j|f|�S | j|f|�}|S dS )ap Delete a task. Deletes a task and associated records. Use this endpoint to delete a task and all associated records (task runs, logs, and labels). Once the task is deleted, InfluxDB cancels all scheduled runs of the task. If you want to disable a task instead of delete it, [update the task status to `inactive`](#operation/PatchTasksID). This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.delete_tasks_id(task_id, async_req=True) >>> result = thread.get() :param async_req bool :param str task_id: The ID of the task to delete. (required) :param str zap_trace_span: OpenTracing span context :return: None If the method is called asynchronously, returns the request thread. T�_return_http_data_only� async_reqN)�get� delete_tasks_id_with_http_info�r �task_id�kwargs�datar r r �delete_tasks_id s z TasksService.delete_tasks_idc K sf | j |f|�\}}}}}| jjdd||||g i dg |�d�|�d�|�dd�|�d�i |�d d�d �S ) a Delete a task. Deletes a task and associated records. Use this endpoint to delete a task and all associated records (task runs, logs, and labels). Once the task is deleted, InfluxDB cancels all scheduled runs of the task. If you want to disable a task instead of delete it, [update the task status to `inactive`](#operation/PatchTasksID). This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.delete_tasks_id_with_http_info(task_id, async_req=True) >>> result = thread.get() :param async_req bool :param str task_id: The ID of the task to delete. (required) :param str zap_trace_span: OpenTracing span context :return: None If the method is called asynchronously, returns the request thread. �/api/v2/tasks/{taskID}�DELETENr r �_preload_contentT�_request_timeout� urlopen_kw� �bodyZ post_params�filesZ response_typeZ auth_settingsr r r r Zcollection_formatsr ��_delete_tasks_id_preparer �call_apir �r r r �local_var_params� path_params� query_params� header_params� body_paramsr r r r 7 s( � �z+TasksService.delete_tasks_id_with_http_infoc � sl | j |f|�\}}}}}| jjdd||||g i dg |�d�|�d�|�dd�|�d�i |�d d�d �I dH S ) a� Delete a task. Deletes a task and associated records. Use this endpoint to delete a task and all associated records (task runs, logs, and labels). Once the task is deleted, InfluxDB cancels all scheduled runs of the task. If you want to disable a task instead of delete it, [update the task status to `inactive`](#operation/PatchTasksID). This method makes an asynchronous HTTP request. :param async_req bool :param str task_id: The ID of the task to delete. (required) :param str zap_trace_span: OpenTracing span context :return: None If the method is called asynchronously, returns the request thread. r r Nr r r Tr r r r r! r r r �delete_tasks_id_async[ s( � �z"TasksService.delete_tasks_id_asyncc K s� t � }ddg}| �d||� d|ks0|d d kr8td��i }d|krP|d |d< g }i }d|krl|d |d< d }| j�dg�|d< |||||fS ) Nr �zap_trace_spanr zGMissing the required parameter `task_id` when calling `delete_tasks_id`�taskID�Zap-Trace-Span�application/json�Accept��locals�_check_operation_params� ValueErrorr �select_header_accept� r r r r" � all_paramsr# r$ r% r& r r r r | s& � �z%TasksService._delete_tasks_id_preparec K s: d|d< |� d�r"| j||f|�S | j||f|�}|S dS )a� Delete a label from a task. Deletes a label from a task. This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.delete_tasks_id_labels_id(task_id, label_id, async_req=True) >>> result = thread.get() :param async_req bool :param str task_id: The ID of the task to delete the label from. (required) :param str label_id: The ID of the label to delete. (required) :param str zap_trace_span: OpenTracing span context :return: None If the method is called asynchronously, returns the request thread. Tr r N)r �(delete_tasks_id_labels_id_with_http_info)r r �label_idr r r r r �delete_tasks_id_labels_id� s z&TasksService.delete_tasks_id_labels_idc K sh | j ||f|�\}}}}}| jjdd||||g i dg |�d�|�d�|�dd�|�d�i |�d d�d �S ) a� Delete a label from a task. Deletes a label from a task. This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.delete_tasks_id_labels_id_with_http_info(task_id, label_id, async_req=True) >>> result = thread.get() :param async_req bool :param str task_id: The ID of the task to delete the label from. (required) :param str label_id: The ID of the label to delete. (required) :param str zap_trace_span: OpenTracing span context :return: None If the method is called asynchronously, returns the request thread. �'/api/v2/tasks/{taskID}/labels/{labelID}r Nr r r Tr r r ��"_delete_tasks_id_labels_id_preparer r r � r r r5 r r" r# r$ r% r& r r r r4 � s( � �z5TasksService.delete_tasks_id_labels_id_with_http_infoc � sn | j ||f|�\}}}}}| jjdd||||g i dg |�d�|�d�|�dd�|�d�i |�d d�d �I dH S ) a� Delete a label from a task. Deletes a label from a task. This method makes an asynchronous HTTP request. :param async_req bool :param str task_id: The ID of the task to delete the label from. (required) :param str label_id: The ID of the label to delete. (required) :param str zap_trace_span: OpenTracing span context :return: None If the method is called asynchronously, returns the request thread. r7 r Nr r r Tr r r r8 r: r r r � delete_tasks_id_labels_id_async� s( � �z,TasksService.delete_tasks_id_labels_id_asyncc K s� t � }dddg}| �d||� d|ks2|d d kr:td��d|ksN|d d krVtd��i }d|krn|d |d< d|kr�|d |d< g }i }d|kr�|d |d < d } | j�d g�|d < ||||| fS ) Nr r5 r( r6 zQMissing the required parameter `task_id` when calling `delete_tasks_id_labels_id`zRMissing the required parameter `label_id` when calling `delete_tasks_id_labels_id`r) ZlabelIDr* r+ r, r- ) r r r5 r r" r3 r# r$ r% r& r r r r9 � s2 � � �z/TasksService._delete_tasks_id_labels_id_preparec K s: d|d< |� d�r"| j||f|�S | j||f|�}|S dS )a� Remove a member from a task. **Deprecated**: Tasks don't use `owner` and `member` roles. Use [`/api/v2/authorizations`](#tag/Authorizations-(API-tokens)) to assign user permissions. Removes a member from a [task](https://docs.influxdata.com/influxdb/latest/reference/glossary/#task). This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.delete_tasks_id_members_id(user_id, task_id, async_req=True) >>> result = thread.get() :param async_req bool :param str user_id: The ID of the member to remove. (required) :param str task_id: The task ID. (required) :param str zap_trace_span: OpenTracing span context :return: None If the method is called asynchronously, returns the request thread. Tr r N)r �)delete_tasks_id_members_id_with_http_info�r �user_idr r r r r r �delete_tasks_id_members_id s z'TasksService.delete_tasks_id_members_idc K sh | j ||f|�\}}}}}| jjdd||||g i dg |�d�|�d�|�dd�|�d�i |�d d�d �S ) a� Remove a member from a task. **Deprecated**: Tasks don't use `owner` and `member` roles. Use [`/api/v2/authorizations`](#tag/Authorizations-(API-tokens)) to assign user permissions. Removes a member from a [task](https://docs.influxdata.com/influxdb/latest/reference/glossary/#task). This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.delete_tasks_id_members_id_with_http_info(user_id, task_id, async_req=True) >>> result = thread.get() :param async_req bool :param str user_id: The ID of the member to remove. (required) :param str task_id: The task ID. (required) :param str zap_trace_span: OpenTracing span context :return: None If the method is called asynchronously, returns the request thread. �'/api/v2/tasks/{taskID}/members/{userID}r Nr r r Tr r r ��#_delete_tasks_id_members_id_preparer r r � r r> r r r" r# r$ r% r& r r r r< / s( � �z6TasksService.delete_tasks_id_members_id_with_http_infoc � sn | j ||f|�\}}}}}| jjdd||||g i dg |�d�|�d�|�dd�|�d�i |�d d�d �I dH S ) a� Remove a member from a task. **Deprecated**: Tasks don't use `owner` and `member` roles. Use [`/api/v2/authorizations`](#tag/Authorizations-(API-tokens)) to assign user permissions. Removes a member from a [task](https://docs.influxdata.com/influxdb/latest/reference/glossary/#task). This method makes an asynchronous HTTP request. :param async_req bool :param str user_id: The ID of the member to remove. (required) :param str task_id: The task ID. (required) :param str zap_trace_span: OpenTracing span context :return: None If the method is called asynchronously, returns the request thread. r@ r Nr r r Tr r r rA rC r r r � delete_tasks_id_members_id_asyncT s( � �z-TasksService.delete_tasks_id_members_id_asyncc K s� t � }dddg}| �d||� d|ks2|d d kr:td��d|ksN|d d krVtd��i }d|krn|d |d< d|kr�|d |d< g }i }d|kr�|d |d < d } | j�d g�|d < ||||| fS ) Nr> r r( r? zRMissing the required parameter `user_id` when calling `delete_tasks_id_members_id`zRMissing the required parameter `task_id` when calling `delete_tasks_id_members_id`�userIDr) r* r+ r, r- � r r> r r r" r3 r# r$ r% r& r r r rB v s2 � � �z0TasksService._delete_tasks_id_members_id_preparec K s: d|d< |� d�r"| j||f|�S | j||f|�}|S dS )a Remove an owner from a task. **Deprecated**: Tasks don't use `owner` and `member` roles. Use [`/api/v2/authorizations`](#tag/Authorizations-(API-tokens)) to assign user permissions. This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.delete_tasks_id_owners_id(user_id, task_id, async_req=True) >>> result = thread.get() :param async_req bool :param str user_id: The ID of the owner to remove. (required) :param str task_id: The task ID. (required) :param str zap_trace_span: OpenTracing span context :return: None If the method is called asynchronously, returns the request thread. Tr r N)r �(delete_tasks_id_owners_id_with_http_infor= r r r �delete_tasks_id_owners_id� s z&TasksService.delete_tasks_id_owners_idc K sh | j ||f|�\}}}}}| jjdd||||g i dg |�d�|�d�|�dd�|�d�i |�d d�d �S ) a( Remove an owner from a task. **Deprecated**: Tasks don't use `owner` and `member` roles. Use [`/api/v2/authorizations`](#tag/Authorizations-(API-tokens)) to assign user permissions. This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.delete_tasks_id_owners_id_with_http_info(user_id, task_id, async_req=True) >>> result = thread.get() :param async_req bool :param str user_id: The ID of the owner to remove. (required) :param str task_id: The task ID. (required) :param str zap_trace_span: OpenTracing span context :return: None If the method is called asynchronously, returns the request thread. �&/api/v2/tasks/{taskID}/owners/{userID}r Nr r r Tr r r ��"_delete_tasks_id_owners_id_preparer r r rC r r r rG � s( � �z5TasksService.delete_tasks_id_owners_id_with_http_infoc � sn | j ||f|�\}}}}}| jjdd||||g i dg |�d�|�d�|�dd�|�d�i |�d d�d �I dH S ) aP Remove an owner from a task. **Deprecated**: Tasks don't use `owner` and `member` roles. Use [`/api/v2/authorizations`](#tag/Authorizations-(API-tokens)) to assign user permissions. This method makes an asynchronous HTTP request. :param async_req bool :param str user_id: The ID of the owner to remove. (required) :param str task_id: The task ID. (required) :param str zap_trace_span: OpenTracing span context :return: None If the method is called asynchronously, returns the request thread. rI r Nr r r Tr r r rJ rC r r r � delete_tasks_id_owners_id_async� s( � �z,TasksService.delete_tasks_id_owners_id_asyncc K s� t � }dddg}| �d||� d|ks2|d d kr:td��d|ksN|d d krVtd��i }d|krn|d |d< d|kr�|d |d< g }i }d|kr�|d |d < d } | j�d g�|d < ||||| fS ) Nr> r r( rH zQMissing the required parameter `user_id` when calling `delete_tasks_id_owners_id`zQMissing the required parameter `task_id` when calling `delete_tasks_id_owners_id`rE r) r* r+ r, r- rF r r r rK � s2 � � �z/TasksService._delete_tasks_id_owners_id_preparec K s: d|d< |� d�r"| j||f|�S | j||f|�}|S dS )aa Cancel a running task. Cancels a running [task](https://docs.influxdata.com/influxdb/latest/reference/glossary/#task). Use this endpoint with InfluxDB OSS to cancel a running task. #### InfluxDB Cloud - Doesn't support this operation. This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.delete_tasks_id_runs_id(task_id, run_id, async_req=True) >>> result = thread.get() :param async_req bool :param str task_id: The ID of the task to cancel. (required) :param str run_id: The ID of the task run to cancel. (required) :param str zap_trace_span: OpenTracing span context :return: None If the method is called asynchronously, returns the request thread. Tr r N)r �&delete_tasks_id_runs_id_with_http_info�r r �run_idr r r r r �delete_tasks_id_runs_id s z$TasksService.delete_tasks_id_runs_idc K sh | j ||f|�\}}}}}| jjdd||||g i dg |�d�|�d�|�dd�|�d�i |�d d�d �S ) ap Cancel a running task. Cancels a running [task](https://docs.influxdata.com/influxdb/latest/reference/glossary/#task). Use this endpoint with InfluxDB OSS to cancel a running task. #### InfluxDB Cloud - Doesn't support this operation. This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.delete_tasks_id_runs_id_with_http_info(task_id, run_id, async_req=True) >>> result = thread.get() :param async_req bool :param str task_id: The ID of the task to cancel. (required) :param str run_id: The ID of the task run to cancel. (required) :param str zap_trace_span: OpenTracing span context :return: None If the method is called asynchronously, returns the request thread. �#/api/v2/tasks/{taskID}/runs/{runID}r Nr r r Tr r r �� _delete_tasks_id_runs_id_preparer r r � r r rO r r" r# r$ r% r& r r r rM / s( � �z3TasksService.delete_tasks_id_runs_id_with_http_infoc � sn | j ||f|�\}}}}}| jjdd||||g i dg |�d�|�d�|�dd�|�d�i |�d d�d �I dH S ) a� Cancel a running task. Cancels a running [task](https://docs.influxdata.com/influxdb/latest/reference/glossary/#task). Use this endpoint with InfluxDB OSS to cancel a running task. #### InfluxDB Cloud - Doesn't support this operation. This method makes an asynchronous HTTP request. :param async_req bool :param str task_id: The ID of the task to cancel. (required) :param str run_id: The ID of the task run to cancel. (required) :param str zap_trace_span: OpenTracing span context :return: None If the method is called asynchronously, returns the request thread. rQ r Nr r r Tr r r rR rT r r r � delete_tasks_id_runs_id_asyncT s( � �z*TasksService.delete_tasks_id_runs_id_asyncc K s� t � }dddg}| �d||� d|ks2|d d kr:td��d|ksN|d d krVtd��i }d|krn|d |d< d|kr�|d |d< g }i }d|kr�|d |d < d } | j�d g�|d < ||||| fS ) Nr rO r( rP zOMissing the required parameter `task_id` when calling `delete_tasks_id_runs_id`zNMissing the required parameter `run_id` when calling `delete_tasks_id_runs_id`r) �runIDr* r+ r, r- � r r rO r r" r3 r# r$ r% r& r r r rS v s2 � � �z-TasksService._delete_tasks_id_runs_id_preparec K s2 d|d< |� d�r | jf |�S | jf |�}|S dS )ax List tasks. Retrieves a list of [tasks](https://docs.influxdata.com/influxdb/latest/reference/glossary/#task). To limit which tasks are returned, pass query parameters in your request. If no query parameters are passed, InfluxDB returns all tasks up to the default `limit`. #### Related guide - [Process data with InfluxDB tasks](https://docs.influxdata.com/influxdb/latest/process-data/) This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.get_tasks(async_req=True) >>> result = thread.get() :param async_req bool :param str zap_trace_span: OpenTracing span context :param str name: A [task](https://docs.influxdata.com/influxdb/latest/reference/glossary/#task) name. Only returns tasks with the specified name. Different tasks may have the same name. :param str after: A [task](https://docs.influxdata.com/influxdb/latest/reference/glossary/#task) ID. Only returns tasks created after the specified task. :param str user: A [user](https://docs.influxdata.com/influxdb/latest/reference/glossary/#user) ID. Only returns tasks owned by the specified user. :param str org: An [organization](https://docs.influxdata.com/influxdb/latest/reference/glossary/#organization) name. Only returns tasks owned by the specified organization. :param str org_id: An [organization](https://docs.influxdata.com/influxdb/latest/reference/glossary/#organization) ID. Only returns tasks owned by the specified organization. :param str status: A [task](https://docs.influxdata.com/influxdb/latest/reference/glossary/#task) status. Only returns tasks that have the specified status (`active` or `inactive`). :param int limit: The maximum number of [tasks](https://docs.influxdata.com/influxdb/latest/reference/glossary/#task) to return. Default is `100`. The minimum is `1` and the maximum is `500`. To reduce the payload size, combine _`type=basic`_ and _`limit`_ (see _Request samples_). For more information about the `basic` response, see the _`type`_ parameter. :param str type: A [task](https://docs.influxdata.com/influxdb/latest/reference/glossary/#task) type (`basic` or `system`). Default is `system`. Specifies the level of detail for tasks in the response. The default (`system`) response contains all the metadata properties for tasks. To reduce the response size, pass `basic` to omit some task properties (`flux`, `createdAt`, `updatedAt`). :return: Tasks If the method is called asynchronously, returns the request thread. Tr r N)r �get_tasks_with_http_info)r r r r r r � get_tasks� s zTasksService.get_tasksc K sd | j f |�\}}}}}| jjdd||||g i dg |�d�|�d�|�dd�|�d�i |�d d �d �S ) a� List tasks. Retrieves a list of [tasks](https://docs.influxdata.com/influxdb/latest/reference/glossary/#task). To limit which tasks are returned, pass query parameters in your request. If no query parameters are passed, InfluxDB returns all tasks up to the default `limit`. #### Related guide - [Process data with InfluxDB tasks](https://docs.influxdata.com/influxdb/latest/process-data/) This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.get_tasks_with_http_info(async_req=True) >>> result = thread.get() :param async_req bool :param str zap_trace_span: OpenTracing span context :param str name: A [task](https://docs.influxdata.com/influxdb/latest/reference/glossary/#task) name. Only returns tasks with the specified name. Different tasks may have the same name. :param str after: A [task](https://docs.influxdata.com/influxdb/latest/reference/glossary/#task) ID. Only returns tasks created after the specified task. :param str user: A [user](https://docs.influxdata.com/influxdb/latest/reference/glossary/#user) ID. Only returns tasks owned by the specified user. :param str org: An [organization](https://docs.influxdata.com/influxdb/latest/reference/glossary/#organization) name. Only returns tasks owned by the specified organization. :param str org_id: An [organization](https://docs.influxdata.com/influxdb/latest/reference/glossary/#organization) ID. Only returns tasks owned by the specified organization. :param str status: A [task](https://docs.influxdata.com/influxdb/latest/reference/glossary/#task) status. Only returns tasks that have the specified status (`active` or `inactive`). :param int limit: The maximum number of [tasks](https://docs.influxdata.com/influxdb/latest/reference/glossary/#task) to return. Default is `100`. The minimum is `1` and the maximum is `500`. To reduce the payload size, combine _`type=basic`_ and _`limit`_ (see _Request samples_). For more information about the `basic` response, see the _`type`_ parameter. :param str type: A [task](https://docs.influxdata.com/influxdb/latest/reference/glossary/#task) type (`basic` or `system`). Default is `system`. Specifies the level of detail for tasks in the response. The default (`system`) response contains all the metadata properties for tasks. To reduce the response size, pass `basic` to omit some task properties (`flux`, `createdAt`, `updatedAt`). :return: Tasks If the method is called asynchronously, returns the request thread. � /api/v2/tasks�GET�Tasksr r r Tr r Nr ��_get_tasks_preparer r r �r r r" r# r$ r% r& r r r rX � s( � �z%TasksService.get_tasks_with_http_infoc � sj | j f |�\}}}}}| jjdd||||g i dg |�d�|�d�|�dd�|�d�i |�d d �d �I d H S ) a� List tasks. Retrieves a list of [tasks](https://docs.influxdata.com/influxdb/latest/reference/glossary/#task). To limit which tasks are returned, pass query parameters in your request. If no query parameters are passed, InfluxDB returns all tasks up to the default `limit`. #### Related guide - [Process data with InfluxDB tasks](https://docs.influxdata.com/influxdb/latest/process-data/) This method makes an asynchronous HTTP request. :param async_req bool :param str zap_trace_span: OpenTracing span context :param str name: A [task](https://docs.influxdata.com/influxdb/latest/reference/glossary/#task) name. Only returns tasks with the specified name. Different tasks may have the same name. :param str after: A [task](https://docs.influxdata.com/influxdb/latest/reference/glossary/#task) ID. Only returns tasks created after the specified task. :param str user: A [user](https://docs.influxdata.com/influxdb/latest/reference/glossary/#user) ID. Only returns tasks owned by the specified user. :param str org: An [organization](https://docs.influxdata.com/influxdb/latest/reference/glossary/#organization) name. Only returns tasks owned by the specified organization. :param str org_id: An [organization](https://docs.influxdata.com/influxdb/latest/reference/glossary/#organization) ID. Only returns tasks owned by the specified organization. :param str status: A [task](https://docs.influxdata.com/influxdb/latest/reference/glossary/#task) status. Only returns tasks that have the specified status (`active` or `inactive`). :param int limit: The maximum number of [tasks](https://docs.influxdata.com/influxdb/latest/reference/glossary/#task) to return. Default is `100`. The minimum is `1` and the maximum is `500`. To reduce the payload size, combine _`type=basic`_ and _`limit`_ (see _Request samples_). For more information about the `basic` response, see the _`type`_ parameter. :param str type: A [task](https://docs.influxdata.com/influxdb/latest/reference/glossary/#task) type (`basic` or `system`). Default is `system`. Specifies the level of detail for tasks in the response. The default (`system`) response contains all the metadata properties for tasks. To reduce the response size, pass `basic` to omit some task properties (`flux`, `createdAt`, `updatedAt`). :return: Tasks If the method is called asynchronously, returns the request thread. rZ r[ r\ r r r Tr r Nr r] r_ r r r �get_tasks_async� s( � �z TasksService.get_tasks_asyncc K s~ t � }ddddddddd g }| �d ||� d|krF|d d krFtd ��d|krb|d d k rbtd��i }g }d|kr�|�d|d f� d|kr�|�d|d f� d|kr�|�d|d f� d|kr�|�d|d f� d|kr�|�d|d f� d|k�r|�d|d f� d|k�r$|�d|d f� d |k�r@|�d |d f� i }d|k�rZ|d |d< d }| j�dg�|d< |||||fS )Nr( �name�after�user�orgZorg_id�status�limit�typerY �� ziInvalid value for parameter `limit` when calling `get_tasks`, must be a value less than or equal to `500`� zjInvalid value for parameter `limit` when calling `get_tasks`, must be a value greater than or equal to `1`ZorgIDr* r+ r, �r. r/ r0 �appendr r1 )r r r" r3 r# r$ r% r& r r r r^ sB �z TasksService._get_tasks_preparec K s6 d|d< |� d�r | j|f|�S | j|f|�}|S dS )a� Retrieve a task. Retrieves a [task](https://docs.influxdata.com/influxdb/latest/reference/glossary/#task). This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.get_tasks_id(task_id, async_req=True) >>> result = thread.get() :param async_req bool :param str task_id: The ID of the task to retrieve. (required) :param str zap_trace_span: OpenTracing span context :return: Task If the method is called asynchronously, returns the request thread. Tr r N)r �get_tasks_id_with_http_infor r r r � get_tasks_id1 s zTasksService.get_tasks_idc K sf | j |f|�\}}}}}| jjdd||||g i dg |�d�|�d�|�dd�|�d�i |�d d �d �S ) a� Retrieve a task. Retrieves a [task](https://docs.influxdata.com/influxdb/latest/reference/glossary/#task). This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.get_tasks_id_with_http_info(task_id, async_req=True) >>> result = thread.get() :param async_req bool :param str task_id: The ID of the task to retrieve. (required) :param str zap_trace_span: OpenTracing span context :return: Task If the method is called asynchronously, returns the request thread. r r[ �Taskr r r Tr r Nr ��_get_tasks_id_preparer r r r! r r r rl H s( � �z(TasksService.get_tasks_id_with_http_infoc � sl | j |f|�\}}}}}| jjdd||||g i dg |�d�|�d�|�dd�|�d�i |�d d �d �I d H S ) a� Retrieve a task. Retrieves a [task](https://docs.influxdata.com/influxdb/latest/reference/glossary/#task). This method makes an asynchronous HTTP request. :param async_req bool :param str task_id: The ID of the task to retrieve. (required) :param str zap_trace_span: OpenTracing span context :return: Task If the method is called asynchronously, returns the request thread. r r[ rn r r r Tr r Nr ro r! r r r �get_tasks_id_asyncl s( � �z TasksService.get_tasks_id_asyncc K s� t � }ddg}| �d||� d|ks0|d d kr8td��i }d|krP|d |d< g }i }d|krl|d |d< d }| j�dg�|d< |||||fS ) Nr r( rm zDMissing the required parameter `task_id` when calling `get_tasks_id`r) r* r+ r, r- r2 r r r rp � s& � �z"TasksService._get_tasks_id_preparec K s6 d|d< |� d�r | j|f|�S | j|f|�}|S dS )a� List labels for a task. Retrieves a list of all labels for a task. Labels may be used for grouping and filtering tasks. This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.get_tasks_id_labels(task_id, async_req=True) >>> result = thread.get() :param async_req bool :param str task_id: The ID of the task to retrieve labels for. (required) :param str zap_trace_span: OpenTracing span context :return: LabelsResponse If the method is called asynchronously, returns the request thread. Tr r N)r �"get_tasks_id_labels_with_http_infor r r r �get_tasks_id_labels� s z TasksService.get_tasks_id_labelsc K sf | j |f|�\}}}}}| jjdd||||g i dg |�d�|�d�|�dd�|�d�i |�d d �d �S ) a� List labels for a task. Retrieves a list of all labels for a task. Labels may be used for grouping and filtering tasks. This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.get_tasks_id_labels_with_http_info(task_id, async_req=True) >>> result = thread.get() :param async_req bool :param str task_id: The ID of the task to retrieve labels for. (required) :param str zap_trace_span: OpenTracing span context :return: LabelsResponse If the method is called asynchronously, returns the request thread. � /api/v2/tasks/{taskID}/labelsr[ �LabelsResponser r r Tr r Nr �� _get_tasks_id_labels_preparer r r r! r r r rr � s( � �z/TasksService.get_tasks_id_labels_with_http_infoc � sl | j |f|�\}}}}}| jjdd||||g i dg |�d�|�d�|�dd�|�d�i |�d d �d �I d H S ) a� List labels for a task. Retrieves a list of all labels for a task. Labels may be used for grouping and filtering tasks. This method makes an asynchronous HTTP request. :param async_req bool :param str task_id: The ID of the task to retrieve labels for. (required) :param str zap_trace_span: OpenTracing span context :return: LabelsResponse If the method is called asynchronously, returns the request thread. rt r[ ru r r r Tr r Nr rv r! r r r �get_tasks_id_labels_async� s( � �z&TasksService.get_tasks_id_labels_asyncc K s� t � }ddg}| �d||� d|ks0|d d kr8td��i }d|krP|d |d< g }i }d|krl|d |d< d }| j�dg�|d< |||||fS ) Nr r( rs zKMissing the required parameter `task_id` when calling `get_tasks_id_labels`r) r* r+ r, r- r2 r r r rw s& � �z)TasksService._get_tasks_id_labels_preparec K s6 d|d< |� d�r | j|f|�S | j|f|�}|S dS )u� Retrieve all logs for a task. Retrieves a list of all logs for a [task](https://docs.influxdata.com/influxdb/latest/reference/glossary/#task). When an InfluxDB task runs, a “run” record is created in the task’s history. Logs associated with each run provide relevant log messages, timestamps, and the exit status of the run attempt. Use this endpoint to retrieve only the log events for a task, without additional task metadata. This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.get_tasks_id_logs(task_id, async_req=True) >>> result = thread.get() :param async_req bool :param str task_id: The task ID. (required) :param str zap_trace_span: OpenTracing span context :return: Logs If the method is called asynchronously, returns the request thread. Tr r N)r � get_tasks_id_logs_with_http_infor r r r �get_tasks_id_logs s z TasksService.get_tasks_id_logsc K sf | j |f|�\}}}}}| jjdd||||g i dg |�d�|�d�|�dd�|�d�i |�d d �d �S ) u� Retrieve all logs for a task. Retrieves a list of all logs for a [task](https://docs.influxdata.com/influxdb/latest/reference/glossary/#task). When an InfluxDB task runs, a “run” record is created in the task’s history. Logs associated with each run provide relevant log messages, timestamps, and the exit status of the run attempt. Use this endpoint to retrieve only the log events for a task, without additional task metadata. This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.get_tasks_id_logs_with_http_info(task_id, async_req=True) >>> result = thread.get() :param async_req bool :param str task_id: The task ID. (required) :param str zap_trace_span: OpenTracing span context :return: Logs If the method is called asynchronously, returns the request thread. �/api/v2/tasks/{taskID}/logsr[ �Logsr r r Tr r Nr ��_get_tasks_id_logs_preparer r r r! r r r ry 6 s( � �z-TasksService.get_tasks_id_logs_with_http_infoc � sl | j |f|�\}}}}}| jjdd||||g i dg |�d�|�d�|�dd�|�d�i |�d d �d �I d H S ) u Retrieve all logs for a task. Retrieves a list of all logs for a [task](https://docs.influxdata.com/influxdb/latest/reference/glossary/#task). When an InfluxDB task runs, a “run” record is created in the task’s history. Logs associated with each run provide relevant log messages, timestamps, and the exit status of the run attempt. Use this endpoint to retrieve only the log events for a task, without additional task metadata. This method makes an asynchronous HTTP request. :param async_req bool :param str task_id: The task ID. (required) :param str zap_trace_span: OpenTracing span context :return: Logs If the method is called asynchronously, returns the request thread. r{ r[ r| r r r Tr r Nr r} r! r r r �get_tasks_id_logs_asyncZ s( � �z$TasksService.get_tasks_id_logs_asyncc K s� t � }ddg}| �d||� d|ks0|d d kr8td��i }d|krP|d |d< g }i }d|krl|d |d< d }| j�dg�|d< |||||fS ) Nr r( rz zIMissing the required parameter `task_id` when calling `get_tasks_id_logs`r) r* r+ r, r- r2 r r r r~ { s& � �z'TasksService._get_tasks_id_logs_preparec K s6 d|d< |� d�r | j|f|�S | j|f|�}|S dS )aW List all task members. **Deprecated**: Tasks don't use `owner` and `member` roles. Use [`/api/v2/authorizations`](#tag/Authorizations-(API-tokens)) to assign user permissions. Lists all users that have the `member` role for the specified [task](https://docs.influxdata.com/influxdb/latest/reference/glossary/#task). This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.get_tasks_id_members(task_id, async_req=True) >>> result = thread.get() :param async_req bool :param str task_id: The task ID. (required) :param str zap_trace_span: OpenTracing span context :return: ResourceMembers If the method is called asynchronously, returns the request thread. Tr r N)r �#get_tasks_id_members_with_http_infor r r r �get_tasks_id_members� s z!TasksService.get_tasks_id_membersc K sf | j |f|�\}}}}}| jjdd||||g i dg |�d�|�d�|�dd�|�d�i |�d d �d �S ) af List all task members. **Deprecated**: Tasks don't use `owner` and `member` roles. Use [`/api/v2/authorizations`](#tag/Authorizations-(API-tokens)) to assign user permissions. Lists all users that have the `member` role for the specified [task](https://docs.influxdata.com/influxdb/latest/reference/glossary/#task). This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.get_tasks_id_members_with_http_info(task_id, async_req=True) >>> result = thread.get() :param async_req bool :param str task_id: The task ID. (required) :param str zap_trace_span: OpenTracing span context :return: ResourceMembers If the method is called asynchronously, returns the request thread. � /api/v2/tasks/{taskID}/membersr[ �ResourceMembersr r r Tr r Nr �� _get_tasks_id_members_preparer r r r! r r r r� � s( � �z0TasksService.get_tasks_id_members_with_http_infoc � sl | j |f|�\}}}}}| jjdd||||g i dg |�d�|�d�|�dd�|�d�i |�d d �d �I d H S ) a� List all task members. **Deprecated**: Tasks don't use `owner` and `member` roles. Use [`/api/v2/authorizations`](#tag/Authorizations-(API-tokens)) to assign user permissions. Lists all users that have the `member` role for the specified [task](https://docs.influxdata.com/influxdb/latest/reference/glossary/#task). This method makes an asynchronous HTTP request. :param async_req bool :param str task_id: The task ID. (required) :param str zap_trace_span: OpenTracing span context :return: ResourceMembers If the method is called asynchronously, returns the request thread. r� r[ r� r r r Tr r Nr r� r! r r r �get_tasks_id_members_async� s( � �z'TasksService.get_tasks_id_members_asyncc K s� t � }ddg}| �d||� d|ks0|d d kr8td��i }d|krP|d |d< g }i }d|krl|d |d< d }| j�dg�|d< |||||fS ) Nr r( r� zLMissing the required parameter `task_id` when calling `get_tasks_id_members`r) r* r+ r, r- r2 r r r r� � s& � �z*TasksService._get_tasks_id_members_preparec K s6 d|d< |� d�r | j|f|�S | j|f|�}|S dS )a& List all owners of a task. **Deprecated**: Tasks don't use `owner` and `member` roles. Use [`/api/v2/authorizations`](#tag/Authorizations-(API-tokens)) to assign user permissions. Retrieves all users that have owner permission for a task. This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.get_tasks_id_owners(task_id, async_req=True) >>> result = thread.get() :param async_req bool :param str task_id: The ID of the task to retrieve owners for. (required) :param str zap_trace_span: OpenTracing span context :return: ResourceOwners If the method is called asynchronously, returns the request thread. Tr r N)r �"get_tasks_id_owners_with_http_infor r r r �get_tasks_id_owners s z TasksService.get_tasks_id_ownersc K sf | j |f|�\}}}}}| jjdd||||g i dg |�d�|�d�|�dd�|�d�i |�d d �d �S ) a5 List all owners of a task. **Deprecated**: Tasks don't use `owner` and `member` roles. Use [`/api/v2/authorizations`](#tag/Authorizations-(API-tokens)) to assign user permissions. Retrieves all users that have owner permission for a task. This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.get_tasks_id_owners_with_http_info(task_id, async_req=True) >>> result = thread.get() :param async_req bool :param str task_id: The ID of the task to retrieve owners for. (required) :param str zap_trace_span: OpenTracing span context :return: ResourceOwners If the method is called asynchronously, returns the request thread. � /api/v2/tasks/{taskID}/ownersr[ �ResourceOwnersr r r Tr r Nr �� _get_tasks_id_owners_preparer r r r! r r r r� $ s( � �z/TasksService.get_tasks_id_owners_with_http_infoc � sl | j |f|�\}}}}}| jjdd||||g i dg |�d�|�d�|�dd�|�d�i |�d d �d �I d H S ) al List all owners of a task. **Deprecated**: Tasks don't use `owner` and `member` roles. Use [`/api/v2/authorizations`](#tag/Authorizations-(API-tokens)) to assign user permissions. Retrieves all users that have owner permission for a task. This method makes an asynchronous HTTP request. :param async_req bool :param str task_id: The ID of the task to retrieve owners for. (required) :param str zap_trace_span: OpenTracing span context :return: ResourceOwners If the method is called asynchronously, returns the request thread. r� r[ r� r r r Tr r Nr r� r! r r r �get_tasks_id_owners_asyncH s( � �z&TasksService.get_tasks_id_owners_asyncc K s� t � }ddg}| �d||� d|ks0|d d kr8td��i }d|krP|d |d< g }i }d|krl|d |d< d }| j�dg�|d< |||||fS ) Nr r( r� zKMissing the required parameter `task_id` when calling `get_tasks_id_owners`r) r* r+ r, r- r2 r r r r� i s& � �z)TasksService._get_tasks_id_owners_preparec K s6 d|d< |� d�r | j|f|�S | j|f|�}|S dS )a� List runs for a task. Retrieves a list of runs for a [task](https://docs.influxdata.com/influxdb/latest/process-data/). To limit which task runs are returned, pass query parameters in your request. If no query parameters are passed, InfluxDB returns all task runs up to the default `limit`. This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.get_tasks_id_runs(task_id, async_req=True) >>> result = thread.get() :param async_req bool :param str task_id: The ID of the task to get runs for. Only returns runs for this task. (required) :param str zap_trace_span: OpenTracing span context :param str after: A task run ID. Only returns runs created after this run. :param int limit: Limits the number of task runs returned. Default is `100`. :param datetime after_time: A timestamp ([RFC3339 date/time format](https://docs.influxdata.com/influxdb/latest/reference/glossary/#rfc3339-timestamp)). Only returns runs scheduled after this time. :param datetime before_time: A timestamp ([RFC3339 date/time format](https://docs.influxdata.com/influxdb/latest/reference/glossary/#rfc3339-timestamp)). Only returns runs scheduled before this time. :return: Runs If the method is called asynchronously, returns the request thread. Tr r N)r � get_tasks_id_runs_with_http_infor r r r �get_tasks_id_runs� s z TasksService.get_tasks_id_runsc K sf | j |f|�\}}}}}| jjdd||||g i dg |�d�|�d�|�dd�|�d�i |�d d �d �S ) a� List runs for a task. Retrieves a list of runs for a [task](https://docs.influxdata.com/influxdb/latest/process-data/). To limit which task runs are returned, pass query parameters in your request. If no query parameters are passed, InfluxDB returns all task runs up to the default `limit`. This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.get_tasks_id_runs_with_http_info(task_id, async_req=True) >>> result = thread.get() :param async_req bool :param str task_id: The ID of the task to get runs for. Only returns runs for this task. (required) :param str zap_trace_span: OpenTracing span context :param str after: A task run ID. Only returns runs created after this run. :param int limit: Limits the number of task runs returned. Default is `100`. :param datetime after_time: A timestamp ([RFC3339 date/time format](https://docs.influxdata.com/influxdb/latest/reference/glossary/#rfc3339-timestamp)). Only returns runs scheduled after this time. :param datetime before_time: A timestamp ([RFC3339 date/time format](https://docs.influxdata.com/influxdb/latest/reference/glossary/#rfc3339-timestamp)). Only returns runs scheduled before this time. :return: Runs If the method is called asynchronously, returns the request thread. �/api/v2/tasks/{taskID}/runsr[ �Runsr r r Tr r Nr ��_get_tasks_id_runs_preparer r r r! r r r r� � s( � �z-TasksService.get_tasks_id_runs_with_http_infoc � sl | j |f|�\}}}}}| jjdd||||g i dg |�d�|�d�|�dd�|�d�i |�d d �d �I d H S ) a� List runs for a task. Retrieves a list of runs for a [task](https://docs.influxdata.com/influxdb/latest/process-data/). To limit which task runs are returned, pass query parameters in your request. If no query parameters are passed, InfluxDB returns all task runs up to the default `limit`. This method makes an asynchronous HTTP request. :param async_req bool :param str task_id: The ID of the task to get runs for. Only returns runs for this task. (required) :param str zap_trace_span: OpenTracing span context :param str after: A task run ID. Only returns runs created after this run. :param int limit: Limits the number of task runs returned. Default is `100`. :param datetime after_time: A timestamp ([RFC3339 date/time format](https://docs.influxdata.com/influxdb/latest/reference/glossary/#rfc3339-timestamp)). Only returns runs scheduled after this time. :param datetime before_time: A timestamp ([RFC3339 date/time format](https://docs.influxdata.com/influxdb/latest/reference/glossary/#rfc3339-timestamp)). Only returns runs scheduled before this time. :return: Runs If the method is called asynchronously, returns the request thread. r� r[ r� r r r Tr r Nr r� r! r r r �get_tasks_id_runs_async� s( � �z$TasksService.get_tasks_id_runs_asyncc K s: t � }ddddddg}| �d||� d|ks8|d d kr@td��d|kr\|d d kr\td ��d|krx|d d k rxtd ��i }d|kr�|d |d < g }d|kr�|�d|d f� d|kr�|�d|d f� d|kr�|�d|d f� d|kr�|�d|d f� i }d|k�r|d |d< d }| j�dg�|d< |||||fS )Nr r( rb rf Z after_timeZ before_timer� zIMissing the required parameter `task_id` when calling `get_tasks_id_runs`rh zqInvalid value for parameter `limit` when calling `get_tasks_id_runs`, must be a value less than or equal to `500`ri zrInvalid value for parameter `limit` when calling `get_tasks_id_runs`, must be a value greater than or equal to `1`r) Z afterTimeZ beforeTimer* r+ r, rj r2 r r r r� � s> � �z'TasksService._get_tasks_id_runs_preparec K s: d|d< |� d�r"| j||f|�S | j||f|�}|S dS )aH Retrieve a run for a task.. Retrieves a specific run for a [task](https://docs.influxdata.com/influxdb/latest/reference/glossary/#task). Use this endpoint to retrieve detail and logs for a specific task run. This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.get_tasks_id_runs_id(task_id, run_id, async_req=True) >>> result = thread.get() :param async_req bool :param str task_id: The ID of the task to retrieve runs for. (required) :param str run_id: The ID of the run to retrieve. (required) :param str zap_trace_span: OpenTracing span context :return: Run If the method is called asynchronously, returns the request thread. Tr r N)r �#get_tasks_id_runs_id_with_http_inforN r r r �get_tasks_id_runs_id s z!TasksService.get_tasks_id_runs_idc K sh | j ||f|�\}}}}}| jjdd||||g i dg |�d�|�d�|�dd�|�d�i |�d d �d �S ) aW Retrieve a run for a task.. Retrieves a specific run for a [task](https://docs.influxdata.com/influxdb/latest/reference/glossary/#task). Use this endpoint to retrieve detail and logs for a specific task run. This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.get_tasks_id_runs_id_with_http_info(task_id, run_id, async_req=True) >>> result = thread.get() :param async_req bool :param str task_id: The ID of the task to retrieve runs for. (required) :param str run_id: The ID of the run to retrieve. (required) :param str zap_trace_span: OpenTracing span context :return: Run If the method is called asynchronously, returns the request thread. rQ r[ �Runr r r Tr r Nr �� _get_tasks_id_runs_id_preparer r r rT r r r r� + s( � �z0TasksService.get_tasks_id_runs_id_with_http_infoc � sn | j ||f|�\}}}}}| jjdd||||g i dg |�d�|�d�|�dd�|�d�i |�d d �d �I d H S ) a� Retrieve a run for a task.. Retrieves a specific run for a [task](https://docs.influxdata.com/influxdb/latest/reference/glossary/#task). Use this endpoint to retrieve detail and logs for a specific task run. This method makes an asynchronous HTTP request. :param async_req bool :param str task_id: The ID of the task to retrieve runs for. (required) :param str run_id: The ID of the run to retrieve. (required) :param str zap_trace_span: OpenTracing span context :return: Run If the method is called asynchronously, returns the request thread. rQ r[ r� r r r Tr r Nr r� rT r r r �get_tasks_id_runs_id_asyncP s( � �z'TasksService.get_tasks_id_runs_id_asyncc K s� t � }dddg}| �d||� d|ks2|d d kr:td��d|ksN|d d krVtd��i }d|krn|d |d< d|kr�|d |d< g }i }d|kr�|d |d < d } | j�d g�|d < ||||| fS ) Nr rO r( r� zLMissing the required parameter `task_id` when calling `get_tasks_id_runs_id`zKMissing the required parameter `run_id` when calling `get_tasks_id_runs_id`r) rV r* r+ r, r- rW r r r r� r s2 � � �z*TasksService._get_tasks_id_runs_id_preparec K s: d|d< |� d�r"| j||f|�S | j||f|�}|S dS )aa Retrieve all logs for a run. Retrieves all logs for a task run. A log is a list of run events with `runID`, `time`, and `message` properties. Use this endpoint to help analyze task performance and troubleshoot failed task runs. This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.get_tasks_id_runs_id_logs(task_id, run_id, async_req=True) >>> result = thread.get() :param async_req bool :param str task_id: The ID of the task to get logs for. (required) :param str run_id: The ID of the run to get logs for. (required) :param str zap_trace_span: OpenTracing span context :return: Logs If the method is called asynchronously, returns the request thread. Tr r N)r �(get_tasks_id_runs_id_logs_with_http_inforN r r r �get_tasks_id_runs_id_logs� s z&TasksService.get_tasks_id_runs_id_logsc K sh | j ||f|�\}}}}}| jjdd||||g i dg |�d�|�d�|�dd�|�d�i |�d d �d �S ) ap Retrieve all logs for a run. Retrieves all logs for a task run. A log is a list of run events with `runID`, `time`, and `message` properties. Use this endpoint to help analyze task performance and troubleshoot failed task runs. This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.get_tasks_id_runs_id_logs_with_http_info(task_id, run_id, async_req=True) >>> result = thread.get() :param async_req bool :param str task_id: The ID of the task to get logs for. (required) :param str run_id: The ID of the run to get logs for. (required) :param str zap_trace_span: OpenTracing span context :return: Logs If the method is called asynchronously, returns the request thread. �(/api/v2/tasks/{taskID}/runs/{runID}/logsr[ r| r r r Tr r Nr ��"_get_tasks_id_runs_id_logs_preparer r r rT r r r r� � s( � �z5TasksService.get_tasks_id_runs_id_logs_with_http_infoc � sn | j ||f|�\}}}}}| jjdd||||g i dg |�d�|�d�|�dd�|�d�i |�d d �d �I d H S ) a� Retrieve all logs for a run. Retrieves all logs for a task run. A log is a list of run events with `runID`, `time`, and `message` properties. Use this endpoint to help analyze task performance and troubleshoot failed task runs. This method makes an asynchronous HTTP request. :param async_req bool :param str task_id: The ID of the task to get logs for. (required) :param str run_id: The ID of the run to get logs for. (required) :param str zap_trace_span: OpenTracing span context :return: Logs If the method is called asynchronously, returns the request thread. r� r[ r| r r r Tr r Nr r� rT r r r � get_tasks_id_runs_id_logs_async� s( � �z,TasksService.get_tasks_id_runs_id_logs_asyncc K s� t � }dddg}| �d||� d|ks2|d d kr:td��d|ksN|d d krVtd��i }d|krn|d |d< d|kr�|d |d< g }i }d|kr�|d |d < d } | j�d g�|d < ||||| fS ) Nr rO r( r� zQMissing the required parameter `task_id` when calling `get_tasks_id_runs_id_logs`zPMissing the required parameter `run_id` when calling `get_tasks_id_runs_id_logs`r) rV r* r+ r, r- rW r r r r� � s2 � � �z/TasksService._get_tasks_id_runs_id_logs_preparec K s: d|d< |� d�r"| j||f|�S | j||f|�}|S dS )a� Update a task. Updates a task and then cancels all scheduled runs of the task. Use this endpoint to set, modify, and clear task properties (for example: `cron`, `name`, `flux`, `status`). Once InfluxDB applies the update, it cancels all previously scheduled runs of the task. To update a task, pass an object that contains the updated key-value pairs. To activate or inactivate a task, set the `status` property. _`"status": "inactive"`_ cancels scheduled runs and prevents manual runs of the task. This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.patch_tasks_id(task_id, task_update_request, async_req=True) >>> result = thread.get() :param async_req bool :param str task_id: The ID of the task to update. (required) :param TaskUpdateRequest task_update_request: An object that contains updated task properties to apply. (required) :param str zap_trace_span: OpenTracing span context :return: Task If the method is called asynchronously, returns the request thread. Tr r N)r � patch_tasks_id_with_http_info)r r �task_update_requestr r r r r �patch_tasks_id s zTasksService.patch_tasks_idc K sh | j ||f|�\}}}}}| jjdd||||g i dg |�d�|�d�|�dd�|�d�i |�d d �d �S ) a� Update a task. Updates a task and then cancels all scheduled runs of the task. Use this endpoint to set, modify, and clear task properties (for example: `cron`, `name`, `flux`, `status`). Once InfluxDB applies the update, it cancels all previously scheduled runs of the task. To update a task, pass an object that contains the updated key-value pairs. To activate or inactivate a task, set the `status` property. _`"status": "inactive"`_ cancels scheduled runs and prevents manual runs of the task. This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.patch_tasks_id_with_http_info(task_id, task_update_request, async_req=True) >>> result = thread.get() :param async_req bool :param str task_id: The ID of the task to update. (required) :param TaskUpdateRequest task_update_request: An object that contains updated task properties to apply. (required) :param str zap_trace_span: OpenTracing span context :return: Task If the method is called asynchronously, returns the request thread. r �PATCHrn r r r Tr r Nr ��_patch_tasks_id_preparer r r � r r r� r r" r# r$ r% r& r r r r� + s( � �z*TasksService.patch_tasks_id_with_http_infoc � sn | j ||f|�\}}}}}| jjdd||||g i dg |�d�|�d�|�dd�|�d�i |�d d �d �I d H S ) a� Update a task. Updates a task and then cancels all scheduled runs of the task. Use this endpoint to set, modify, and clear task properties (for example: `cron`, `name`, `flux`, `status`). Once InfluxDB applies the update, it cancels all previously scheduled runs of the task. To update a task, pass an object that contains the updated key-value pairs. To activate or inactivate a task, set the `status` property. _`"status": "inactive"`_ cancels scheduled runs and prevents manual runs of the task. This method makes an asynchronous HTTP request. :param async_req bool :param str task_id: The ID of the task to update. (required) :param TaskUpdateRequest task_update_request: An object that contains updated task properties to apply. (required) :param str zap_trace_span: OpenTracing span context :return: Task If the method is called asynchronously, returns the request thread. r r� rn r r r Tr r Nr r� r� r r r �patch_tasks_id_asyncP s( � �z!TasksService.patch_tasks_id_asyncc K s� t � }dddg}| �d||� d|ks2|d d kr:td��d|ksN|d d krVtd��i }d|krn|d |d< g }i }d|kr�|d |d< d } d|kr�|d } | j�d g�|d < | j�d g�|d < ||||| fS ) Nr r� r( r� zFMissing the required parameter `task_id` when calling `patch_tasks_id`zRMissing the required parameter `task_update_request` when calling `patch_tasks_id`r) r* r+ r, � Content-Type�r. r/ r0 r r1 Zselect_header_content_type) r r r� r r" r3 r# r$ r% r& r r r r� r s8 � � ��z$TasksService._patch_tasks_id_preparec K s6 d|d< |� d�r | j|f|�S | j|f|�}|S dS )aM Create a task. Creates a [task](https://docs.influxdata.com/influxdb/latest/reference/glossary/#task) and returns the task. #### Related guides - [Get started with tasks](https://docs.influxdata.com/influxdb/latest/process-data/get-started/) - [Create a task](https://docs.influxdata.com/influxdb/latest/process-data/manage-tasks/create-task/) - [Common tasks](https://docs.influxdata.com/influxdb/latest/process-data/common-tasks/) - [Task configuration options](https://docs.influxdata.com/influxdb/latest/process-data/task-options/) This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.post_tasks(task_create_request, async_req=True) >>> result = thread.get() :param async_req bool :param TaskCreateRequest task_create_request: The task to create. (required) :param str zap_trace_span: OpenTracing span context :return: Task If the method is called asynchronously, returns the request thread. Tr r N)r �post_tasks_with_http_info)r �task_create_requestr r r r r � post_tasks� s zTasksService.post_tasksc K sf | j |f|�\}}}}}| jjdd||||g i dg |�d�|�d�|�dd�|�d�i |�d d �d �S ) a\ Create a task. Creates a [task](https://docs.influxdata.com/influxdb/latest/reference/glossary/#task) and returns the task. #### Related guides - [Get started with tasks](https://docs.influxdata.com/influxdb/latest/process-data/get-started/) - [Create a task](https://docs.influxdata.com/influxdb/latest/process-data/manage-tasks/create-task/) - [Common tasks](https://docs.influxdata.com/influxdb/latest/process-data/common-tasks/) - [Task configuration options](https://docs.influxdata.com/influxdb/latest/process-data/task-options/) This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.post_tasks_with_http_info(task_create_request, async_req=True) >>> result = thread.get() :param async_req bool :param TaskCreateRequest task_create_request: The task to create. (required) :param str zap_trace_span: OpenTracing span context :return: Task If the method is called asynchronously, returns the request thread. rZ �POSTrn r r r Tr r Nr ��_post_tasks_preparer r r �r r� r r" r# r$ r% r& r r r r� � s( � �z&TasksService.post_tasks_with_http_infoc � sl | j |f|�\}}}}}| jjdd||||g i dg |�d�|�d�|�dd�|�d�i |�d d �d �I d H S ) a� Create a task. Creates a [task](https://docs.influxdata.com/influxdb/latest/reference/glossary/#task) and returns the task. #### Related guides - [Get started with tasks](https://docs.influxdata.com/influxdb/latest/process-data/get-started/) - [Create a task](https://docs.influxdata.com/influxdb/latest/process-data/manage-tasks/create-task/) - [Common tasks](https://docs.influxdata.com/influxdb/latest/process-data/common-tasks/) - [Task configuration options](https://docs.influxdata.com/influxdb/latest/process-data/task-options/) This method makes an asynchronous HTTP request. :param async_req bool :param TaskCreateRequest task_create_request: The task to create. (required) :param str zap_trace_span: OpenTracing span context :return: Task If the method is called asynchronously, returns the request thread. rZ r� rn r r r Tr r Nr r� r� r r r �post_tasks_async� s( � �z TasksService.post_tasks_asyncc K s� t � }ddg}| �d||� d|ks0|d d kr8td��i }g }i }d|krX|d |d< d }d|krl|d }| j�dg�|d< | j�dg�|d< |||||fS ) Nr� r( r� zNMissing the required parameter `task_create_request` when calling `post_tasks`r* r+ r, r� r� ) r r� r r" r3 r# r$ r% r& r r r r� � s, � ��z TasksService._post_tasks_preparec K s: d|d< |� d�r"| j||f|�S | j||f|�}|S dS )a- Add a label to a task. Adds a label to a task. Use this endpoint to add a label that you can use to filter tasks in the InfluxDB UI. This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.post_tasks_id_labels(task_id, label_mapping, async_req=True) >>> result = thread.get() :param async_req bool :param str task_id: The ID of the task to label. (required) :param LabelMapping label_mapping: An object that contains a _`labelID`_ to add to the task. (required) :param str zap_trace_span: OpenTracing span context :return: LabelResponse If the method is called asynchronously, returns the request thread. Tr r N)r �#post_tasks_id_labels_with_http_info)r r � label_mappingr r r r r �post_tasks_id_labels s z!TasksService.post_tasks_id_labelsc K sh | j ||f|�\}}}}}| jjdd||||g i dg |�d�|�d�|�dd�|�d�i |�d d �d �S ) a< Add a label to a task. Adds a label to a task. Use this endpoint to add a label that you can use to filter tasks in the InfluxDB UI. This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.post_tasks_id_labels_with_http_info(task_id, label_mapping, async_req=True) >>> result = thread.get() :param async_req bool :param str task_id: The ID of the task to label. (required) :param LabelMapping label_mapping: An object that contains a _`labelID`_ to add to the task. (required) :param str zap_trace_span: OpenTracing span context :return: LabelResponse If the method is called asynchronously, returns the request thread. rt r� � LabelResponser r r Tr r Nr �� _post_tasks_id_labels_preparer r r � r r r� r r" r# r$ r% r& r r r r� * s( � �z0TasksService.post_tasks_id_labels_with_http_infoc � sn | j ||f|�\}}}}}| jjdd||||g i dg |�d�|�d�|�dd�|�d�i |�d d �d �I d H S ) ac Add a label to a task. Adds a label to a task. Use this endpoint to add a label that you can use to filter tasks in the InfluxDB UI. This method makes an asynchronous HTTP request. :param async_req bool :param str task_id: The ID of the task to label. (required) :param LabelMapping label_mapping: An object that contains a _`labelID`_ to add to the task. (required) :param str zap_trace_span: OpenTracing span context :return: LabelResponse If the method is called asynchronously, returns the request thread. rt r� r� r r r Tr r Nr r� r� r r r �post_tasks_id_labels_asyncO s( � �z'TasksService.post_tasks_id_labels_asyncc K s� t � }dddg}| �d||� d|ks2|d d kr:td��d|ksN|d d krVtd��i }d|krn|d |d< g }i }d|kr�|d |d< d } d|kr�|d } | j�d g�|d < | j�d g�|d < ||||| fS ) Nr r� r( r� zLMissing the required parameter `task_id` when calling `post_tasks_id_labels`zRMissing the required parameter `label_mapping` when calling `post_tasks_id_labels`r) r* r+ r, r� r� ) r r r� r r" r3 r# r$ r% r& r r r r� q s8 � � ��z*TasksService._post_tasks_id_labels_preparec K s: d|d< |� d�r"| j||f|�S | j||f|�}|S dS )a� Add a member to a task. **Deprecated**: Tasks don't use `owner` and `member` roles. Use [`/api/v2/authorizations`](#tag/Authorizations-(API-tokens)) to assign user permissions. Adds a user to members of a task and returns the member. This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.post_tasks_id_members(task_id, add_resource_member_request_body, async_req=True) >>> result = thread.get() :param async_req bool :param str task_id: The task ID. (required) :param AddResourceMemberRequestBody add_resource_member_request_body: A user to add as a member of the task. (required) :param str zap_trace_span: OpenTracing span context :return: ResourceMember If the method is called asynchronously, returns the request thread. Tr r N)r �$post_tasks_id_members_with_http_info�r r � add_resource_member_request_bodyr r r r r �post_tasks_id_members� s z"TasksService.post_tasks_id_membersc K sh | j ||f|�\}}}}}| jjdd||||g i dg |�d�|�d�|�dd�|�d�i |�d d �d �S ) a� Add a member to a task. **Deprecated**: Tasks don't use `owner` and `member` roles. Use [`/api/v2/authorizations`](#tag/Authorizations-(API-tokens)) to assign user permissions. Adds a user to members of a task and returns the member. This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.post_tasks_id_members_with_http_info(task_id, add_resource_member_request_body, async_req=True) >>> result = thread.get() :param async_req bool :param str task_id: The task ID. (required) :param AddResourceMemberRequestBody add_resource_member_request_body: A user to add as a member of the task. (required) :param str zap_trace_span: OpenTracing span context :return: ResourceMember If the method is called asynchronously, returns the request thread. r� r� �ResourceMemberr r r Tr r Nr �� _post_tasks_id_members_preparer r r � r r r� r r" r# r$ r% r& r r r r� � s( � �z1TasksService.post_tasks_id_members_with_http_infoc � sn | j ||f|�\}}}}}| jjdd||||g i dg |�d�|�d�|�dd�|�d�i |�d d �d �I d H S ) a� Add a member to a task. **Deprecated**: Tasks don't use `owner` and `member` roles. Use [`/api/v2/authorizations`](#tag/Authorizations-(API-tokens)) to assign user permissions. Adds a user to members of a task and returns the member. This method makes an asynchronous HTTP request. :param async_req bool :param str task_id: The task ID. (required) :param AddResourceMemberRequestBody add_resource_member_request_body: A user to add as a member of the task. (required) :param str zap_trace_span: OpenTracing span context :return: ResourceMember If the method is called asynchronously, returns the request thread. r� r� r� r r r Tr r Nr r� r� r r r �post_tasks_id_members_async� s( � �z(TasksService.post_tasks_id_members_asyncc K s� t � }dddg}| �d||� d|ks2|d d kr:td��d|ksN|d d krVtd��i }d|krn|d |d< g }i }d|kr�|d |d< d } d|kr�|d } | j�d g�|d < | j�d g�|d < ||||| fS ) Nr r� r( r� zMMissing the required parameter `task_id` when calling `post_tasks_id_members`zfMissing the required parameter `add_resource_member_request_body` when calling `post_tasks_id_members`r) r* r+ r, r� r� � r r r� r r" r3 r# r$ r% r& r r r r� � s8 � � ��z+TasksService._post_tasks_id_members_preparec K s: d|d< |� d�r"| j||f|�S | j||f|�}|S dS )a Add an owner for a task. **Deprecated**: Tasks don't use `owner` and `member` roles. Use [`/api/v2/authorizations`](#tag/Authorizations-(API-tokens)) to assign user permissions. Assigns a task `owner` role to a user. Use this endpoint to create a _resource owner_ for the task. A _resource owner_ is a user with `role: owner` for a specific resource. This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.post_tasks_id_owners(task_id, add_resource_member_request_body, async_req=True) >>> result = thread.get() :param async_req bool :param str task_id: The task ID. (required) :param AddResourceMemberRequestBody add_resource_member_request_body: A user to add as an owner of the task. (required) :param str zap_trace_span: OpenTracing span context :return: ResourceOwner If the method is called asynchronously, returns the request thread. Tr r N)r �#post_tasks_id_owners_with_http_infor� r r r �post_tasks_id_owners s z!TasksService.post_tasks_id_ownersc K sh | j ||f|�\}}}}}| jjdd||||g i dg |�d�|�d�|�dd�|�d�i |�d d �d �S ) a* Add an owner for a task. **Deprecated**: Tasks don't use `owner` and `member` roles. Use [`/api/v2/authorizations`](#tag/Authorizations-(API-tokens)) to assign user permissions. Assigns a task `owner` role to a user. Use this endpoint to create a _resource owner_ for the task. A _resource owner_ is a user with `role: owner` for a specific resource. This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.post_tasks_id_owners_with_http_info(task_id, add_resource_member_request_body, async_req=True) >>> result = thread.get() :param async_req bool :param str task_id: The task ID. (required) :param AddResourceMemberRequestBody add_resource_member_request_body: A user to add as an owner of the task. (required) :param str zap_trace_span: OpenTracing span context :return: ResourceOwner If the method is called asynchronously, returns the request thread. r� r� � ResourceOwnerr r r Tr r Nr �� _post_tasks_id_owners_preparer r r r� r r r r� 2 s( � �z0TasksService.post_tasks_id_owners_with_http_infoc � sn | j ||f|�\}}}}}| jjdd||||g i dg |�d�|�d�|�dd�|�d�i |�d d �d �I d H S ) a> Add an owner for a task. **Deprecated**: Tasks don't use `owner` and `member` roles. Use [`/api/v2/authorizations`](#tag/Authorizations-(API-tokens)) to assign user permissions. Assigns a task `owner` role to a user. Use this endpoint to create a _resource owner_ for the task. A _resource owner_ is a user with `role: owner` for a specific resource. This method makes an asynchronous HTTP request. :param async_req bool :param str task_id: The task ID. (required) :param AddResourceMemberRequestBody add_resource_member_request_body: A user to add as an owner of the task. (required) :param str zap_trace_span: OpenTracing span context :return: ResourceOwner If the method is called asynchronously, returns the request thread. r� r� r� r r r Tr r Nr r� r� r r r �post_tasks_id_owners_asyncW s( � �z'TasksService.post_tasks_id_owners_asyncc K s� t � }dddg}| �d||� d|ks2|d d kr:td��d|ksN|d d krVtd��i }d|krn|d |d< g }i }d|kr�|d |d< d } d|kr�|d } | j�d g�|d < | j�d g�|d < ||||| fS ) Nr r� r( r� zLMissing the required parameter `task_id` when calling `post_tasks_id_owners`zeMissing the required parameter `add_resource_member_request_body` when calling `post_tasks_id_owners`r) r* r+ r, r� r� r� r r r r� y s8 � � ��z*TasksService._post_tasks_id_owners_preparec K s6 d|d< |� d�r | j|f|�S | j|f|�}|S dS )a� Start a task run, overriding the schedule. Schedules a task run to start immediately, ignoring scheduled runs. Use this endpoint to manually start a task run. Scheduled runs will continue to run as scheduled. This may result in concurrently running tasks. To _retry_ a previous run (and avoid creating a new run), use the [`POST /api/v2/tasks/{taskID}/runs/{runID}/retry` endpoint](#operation/PostTasksIDRunsIDRetry). This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.post_tasks_id_runs(task_id, async_req=True) >>> result = thread.get() :param async_req bool :param str task_id: (required) :param str zap_trace_span: OpenTracing span context :param RunManually run_manually: :return: Run If the method is called asynchronously, returns the request thread. Tr r N)r �!post_tasks_id_runs_with_http_infor r r r �post_tasks_id_runs� s z TasksService.post_tasks_id_runsc K sf | j |f|�\}}}}}| jjdd||||g i dg |�d�|�d�|�dd�|�d�i |�d d �d �S ) a� Start a task run, overriding the schedule. Schedules a task run to start immediately, ignoring scheduled runs. Use this endpoint to manually start a task run. Scheduled runs will continue to run as scheduled. This may result in concurrently running tasks. To _retry_ a previous run (and avoid creating a new run), use the [`POST /api/v2/tasks/{taskID}/runs/{runID}/retry` endpoint](#operation/PostTasksIDRunsIDRetry). This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.post_tasks_id_runs_with_http_info(task_id, async_req=True) >>> result = thread.get() :param async_req bool :param str task_id: (required) :param str zap_trace_span: OpenTracing span context :param RunManually run_manually: :return: Run If the method is called asynchronously, returns the request thread. r� r� r� r r r Tr r Nr ��_post_tasks_id_runs_preparer r r r! r r r r� � s( � �z.TasksService.post_tasks_id_runs_with_http_infoc � sl | j |f|�\}}}}}| jjdd||||g i dg |�d�|�d�|�dd�|�d�i |�d d �d �I d H S ) a Start a task run, overriding the schedule. Schedules a task run to start immediately, ignoring scheduled runs. Use this endpoint to manually start a task run. Scheduled runs will continue to run as scheduled. This may result in concurrently running tasks. To _retry_ a previous run (and avoid creating a new run), use the [`POST /api/v2/tasks/{taskID}/runs/{runID}/retry` endpoint](#operation/PostTasksIDRunsIDRetry). This method makes an asynchronous HTTP request. :param async_req bool :param str task_id: (required) :param str zap_trace_span: OpenTracing span context :param RunManually run_manually: :return: Run If the method is called asynchronously, returns the request thread. r� r� r� r r r Tr r Nr r� r! r r r �post_tasks_id_runs_async� s( � �z%TasksService.post_tasks_id_runs_asyncc K s� t � }dddg}| �d||� d|ks2|d d kr:td��i }d|krR|d |d< g }i }d|krn|d |d< d }d|kr�|d }| j�dg�|d < | j�dg�|d < |||||fS ) Nr r( Z run_manuallyr� zJMissing the required parameter `task_id` when calling `post_tasks_id_runs`r) r* r+ r, r� r� r2 r r r r� � s0 � ��z(TasksService._post_tasks_id_runs_preparec K s: d|d< |� d�r"| j||f|�S | j||f|�}|S dS )a Retry a task run. Queues a [task](https://docs.influxdata.com/influxdb/latest/reference/glossary/#task) run to retry and returns the scheduled run. To manually start a _new_ task run, use the [`POST /api/v2/tasks/{taskID}/runs` endpoint](#operation/PostTasksIDRuns). #### Limitations - The task must be _active_ (`status: "active"`). This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.post_tasks_id_runs_id_retry(task_id, run_id, async_req=True) >>> result = thread.get() :param async_req bool :param str task_id: A [task](https://docs.influxdata.com/influxdb/latest/reference/glossary/#task) ID. Specifies the task to retry. (required) :param str run_id: A [task](https://docs.influxdata.com/influxdb/latest/reference/glossary/#task) run ID. Specifies the task run to retry. To find a task run ID, use the [`GET /api/v2/tasks/{taskID}/runs` endpoint](#operation/GetTasksIDRuns) to list task runs. (required) :param str zap_trace_span: OpenTracing span context :param str body: :return: Run If the method is called asynchronously, returns the request thread. Tr r N)r �*post_tasks_id_runs_id_retry_with_http_inforN r r r �post_tasks_id_runs_id_retry s z(TasksService.post_tasks_id_runs_id_retryc K sh | j ||f|�\}}}}}| jjdd||||g i dg |�d�|�d�|�dd�|�d�i |�d d �d �S ) a Retry a task run. Queues a [task](https://docs.influxdata.com/influxdb/latest/reference/glossary/#task) run to retry and returns the scheduled run. To manually start a _new_ task run, use the [`POST /api/v2/tasks/{taskID}/runs` endpoint](#operation/PostTasksIDRuns). #### Limitations - The task must be _active_ (`status: "active"`). This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.post_tasks_id_runs_id_retry_with_http_info(task_id, run_id, async_req=True) >>> result = thread.get() :param async_req bool :param str task_id: A [task](https://docs.influxdata.com/influxdb/latest/reference/glossary/#task) ID. Specifies the task to retry. (required) :param str run_id: A [task](https://docs.influxdata.com/influxdb/latest/reference/glossary/#task) run ID. Specifies the task run to retry. To find a task run ID, use the [`GET /api/v2/tasks/{taskID}/runs` endpoint](#operation/GetTasksIDRuns) to list task runs. (required) :param str zap_trace_span: OpenTracing span context :param str body: :return: Run If the method is called asynchronously, returns the request thread. �)/api/v2/tasks/{taskID}/runs/{runID}/retryr� r� r r r Tr r Nr ��$_post_tasks_id_runs_id_retry_preparer r r rT r r r r� 7 s( � �z7TasksService.post_tasks_id_runs_id_retry_with_http_infoc � sn | j ||f|�\}}}}}| jjdd||||g i dg |�d�|�d�|�dd�|�d�i |�d d �d �I d H S ) a; Retry a task run. Queues a [task](https://docs.influxdata.com/influxdb/latest/reference/glossary/#task) run to retry and returns the scheduled run. To manually start a _new_ task run, use the [`POST /api/v2/tasks/{taskID}/runs` endpoint](#operation/PostTasksIDRuns). #### Limitations - The task must be _active_ (`status: "active"`). This method makes an asynchronous HTTP request. :param async_req bool :param str task_id: A [task](https://docs.influxdata.com/influxdb/latest/reference/glossary/#task) ID. Specifies the task to retry. (required) :param str run_id: A [task](https://docs.influxdata.com/influxdb/latest/reference/glossary/#task) run ID. Specifies the task run to retry. To find a task run ID, use the [`GET /api/v2/tasks/{taskID}/runs` endpoint](#operation/GetTasksIDRuns) to list task runs. (required) :param str zap_trace_span: OpenTracing span context :param str body: :return: Run If the method is called asynchronously, returns the request thread. r� r� r� r r r Tr r Nr r� rT r r r �!post_tasks_id_runs_id_retry_async] s( � �z.TasksService.post_tasks_id_runs_id_retry_asyncc K s� t � }ddddg}| �d||� d|ks4|d d kr<td��d|ksP|d d krXtd��i }d|krp|d |d< d|kr�|d |d < g }i }d|kr�|d |d < d } d|kr�|d } | j�d g�|d < | j�d g�|d< ||||| fS )Nr rO r( r r� zSMissing the required parameter `task_id` when calling `post_tasks_id_runs_id_retry`zRMissing the required parameter `run_id` when calling `post_tasks_id_runs_id_retry`r) rV r* r+ r, z application/json; charset=utf-8r� r� rW r r r r� � s< � � ��z1TasksService._post_tasks_id_runs_id_retry_prepare)N)Z�__name__� __module__� __qualname__�__doc__r r r r' r r6 r4 r; r9 r? r< rD rB rH rG rL rK rP rM rU rS rY rX r` r^ rm rl rq rp rs rr rx rw rz ry r r~ r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� � __classcell__r r r r r s� $!%"!%"!%"!%"! +()$!$!$!$!$!(%'%"!%"!%"%$! %"%%"%%"%%"!&#r )r� � __future__r �reZ%influxdb_client.service._base_servicer r r r r r �<module> s
💾 Save Changes
❌ Cancel