U wâ’i¢=ã@s8dZddlmZddlZddlmZGdd„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)Ú_BaseServicecsÂeZdZdZd‡fdd„ Zdd„Zdd„Zd d „Zdd„Zd d„Z dd„Z dd„Zdd„Zdd„Z dd„Zdd„Zdd„Zdd„Zdd „Zd!d"„Zd#d$„Zd%d&„Zd'd(„Zd)d*„Zd+d,„Zd-d.„Zd/d0„Zd1d2„Zd3d4„Zd5d6„Zd7d8„Zd9d:„Zd;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„Zdydz„Z?d{d|„Z@d}d~„ZAdd€„ZBdd‚„ZCdƒd„„ZDd…d†„ZEd‡dˆ„ZFd‰dŠ„ZGd‹dŒ„ZHddŽ„ZIdd„ZJd‘d’„ZKd“d”„ZLd•d–„ZMd—d˜„ZNd™dš„ZOd›dœ„ZPddž„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. Ncstƒ |¡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.pyrszTasksService.__init__cKs6d|d<| d¡r |j|f|ŽS|j|f|Ž}|SdS)apDelete 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ÚdatarrrÚdelete_tasks_id s zTasksService.delete_tasks_idcKsf|j|f|Ž\}}}}}|jjdd||||gidg| d¡| d¡| dd¡| d¡i| d d¡d S)aDelete 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}ÚDELETENrr Ú_preload_contentTÚ_request_timeoutÚ urlopen_kw©ÚbodyZpost_paramsÚfilesZ response_typeZ auth_settingsrr rrZcollection_formatsr©Ú_delete_tasks_id_preparerÚcall_apir©rrrÚlocal_var_paramsÚpath_paramsÚquery_paramsÚ header_paramsÚbody_paramsrrrr7s(ÿ ñz+TasksService.delete_tasks_id_with_http_infocËsl|j|f|Ž\}}}}}|jjdd||||gidg| d¡| d¡| dd¡| d¡i| d d¡d IdHS)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. rrNrr rTrrrrr!rrrÚdelete_tasks_id_async[s(ÿ ñz"TasksService.delete_tasks_id_asyncc Kstƒ}ddg}| d||¡d|ks0|ddkr8tdƒ‚i}d|krP|d|d<g}i}d|krl|d|d<d}|j dg¡|d<|||||fS) NrÚzap_trace_spanrzGMissing 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© rrrr"Ú all_paramsr#r$r%r&rrrr|s& ÿÿz%TasksService._delete_tasks_id_preparecKs:d|d<| d¡r"|j||f|ŽS|j||f|Ž}|SdS)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 rN)rÚ(delete_tasks_id_labels_id_with_http_info)rrÚlabel_idrrrrrÚdelete_tasks_id_labels_id—s z&TasksService.delete_tasks_id_labels_idc Ksh|j||f|Ž\}}}}}|jjdd||||gidg| 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}rNrr rTrrr©Ú"_delete_tasks_id_labels_id_preparerr r© rrr5rr"r#r$r%r&rrrr4¯s(ÿ ñz5TasksService.delete_tasks_id_labels_id_with_http_infoc Ësn|j||f|Ž\}}}}}|jjdd||||gidg| d¡| d¡| dd¡| d¡i| d d¡d IdHS)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. r7rNrr rTrrrr8r:rrrÚdelete_tasks_id_labels_id_asyncÔs(ÿ ñz,TasksService.delete_tasks_id_labels_id_asyncc KsÂtƒ}dddg}| d||¡d|ks2|ddkr:tdƒ‚d|ksN|ddkrVtdƒ‚i}d|krn|d|d<d|kr‚|d|d<g}i}d|krž|d|d <d} |j d g¡|d<||||| fS)Nrr5r(r6zQMissing 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-) rrr5rr"r3r#r$r%r&rrrr9ös2 ÿ ÿÿz/TasksService._delete_tasks_id_labels_id_preparecKs:d|d<| d¡r"|j||f|ŽS|j||f|Ž}|SdS)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 rN)rÚ)delete_tasks_id_members_id_with_http_info©rÚuser_idrrrrrrÚdelete_tasks_id_members_ids z'TasksService.delete_tasks_id_members_idc Ksh|j||f|Ž\}}}}}|jjdd||||gidg| 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}rNrr rTrrr©Ú#_delete_tasks_id_members_id_preparerr r© rr>rrr"r#r$r%r&rrrr</s(ÿ ñz6TasksService.delete_tasks_id_members_id_with_http_infoc Ësn|j||f|Ž\}}}}}|jjdd||||gidg| d¡| d¡| dd¡| d¡i| d d¡d IdHS)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@rNrr rTrrrrArCrrrÚ delete_tasks_id_members_id_asyncTs(ÿ ñz-TasksService.delete_tasks_id_members_id_asyncc KsÂtƒ}dddg}| d||¡d|ks2|ddkr:tdƒ‚d|ksN|ddkrVtdƒ‚i}d|krn|d|d<d|kr‚|d|d<g}i}d|krž|d|d <d} |j d g¡|d<||||| fS)Nr>rr(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-© rr>rrr"r3r#r$r%r&rrrrBvs2 ÿ ÿÿz0TasksService._delete_tasks_id_members_id_preparecKs:d|d<| d¡r"|j||f|ŽS|j||f|Ž}|SdS)aRemove 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 rN)rÚ(delete_tasks_id_owners_id_with_http_infor=rrrÚdelete_tasks_id_owners_id—s z&TasksService.delete_tasks_id_owners_idc Ksh|j||f|Ž\}}}}}|jjdd||||gidg| 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}rNrr rTrrr©Ú"_delete_tasks_id_owners_id_preparerr rrCrrrrG¯s(ÿ ñz5TasksService.delete_tasks_id_owners_id_with_http_infoc Ësn|j||f|Ž\}}}}}|jjdd||||gidg| d¡| d¡| dd¡| d¡i| d d¡d IdHS)aPRemove 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. rIrNrr rTrrrrJrCrrrÚdelete_tasks_id_owners_id_asyncÔs(ÿ ñz,TasksService.delete_tasks_id_owners_id_asyncc KsÂtƒ}dddg}| d||¡d|ks2|ddkr:tdƒ‚d|ksN|ddkrVtdƒ‚i}d|krn|d|d<d|kr‚|d|d<g}i}d|krž|d|d <d} |j d g¡|d<||||| fS)Nr>rr(rHzQMissing 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`rEr)r*r+r,r-rFrrrrKös2 ÿ ÿÿz/TasksService._delete_tasks_id_owners_id_preparecKs:d|d<| d¡r"|j||f|ŽS|j||f|Ž}|SdS)aaCancel 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 rN)rÚ&delete_tasks_id_runs_id_with_http_info©rrÚrun_idrrrrrÚdelete_tasks_id_runs_ids z$TasksService.delete_tasks_id_runs_idc Ksh|j||f|Ž\}}}}}|jjdd||||gidg| d¡| d¡| dd¡| d¡i| d d¡d S)apCancel 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}rNrr rTrrr©Ú _delete_tasks_id_runs_id_preparerr r© rrrOrr"r#r$r%r&rrrrM/s(ÿ ñz3TasksService.delete_tasks_id_runs_id_with_http_infoc Ësn|j||f|Ž\}}}}}|jjdd||||gidg| d¡| d¡| dd¡| d¡i| d d¡d IdHS)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. rQrNrr rTrrrrRrTrrrÚdelete_tasks_id_runs_id_asyncTs(ÿ ñz*TasksService.delete_tasks_id_runs_id_asyncc KsÂtƒ}dddg}| d||¡d|ks2|ddkr:tdƒ‚d|ksN|ddkrVtdƒ‚i}d|krn|d|d<d|kr‚|d|d<g}i}d|krž|d|d <d} |j d g¡|d<||||| fS)NrrOr(rPzOMissing 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-© rrrOrr"r3r#r$r%r&rrrrSvs2 ÿ ÿÿz-TasksService._delete_tasks_id_runs_id_preparecKs2d|d<| d¡r|jf|ŽS|jf|Ž}|SdS)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 rN)rÚget_tasks_with_http_info)rrrrrrÚ get_tasks—s zTasksService.get_taskscKsd|jf|Ž\}}}}}|jjdd||||gidg| d¡| d¡| dd¡| d¡i| d d ¡dS)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ÚTasksrr rTrrNr©Ú_get_tasks_preparerr r©rrr"r#r$r%r&rrrrXµs( ÿ ñz%TasksService.get_tasks_with_http_infocËsj|jf|Ž\}}}}}|jjdd||||gidg| d¡| d¡| dd¡| d¡i| d d ¡dId HS)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. rZr[r\rr rTrrNrr]r_rrrÚget_tasks_asyncàs( ÿ ñzTasksService.get_tasks_asyncc Ks~tƒ}ddddddddd g }| d ||¡d|krF|ddkrFtdƒ‚d|krb|dd krbtdƒ‚i}g}d|kr„| d|df¡d|krž| d|df¡d|kr¸| d|df¡d|krÒ| d|df¡d|krì| d|df¡d|kr| d|df¡d|kr$| d|df¡d |kr@| d |d f¡i}d|krZ|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Úappendrr1)rrr"r3r#r$r%r&rrrr^sB ÿzTasksService._get_tasks_preparecKs6d|d<| d¡r |j|f|ŽS|j|f|Ž}|SdS)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 rN)rÚget_tasks_id_with_http_inforrrrÚget_tasks_id1s zTasksService.get_tasks_idcKsf|j|f|Ž\}}}}}|jjdd||||gidg| d¡| d¡| dd¡| d¡i| d d ¡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_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. rr[ÚTaskrr rTrrNr©Ú_get_tasks_id_preparerr rr!rrrrlHs(ÿ ñz(TasksService.get_tasks_id_with_http_infocËsl|j|f|Ž\}}}}}|jjdd||||gidg| d¡| d¡| dd¡| d¡i| d d ¡dId HS)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. rr[rnrr rTrrNrror!rrrÚget_tasks_id_asyncls(ÿ ñzTasksService.get_tasks_id_asyncc Kstƒ}ddg}| d||¡d|ks0|ddkr8tdƒ‚i}d|krP|d|d<g}i}d|krl|d|d<d}|j dg¡|d<|||||fS) Nrr(rmzDMissing the required parameter `task_id` when calling `get_tasks_id`r)r*r+r,r-r2rrrrps& ÿÿz"TasksService._get_tasks_id_preparecKs6d|d<| d¡r |j|f|ŽS|j|f|Ž}|SdS)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 rN)rÚ"get_tasks_id_labels_with_http_inforrrrÚget_tasks_id_labels¨s z TasksService.get_tasks_id_labelscKsf|j|f|Ž\}}}}}|jjdd||||gidg| d¡| d¡| dd¡| d¡i| d d ¡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_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[ÚLabelsResponserr rTrrNr©Ú_get_tasks_id_labels_preparerr rr!rrrrr¿s(ÿ ñz/TasksService.get_tasks_id_labels_with_http_infocËsl|j|f|Ž\}}}}}|jjdd||||gidg| d¡| d¡| dd¡| d¡i| d d ¡dId HS)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. rtr[rurr rTrrNrrvr!rrrÚget_tasks_id_labels_asyncãs(ÿ ñz&TasksService.get_tasks_id_labels_asyncc Kstƒ}ddg}| d||¡d|ks0|ddkr8tdƒ‚i}d|krP|d|d<g}i}d|krl|d|d<d}|j dg¡|d<|||||fS) Nrr(rszKMissing the required parameter `task_id` when calling `get_tasks_id_labels`r)r*r+r,r-r2rrrrws& ÿÿz)TasksService._get_tasks_id_labels_preparecKs6d|d<| d¡r |j|f|ŽS|j|f|Ž}|SdS)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 rN)rÚ get_tasks_id_logs_with_http_inforrrrÚget_tasks_id_logss zTasksService.get_tasks_id_logscKsf|j|f|Ž\}}}}}|jjdd||||gidg| d¡| d¡| dd¡| d¡i| d d ¡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_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[ÚLogsrr rTrrNr©Ú_get_tasks_id_logs_preparerr rr!rrrry6s(ÿ ñz-TasksService.get_tasks_id_logs_with_http_infocËsl|j|f|Ž\}}}}}|jjdd||||gidg| d¡| d¡| dd¡| d¡i| d d ¡dId HS)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|rr rTrrNrr}r!rrrÚget_tasks_id_logs_asyncZs(ÿ ñz$TasksService.get_tasks_id_logs_asyncc Kstƒ}ddg}| d||¡d|ks0|ddkr8tdƒ‚i}d|krP|d|d<g}i}d|krl|d|d<d}|j dg¡|d<|||||fS) Nrr(rzzIMissing the required parameter `task_id` when calling `get_tasks_id_logs`r)r*r+r,r-r2rrrr~{s& ÿÿz'TasksService._get_tasks_id_logs_preparecKs6d|d<| d¡r |j|f|ŽS|j|f|Ž}|SdS)aWList 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 rN)rÚ#get_tasks_id_members_with_http_inforrrrÚget_tasks_id_members–s z!TasksService.get_tasks_id_memberscKsf|j|f|Ž\}}}}}|jjdd||||gidg| d¡| d¡| dd¡| d¡i| d d ¡dS)afList 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[ÚResourceMembersrr rTrrNr©Ú_get_tasks_id_members_preparerr rr!rrrr€s(ÿ ñz0TasksService.get_tasks_id_members_with_http_infocËsl|j|f|Ž\}}}}}|jjdd||||gidg| d¡| d¡| dd¡| d¡i| d d ¡dId HS)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ƒrr rTrrNrr„r!rrrÚget_tasks_id_members_asyncÑs(ÿ ñz'TasksService.get_tasks_id_members_asyncc Kstƒ}ddg}| d||¡d|ks0|ddkr8tdƒ‚i}d|krP|d|d<g}i}d|krl|d|d<d}|j dg¡|d<|||||fS) Nrr(rzLMissing the required parameter `task_id` when calling `get_tasks_id_members`r)r*r+r,r-r2rrrr…òs& ÿÿz*TasksService._get_tasks_id_members_preparecKs6d|d<| d¡r |j|f|ŽS|j|f|Ž}|SdS)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 rN)rÚ"get_tasks_id_owners_with_http_inforrrrÚget_tasks_id_owners s z TasksService.get_tasks_id_ownerscKsf|j|f|Ž\}}}}}|jjdd||||gidg| d¡| d¡| dd¡| d¡i| d d ¡dS)a5List 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[ÚResourceOwnersrr rTrrNr©Ú_get_tasks_id_owners_preparerr rr!rrrr‡$s(ÿ ñz/TasksService.get_tasks_id_owners_with_http_infocËsl|j|f|Ž\}}}}}|jjdd||||gidg| d¡| d¡| dd¡| d¡i| d d ¡dId HS)alList 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Šrr rTrrNrr‹r!rrrÚget_tasks_id_owners_asyncHs(ÿ ñz&TasksService.get_tasks_id_owners_asyncc Kstƒ}ddg}| d||¡d|ks0|ddkr8tdƒ‚i}d|krP|d|d<g}i}d|krl|d|d<d}|j dg¡|d<|||||fS) Nrr(rˆzKMissing the required parameter `task_id` when calling `get_tasks_id_owners`r)r*r+r,r-r2rrrrŒis& ÿÿz)TasksService._get_tasks_id_owners_preparecKs6d|d<| d¡r |j|f|ŽS|j|f|Ž}|SdS)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 rN)rÚ get_tasks_id_runs_with_http_inforrrrÚget_tasks_id_runs„s zTasksService.get_tasks_id_runscKsf|j|f|Ž\}}}}}|jjdd||||gidg| d¡| d¡| dd¡| d¡i| d d ¡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_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[ÚRunsrr rTrrNr©Ú_get_tasks_id_runs_preparerr rr!rrrrŽŸs(ÿ ñz-TasksService.get_tasks_id_runs_with_http_infocËsl|j|f|Ž\}}}}}|jjdd||||gidg| d¡| d¡| dd¡| d¡i| d d ¡dId HS)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. rr[r‘rr rTrrNrr’r!rrrÚget_tasks_id_runs_asyncÇs(ÿ ñz$TasksService.get_tasks_id_runs_asyncc Ks:tƒ}ddddddg}| d||¡d|ks8|ddkr@tdƒ‚d|kr\|dd kr\td ƒ‚d|krx|ddkrxtdƒ‚i}d|kr|d|d <g}d|kr®| d|df¡d|krÈ| d|df¡d|krâ| d|df¡d|krü| d|df¡i}d|kr|d|d<d}|j dg¡|d<|||||fS)Nrr(rbrfZ after_timeZbefore_timerzIMissing the required parameter `task_id` when calling `get_tasks_id_runs`rhzqInvalid value for parameter `limit` when calling `get_tasks_id_runs`, must be a value less than or equal to `500`rizrInvalid 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,rjr2rrrr“ìs> ÿ ÿz'TasksService._get_tasks_id_runs_preparecKs:d|d<| d¡r"|j||f|ŽS|j||f|Ž}|SdS)aHRetrieve 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 rN)rÚ#get_tasks_id_runs_id_with_http_inforNrrrÚget_tasks_id_runs_ids z!TasksService.get_tasks_id_runs_idc Ksh|j||f|Ž\}}}}}|jjdd||||gidg| d¡| d¡| dd¡| d¡i| d d ¡dS)aWRetrieve 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. rQr[ÚRunrr rTrrNr©Ú_get_tasks_id_runs_id_preparerr rrTrrrr•+s(ÿ ñz0TasksService.get_tasks_id_runs_id_with_http_infoc Ësn|j||f|Ž\}}}}}|jjdd||||gidg| d¡| d¡| dd¡| d¡i| d d ¡dId HS)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. rQr[r—rr rTrrNrr˜rTrrrÚget_tasks_id_runs_id_asyncPs(ÿ ñz'TasksService.get_tasks_id_runs_id_asyncc KsÂtƒ}dddg}| d||¡d|ks2|ddkr:tdƒ‚d|ksN|ddkrVtdƒ‚i}d|krn|d|d<d|kr‚|d|d<g}i}d|krž|d|d <d} |j d g¡|d<||||| fS)NrrOr(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)rVr*r+r,r-rWrrrr™rs2 ÿ ÿÿz*TasksService._get_tasks_id_runs_id_preparecKs:d|d<| d¡r"|j||f|ŽS|j||f|Ž}|SdS)aaRetrieve 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 rN)rÚ(get_tasks_id_runs_id_logs_with_http_inforNrrrÚget_tasks_id_runs_id_logs“s z&TasksService.get_tasks_id_runs_id_logsc Ksh|j||f|Ž\}}}}}|jjdd||||gidg| d¡| d¡| dd¡| d¡i| d d ¡dS)apRetrieve 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|rr rTrrNr©Ú"_get_tasks_id_runs_id_logs_preparerr rrTrrrr›«s(ÿ ñz5TasksService.get_tasks_id_runs_id_logs_with_http_infoc Ësn|j||f|Ž\}}}}}|jjdd||||gidg| d¡| d¡| dd¡| d¡i| d d ¡dId HS)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. rr[r|rr rTrrNrržrTrrrÚget_tasks_id_runs_id_logs_asyncÐs(ÿ ñz,TasksService.get_tasks_id_runs_id_logs_asyncc KsÂtƒ}dddg}| d||¡d|ks2|ddkr:tdƒ‚d|ksN|ddkrVtdƒ‚i}d|krn|d|d<d|kr‚|d|d<g}i}d|krž|d|d <d} |j d g¡|d<||||| fS)NrrOr(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)rVr*r+r,r-rWrrrrŸòs2 ÿ ÿÿz/TasksService._get_tasks_id_runs_id_logs_preparecKs:d|d<| d¡r"|j||f|ŽS|j||f|Ž}|SdS)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 rN)rÚpatch_tasks_id_with_http_info)rrÚtask_update_requestrrrrrÚpatch_tasks_ids zTasksService.patch_tasks_idc Ksh|j||f|Ž\}}}}}|jjdd||||gidg| d¡| d¡| dd¡| d¡i| d d ¡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_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ÚPATCHrnrr rTrrNr©Ú_patch_tasks_id_preparerr r© rrr¢rr"r#r$r%r&rrrr¡+s(ÿ ñz*TasksService.patch_tasks_id_with_http_infoc Ësn|j||f|Ž\}}}}}|jjdd||||gidg| d¡| d¡| dd¡| d¡i| d d ¡dId HS)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. rr¤rnrr rTrrNrr¥r§rrrÚpatch_tasks_id_asyncPs(ÿ ñz!TasksService.patch_tasks_id_asyncc KsÐtƒ}dddg}| d||¡d|ks2|ddkr:tdƒ‚d|ksN|ddkrVtdƒ‚i}d|krn|d|d<g}i}d|krŠ|d|d<d} d|krž|d} |j d g¡|d <|j d g¡|d<||||| fS)Nrr¢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/r0rr1Zselect_header_content_type) rrr¢rr"r3r#r$r%r&rrrr¦rs8 ÿ ÿÿÿz$TasksService._patch_tasks_id_preparecKs6d|d<| d¡r |j|f|ŽS|j|f|Ž}|SdS)aMCreate 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 rN)rÚpost_tasks_with_http_info)rÚtask_create_requestrrrrrÚ post_tasks—s zTasksService.post_taskscKsf|j|f|Ž\}}}}}|jjdd||||gidg| d¡| d¡| dd¡| d¡i| d d ¡dS)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ÚPOSTrnrr rTrrNr©Ú_post_tasks_preparerr r©rr¬rr"r#r$r%r&rrrr«®s(ÿ ñz&TasksService.post_tasks_with_http_infocËsl|j|f|Ž\}}}}}|jjdd||||gidg| d¡| d¡| dd¡| d¡i| d d ¡dId HS)aCreate 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. rZr®rnrr rTrrNrr¯r±rrrÚpost_tasks_asyncÒs(ÿ ñzTasksService.post_tasks_asyncc Ksžtƒ}ddg}| d||¡d|ks0|ddkr8tdƒ‚i}g}i}d|krX|d|d<d}d|krl|d}|j dg¡|d<|j dg¡|d<|||||fS) Nr¬r(rzNMissing the required parameter `task_create_request` when calling `post_tasks`r*r+r,r©rª) rr¬rr"r3r#r$r%r&rrrr°ós, ÿÿÿz TasksService._post_tasks_preparecKs:d|d<| d¡r"|j||f|ŽS|j||f|Ž}|SdS)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 rN)rÚ#post_tasks_id_labels_with_http_info)rrÚ label_mappingrrrrrÚpost_tasks_id_labelss z!TasksService.post_tasks_id_labelsc Ksh|j||f|Ž\}}}}}|jjdd||||gidg| d¡| d¡| dd¡| d¡i| d d ¡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_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. rtr®Ú LabelResponserr rTrrNr©Ú_post_tasks_id_labels_preparerr r© rrr´rr"r#r$r%r&rrrr³*s(ÿ ñz0TasksService.post_tasks_id_labels_with_http_infoc Ësn|j||f|Ž\}}}}}|jjdd||||gidg| d¡| d¡| dd¡| d¡i| d d ¡dId HS)acAdd 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. rtr®r¶rr rTrrNrr·r¹rrrÚpost_tasks_id_labels_asyncOs(ÿ ñz'TasksService.post_tasks_id_labels_asyncc KsÐtƒ}dddg}| d||¡d|ks2|ddkr:tdƒ‚d|ksN|ddkrVtdƒ‚i}d|krn|d|d<g}i}d|krŠ|d|d<d} d|krž|d} |j d g¡|d <|j d g¡|d<||||| fS)Nrr´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ª) rrr´rr"r3r#r$r%r&rrrr¸qs8 ÿ ÿÿÿz*TasksService._post_tasks_id_labels_preparecKs:d|d<| d¡r"|j||f|ŽS|j||f|Ž}|SdS)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 rN)rÚ$post_tasks_id_members_with_http_info©rrÚ add_resource_member_request_bodyrrrrrÚpost_tasks_id_members–s z"TasksService.post_tasks_id_membersc Ksh|j||f|Ž\}}}}}|jjdd||||gidg| d¡| d¡| dd¡| d¡i| d d ¡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_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®ÚResourceMemberrr rTrrNr©Ú_post_tasks_id_members_preparerr r© rrr½rr"r#r$r%r&rrrr»®s(ÿ ñz1TasksService.post_tasks_id_members_with_http_infoc Ësn|j||f|Ž\}}}}}|jjdd||||gidg| d¡| d¡| dd¡| d¡i| d d ¡dId HS)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¿rr rTrrNrrÀrÂrrrÚpost_tasks_id_members_asyncÓs(ÿ ñz(TasksService.post_tasks_id_members_asyncc KsÐtƒ}dddg}| d||¡d|ks2|ddkr:tdƒ‚d|ksN|ddkrVtdƒ‚i}d|krn|d|d<g}i}d|krŠ|d|d<d} d|krž|d} |j d g¡|d <|j d g¡|d<||||| fS)Nrr½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ª© rrr½rr"r3r#r$r%r&rrrrÁõs8 ÿ ÿÿÿz+TasksService._post_tasks_id_members_preparecKs:d|d<| d¡r"|j||f|ŽS|j||f|Ž}|SdS)aAdd 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 rN)rÚ#post_tasks_id_owners_with_http_infor¼rrrÚpost_tasks_id_owners s z!TasksService.post_tasks_id_ownersc Ksh|j||f|Ž\}}}}}|jjdd||||gidg| d¡| d¡| dd¡| d¡i| d d ¡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_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®Ú ResourceOwnerrr rTrrNr©Ú_post_tasks_id_owners_preparerr rrÂrrrrÅ2 s(ÿ ñz0TasksService.post_tasks_id_owners_with_http_infoc Ësn|j||f|Ž\}}}}}|jjdd||||gidg| d¡| d¡| dd¡| d¡i| d d ¡dId HS)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Çrr rTrrNrrÈrÂrrrÚpost_tasks_id_owners_asyncW s(ÿ ñz'TasksService.post_tasks_id_owners_asyncc KsÐtƒ}dddg}| d||¡d|ks2|ddkr:tdƒ‚d|ksN|ddkrVtdƒ‚i}d|krn|d|d<g}i}d|krŠ|d|d<d} d|krž|d} |j d g¡|d <|j d g¡|d<||||| fS)Nrr½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ÄrrrrÉy s8 ÿ ÿÿÿz*TasksService._post_tasks_id_owners_preparecKs6d|d<| d¡r |j|f|ŽS|j|f|Ž}|SdS)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 rN)rÚ!post_tasks_id_runs_with_http_inforrrrÚpost_tasks_id_runsž s zTasksService.post_tasks_id_runscKsf|j|f|Ž\}}}}}|jjdd||||gidg| d¡| d¡| dd¡| d¡i| d d ¡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_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. rr®r—rr rTrrNr©Ú_post_tasks_id_runs_preparerr rr!rrrrË¶ s(ÿ ñz.TasksService.post_tasks_id_runs_with_http_infocËsl|j|f|Ž\}}}}}|jjdd||||gidg| d¡| d¡| dd¡| d¡i| d d ¡dId HS)aStart 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. rr®r—rr rTrrNrrÍr!rrrÚpost_tasks_id_runs_asyncÛ s(ÿ ñz%TasksService.post_tasks_id_runs_asyncc Ks´tƒ}dddg}| d||¡d|ks2|ddkr:tdƒ‚i}d|krR|d|d<g}i}d|krn|d|d<d}d|kr‚|d}|j dg¡|d <|j dg¡|d <|||||fS)Nrr(Zrun_manuallyrÌzJMissing the required parameter `task_id` when calling `post_tasks_id_runs`r)r*r+r,r©rªr2rrrrÎý s0 ÿÿÿz(TasksService._post_tasks_id_runs_preparecKs:d|d<| d¡r"|j||f|ŽS|j||f|Ž}|SdS)aRetry 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 rN)rÚ*post_tasks_id_runs_id_retry_with_http_inforNrrrÚpost_tasks_id_runs_id_retry s z(TasksService.post_tasks_id_runs_id_retryc Ksh|j||f|Ž\}}}}}|jjdd||||gidg| d¡| d¡| dd¡| d¡i| d d ¡dS)aRetry 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—rr rTrrNr©Ú$_post_tasks_id_runs_id_retry_preparerr rrTrrrrÐ7 s(ÿ ñz7TasksService.post_tasks_id_runs_id_retry_with_http_infoc Ësn|j||f|Ž\}}}}}|jjdd||||gidg| d¡| d¡| dd¡| d¡i| d d ¡dId HS)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—rr rTrrNrrÓrTrrrÚ!post_tasks_id_runs_id_retry_async] s(ÿ ñz.TasksService.post_tasks_id_runs_id_retry_asyncc Ksætƒ}ddddg}| d||¡d|ks4|ddkrs