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 s|tvrdt|d} nd} i} |dur|| d<|dur"|| d<|dur*|| d<|dur2|| d<|dur:|| d <|durB|| d <|durJ|| d <| durR| | d <d di} |jd| | | dIdHS)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__headersrX/var/www/html/lang_env/lib/python3.10/site-packages/elasticsearch/_async/client/tasks.pycancels2 zTasksClient.cancel)r r r rtimeoutrr"z t.Literal[-1]z t.Literal[0]c s|tvr tddt|}i} |dur|| d<|dur"|| d<|dur*|| d<|dur2|| d<|dur:|| d<|durB|| d <d d i} |jd || | d IdHS)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 sd} i}|dur ||d<|dur||d<|dur||d<|dur%||d<|dur-||d<|dur5||d<|dur=||d <|durE||d <| durM| |d <| durU| |d <| dur]| |d <| dure| |d<ddi}|jd| ||dIdHS)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