o gZh @sHddlZddlmZddlmZddlmZmZm Z GdddeZ dS)N)ObjectApiResponse)NamespacedClient) SKIP_IN_PATH_quote_rewrite_parametersc@sBeZdZedddddddddd dejejeefdejejeej efdeje dejejeej efdeje dejej ed ejed eje d eje d e ej fd dZ eddddddddedeje dejejeej efdeje d eje dejejddefd eje d e ej fddZeddddddddddddd dejejeej efdeje deje dejejeej efdejejdefdeje dejejddefdejej ed ejed eje dejejddefd eje d e ej fddZdS) TasksClientN) task_idactions error_trace filter_pathhumannodesparent_task_idprettywait_for_completionr r r r r rrrrreturnc Cs|tvr dt|d} nd} i} |dur|| d<|dur!|| d<|dur)|| d<|dur1|| d<|dur9|| d <|durA|| d <|durI|| d <| durQ| | d <d di} |jd| | | dS)a Cancels a task, if it can be cancelled through an API. ``_ :param task_id: ID of the task. :param actions: Comma-separated list or wildcard expression of actions used to limit the request. :param nodes: Comma-separated list of node IDs or names used to limit the request. :param parent_task_id: Parent task ID used to limit the tasks. :param wait_for_completion: Should the request block until the cancellation of the task and its descendant tasks is completed. Defaults to false /_tasks/z/_cancelz/_tasks/_cancelNr r r r rrrracceptapplication/jsonPOSTparamsheaders)rrperform_request) selfr r r r r rrrr_TasksClient__path_TasksClient__query_TasksClient__headersrW/var/www/html/lang_env/lib/python3.10/site-packages/elasticsearch/_sync/client/tasks.pycancels0zTasksClient.cancel)r r r rtimeoutrr"z t.Literal[-1]z t.Literal[0]c Cs|tvrtddt|}i} |dur|| d<|dur!|| d<|dur)|| d<|dur1|| d<|dur9|| d<|durA|| d <d d i} |jd || | d S)a Returns information about a task. ``_ :param task_id: ID of the task. :param timeout: Period to wait for a response. If no response is received before the timeout expires, the request fails and returns an error. :param wait_for_completion: If `true`, the request blocks until the task has completed. z*Empty value passed for parameter 'task_id'rNr r r rr"rrrGETr)r ValueErrorrr) rr r r r rr"rrrrrrr getPs(zTasksClient.get) r detailedr r group_byr master_timeoutnode_idrrr"rr&r'z%t.Literal['nodes', 'none', 'parents']r(r)c Csd} i}|dur ||d<|dur||d<|dur||d<|dur$||d<|dur,||d<|dur4||d<|dur<||d <|durD||d <| durL| |d <| durT| |d <| dur\| |d <| durd| |d<ddi}|jd| ||dS)a Returns a list of tasks. ``_ :param actions: Comma-separated list or wildcard expression of actions used to limit the request. :param detailed: If `true`, the response includes detailed information about shard recoveries. :param group_by: Key used to group tasks in the response. :param master_timeout: Period to wait for a connection to the master node. If no response is received before the timeout expires, the request fails and returns an error. :param node_id: Comma-separated list of node IDs or names used to limit returned information. :param parent_task_id: Parent task ID used to limit returned information. To return all tasks, omit this parameter or use a value of `-1`. :param timeout: Period to wait for a response. If no response is received before the timeout expires, the request fails and returns an error. :param wait_for_completion: If `true`, the request blocks until the operation is complete. z/_tasksNr r&r r r'r r(r)rrr"rrrr#r)r)rr r&r r r'r r(r)rrr"rrrrrrr list|s<+zTasksClient.list)__name__ __module__ __qualname__rtOptionalUnionintstrSequenceboolrAnyr!r%r*rrrr rs    4  +   r) typingr.Zelastic_transportr_baserutilsrrrrrrrr s