관리-도구
편집 파일: task_executor.cpython-39.pyc
a �)gz� � @ s� d dl mZmZmZ eZd dlZd dlZd dlZd dl Z d dl Z d dl Z d dl Z d dl Z d dlZd dlmZ d dlmZmZmZmZmZmZ d dlmZ d dlm Z d dl m Z d dl m Z d d l!m"Z"m#Z# d d l$m%Z% d d l&m'Z' d d l(m)Z) d d l*m+Z+ d dl,m-Z-m.Z.m/Z/m0Z0m1Z1m2Z2 d dl3m4Z4 d dl5m6Z6m7Z7 d dl8m9Z9 d dl:m;Z;m<Z< d dl=m>Z>m?Z? d dl@mAZA d dlBmCZCmDZD eA� ZEdd� ejF�G� D �ZHdgZIG dd� deJ�ZKdd � ZLd d � ZMG d d� d�ZNd d!� ZOdS )"� )�absolute_import�division�print_functionN)� constants)� AnsibleError�AnsibleParserError�AnsibleUndefinedVariable�AnsibleConnectionFailure�AnsibleActionFail�AnsibleActionSkip)� TaskResult)� get_action_args_with_defaults)�boolean)� binary_type)�to_text� to_native)�write_to_file_descriptor)� Conditional)�Task)�get_plugin_class)� become_loader�cliconf_loader�connection_loader�httpapi_loader�netconf_loader�terminal_loader)�Templar)�AnsibleCollectionConfig�AnsibleCollectionRef)�listify_lookup_plugin_terms)�to_unsafe_text�wrap_var)�namespace_facts� clean_facts)�Display)� combine_vars� isidentifierc C s g | ]}d |vrd|vr|�qS )�becomeZ_pass� )�.0�xr( r( �B/usr/lib/python3.9/site-packages/ansible/executor/task_executor.py� <listcomp>( � r, � TaskExecutorc @ s e Zd ZdS )�TaskTimeoutErrorN)�__name__� __module__� __qualname__r( r( r( r+ r/ - s r/ c C s t �d S �N)r/ )Zsignum�framer( r( r+ � task_timeout1 s r5 c s� t | t�s| S i }| �� D ]x}|d � kr.qqt |d t�rTt|d � �||d < qt |d t�r�� fdd�|d D �||d < q|d ||d < q|S )z� Remove args with a value equal to the ``omit_token`` recursively to align with now having suboptions in the argument_spec � r c s g | ]}t |� ��qS r( )� remove_omit)r) �v�� omit_tokenr( r+ r, E r- z remove_omit.<locals>.<listcomp>)� isinstance�dict�itemsr7 �list)Z task_argsr: �new_args�ir( r9 r+ r7 5 s r7 c @ s| e Zd ZdZdd� Zdd� Zdd� Zdd � Zd d d �Zd d d�Z dd� Z dd� Z dd� Z dd� Z dd� Zdd� Zdd � Zd S ) r. z� This is the main worker class for the executor pipeline, which handles loading an action plugin to actually dispatch the task to a given host. This class roughly corresponds to the old Runner() class. c C sJ || _ || _|| _|| _|| _|| _|| _d | _|| _d | _ | j� � d S r3 ) �_host�_task� _job_vars� _play_context� _new_stdin�_loader�_shared_loader_obj� _connection�_final_q�_loop_eval_errorZsquash) �self�host�taskZjob_vars� play_contextZ new_stdin�loader�shared_loader_objZfinal_qr( r( r+ �__init__U s zTaskExecutor.__init__c s� t �d| jj � �z2�z�z | �� }W n. tyT } zd}|| _W Y d}~n d}~0 0 |du�r�t|�dk�r�| �|�}t |d�}d|d< |D �]}d|v r�|d r�|� d�s�d|d< |d r�d|vs�d|v r�|d s�d|d< d |v �r:|d �r:|� d �}|� d ��s"d|d < d |d < || j_ n| jj �r:|�s:|| j_ d D ]d}||v �r>|| �r>||v�rhg ||< t || t��s�|| g||< || || ||< ||= �q>q�|� d d��s�d|d < |d �r�d|d < nt dddg d�}n t �d� | �� }t �d� d|v�rd|d< d � fdd� � t �d� � |�}t �d� |W W z| j�� W S t�yb Y S t�y� } z t �dt|� � W Y d}~S d}~0 0 S t�y: } z�t dtt|dd��| jjd �W Y d}~W z| j�� W S t�y� Y S t�y. } z t �dt|� � W Y d}~S d}~0 0 S d}~0 t�y� } z�t dtd t|dd� �tt�� �d | jjd �W Y d}~W z| j�� W S t�y� Y S t�y� } z t �dt|� � W Y d}~S d}~0 0 S d}~0 0 W z| j�� W nJ t�y Y n8 t�yD } z t �dt|� � W Y d}~n d}~0 0 n\z| j�� W nJ t�yj Y n8 t�y� } z t �dt|� � W Y d}~n d}~0 0 0 dS )!a The main executor entrypoint, where we determine if the specified task requires looping and either runs the task with self._run_loop() or self._execute(). After that, the returned results are parsed and returned as a dict. zin run() - task %sNr )�resultsT�skipped�changedF�failed�_ansible_ignore_errorszOne or more items failed�msg)�warningsZ deprecationszAll items completedzAll items skippedzNo items in the list)rT rS Zskipped_reasonrR zcalling self._execute()z_execute() done�surrogate_or_strictc s� t | t�rt| |d�S t | t�r�| D ]Z}z� | | |d�| |< W q$ ty| |dkrvt�d� � | | dd�| |< n� Y q$0 q$n,t | t�r�t| �D ]\}}� ||d�| |< q�| S )N��errors�diffz{We were unable to decode all characters in the module return data. Replaced some in an effort to return as much as possible�surrogate_then_replace) r; r r r< � UnicodeError�display�warningr> � enumerate)�resr[ �k�idx�item�� _clean_resr( r+ rg � s z$TaskExecutor.run.<locals>._clean_reszdumping result to jsonz done dumping result, returningz error closing connection: %sZ simplerepr)Z nonstring)rU rW �_ansible_no_logz.Unexpected failure during module execution: %s� )rU rW � exception�stdoutrh )rY ) r_ �debugrB �_uuid�_get_loop_itemsr rJ �len� _run_loopr< �get�pop� ignore_errorsr; r> �_executerH �close�AttributeError� Exceptionr r r! rD �no_logr � traceback� format_exc)rK r= �eZ item_resultsrb re Z item_ignoreZarrayr( rf r+ �runc s� (�*(� �(�*�zTaskExecutor.runc sh | j �� | jd< | j�� | jd vr:| jd �| j�� � t| j| jd�� d}| j�d�}|durh|}n�| j j�r0| j j| j j v �r d}| j jdkr�d}t | j j � |dd�}|s fd d �|D �}| j j j| j j| j� d �}d D ]}|| j j v r� q�q�t|d |d � t|j|| jdd��}ntd| j j ��n4| j j du�rd� �| j j �}t|t��sdtd| ��|S )z� Loads a lookup plugin to handle the with_* portion of a task (if specified), and returns the items result. Zansible_search_path�rO � variablesNZ_ansible_loop_cacheTZ first_foundF)�terms�templarZfail_on_undefinedZ convert_barec s g | ]}� � |�s|�qS r( )Z is_template)r) �t�r� r( r+ r, � r- z0TaskExecutor._get_loop_items.<locals>.<listcomp>)rO r� )�template�var�fileZ_subdir�s)r r~ ZwantlistzSUnexpected failure in finding the lookup named '%s' in the available lookup pluginsz�Invalid data passed to 'loop', it requires a list, got this instead: %s. Hint: If you passed a list/dict of just one element, try adding wantlist=True to your lookup invocation or use q/query instead of lookup.)rB Zget_search_pathrC rF Z get_basedir�appendr rq Z loop_withrG Z lookup_loaderr Zloop�action�setattrr! r| r r� r; r> )rK r= Z loop_cacheZfailZ loop_termsZmylookupZsubdirr( r� r+ rn � s@ ��z TaskExecutor._get_loop_itemsc C s$ | j }t| j|d�}| jjj|d� | jjj}| jjj}| jjj}| jjj }| jjj }| jjj pjd| d } ||v r�t � d| j|f � d} d} t|�} g } t|�D �]p\}}||d< |||< |r�||d< |||< |�rn|d ||d k|d | k| | | | | d d �|d < |�r ||d d < z||d |d d< W n t�yJ Y n0 |d d k�rn||d |d d< ||_|�r�| �r�t�|� nd} z(| jjddd�}| jj|_| j�� }W nH t�y } z.| �tdt|�d�� W Y d}~q�W Y d}~n d}~0 0 || j | _}|| j | _}| j|d�}| j� � }|| j | _}|| j | _}| �pZ|j } |||< ||d< |�r�|||< ||d< |�r�|d |d < d|d< |� d�|d< z|� | �|d< W n> t �y� } z$|�!ddt|� d�� W Y d}~n d}~0 0 t"| j#j$| jj%||d�}|�&� �s(|�'� �r8| j(�)d|� nV|�*� �rR| j(�)d |� n<t+| jd d��rp| j(�)d |� | jj,t-j.v�r�| j(�)d |� | �|� ||= | j/r�| j/j0| j/j1j0d �}| j/j2�r�| j/j2j0|d!< |�3� D ]<\}}t-j4�5||�D ]"}||v �r�|| j v�r�||= �q�q�q�| | j_ | S )"z� Runs the task with the loop items specified and collates the result into an array named 'results' which is inserted into the final result along with the item for which the loop ran. r} r� z{{z}}z�%s: The loop variable '%s' is already in use. You should set the `loop_var` value in the `loop_control` option for the task to something else to avoid variable collisions and unexpected behavior.FZansible_loop_varZansible_index_varr6 r )�indexZindex0�first�last�lengthZrevindexZ revindex0Z ansible_loopZallitemsZnextitemZprevitemT)Zexclude_parentZ exclude_tasks�rU rW N)r~ Z_ansible_item_resultrs rV Z_ansible_item_labelz)Failed to template loop_control.label: %s�� task_fieldsZv2_runner_item_on_failedZv2_runner_item_on_skippedr\ Zv2_on_file_diffZv2_runner_item_on_ok)� connection�shellr' )6rC r rF rB Z loop_control� post_validate�loop_var� index_var�pause�extended�extended_allitems�labelr_ r` ro ra � IndexError�available_variables�time�sleep�copy�_parentrD r r� r< r rt � dump_attrsrx rq r� r �updater rA �namerm Z is_failedZis_unreachablerI � send_callbackZ is_skipped�getattrr� �CZ_ACTION_INVENTORY_TASKSrH � _load_nameZ_shellr' r= �config�get_plugin_vars)rK r= � task_varsr� r� r� Z loop_pauser� r� r� Zran_oncerx Z items_lenrR Z item_indexre Ztmp_taskZtmp_play_contextr{ rb r� �trZ clear_plugins� plugin_typeZ plugin_namer� r( r( r+ rp s� � � " � � � zTaskExecutor._run_loopNc s2 |du r� j }t� j|d��d}|�� }zH� jj� j|�d�� _� jj�d� � jjsb� j j � j_� j� |� W n( t y� } z|}W Y d}~n d}~0 0 � jj }z.� j��|�s�t�d� tddd|d �W S W nH t �y } z.� jdu�rt�t|�� � j�� W Y d}~n d}~0 0 � jdu�r,� j�|du�r�d}� jj�r~t|t��rVd}n(t|t��r~t|d d�}t|t��r~d}|�r�|�|�_� jjt j v �rވ jj �� }|� d d�} | �s�tdd d �S �� | �} t| |d�S � jjt j!v �r� jj �� }t|d�S z� jj�d� W n@ t �y, � Y n, t"�yV tdd|tt#�$� �d� Y S 0 d� jj v �r�� jj � d�} t| t��r�t j%�r�t�&d� | �'� jj � | � j_ nt d| � d���� jj }i }� jj�r�|�(di ��(� jji �} n|} | �_| �(d�du�r�� | d �} n� jj)} � j*�rXt� j*dd��rX� j*�+| g��rX� jj� j*jjk�rj� �,| �| �� _*n� j� j*_� �-| �� j*� � �.| ��} |�� �� j*� �� ��_� jj� j��d�� j*_t/� j*j0�o�t j1� j*j2f��r\� j*�3d�� j_4tj5d� jjd� tj5d� j*j6 � jjd� � j*�7� }t8� j|� jj9�}tj5d | � jjd� t:� j*d |� d | v �rzd | v�rzt;j<| d < � j=� j*�d �\� _>}|du�r�|j?}n� jj@}tA|� jj � jjB�� jjCjDjEd!�� j_ |�(d"�}|du�r�tF� jj |�� j_ � jjG�r2� jjH}|du �rd#}n|d$k�r(d%}n|d%7 }nd%}� jjI}|d$k �rLd%}t�d&� d}tJd%|d% �D �]n}t�d'� �z�z:� jj4�r�tK�KtKjLtM�}tK�N� jj4� � j>jO�d(�}W �n> tPtQf�y } zD|jRW Y d}~W � jj4�r tK�Nd$� tK�KtKjL|�}� j>�S� S d}~0 tT�y~ } zNtdt|�d)�W Y d}~W � jj4�rftK�Nd$� tK�KtKjL|�}� j>�S� S d}~0 tU�y� } z^d*� jj� jj4f }td|d �W Y d}~W � jj4�r�tK�Nd$� tK�KtKjL|�}� j>�S� S d}~0 0 W � jj4�rtK�Nd$� tK�KtKjL|�}� j>�S� n.� jj4�rHtK�Nd$� tK�KtKjL|�}� j>�S� 0 t�d+� tV|�pp|�(d,d��|d,< � jjt jWv�r�tX|�}� jjY�r�tZ� jjY��s�t d-� jjY ��|�� jjY< � jj[d$k�rn� jj\d$k�rf|�(d.��sf|�(d/��sf� j]|��d0�}|�(d/��r>� j^�_d1t`� j ja� jj9|� j�b� d2�� n(� j^�_d3t`� j ja� jj9|� j�b� d2�� ||d,< � ��fd4d5�}� ��fd6d7�}d8|v � rD� jjt jcv� rD� jjt jWv � r� jj�r�� jjd�r�d9�v �r�d9 �'|d8 � n |d8 �d9< n��'|d8 � n<tX|d8 �}te��(d8i �tf|���d8< t j%� rD��'tg|�� d/|v� rxd:|v � rp|d: d;v� rpd|d/< nd|d/< � jjG� r�||d<< d=|v� r�d|d=< � jjt jWv� r�tX|�}� jjY� r�|�� jjY< d.|v� r0d=} z||� d/} ||� W n> t � y. } z$d|d/< t|�|d>| < W Y d}~n d}~0 0 |d%k�rhth� jd?�} � jjG| _i| ����� rf � q�np||k �rhd|d@< ||dA< t�dB||f � � j^�_dCt`� j ja� jj9|� j�b� d2�� tj�k|� � jl� j*�d �� _>�qh|d%k� r�|d% |d<< d|d/< � jjt jWv� rtX|�}� jjY� r&||� jjY< d8|v � r�� jjt jcv� r�� jjt jWv � r`|�'|d8 � n<tX|d8 �}te|�(d8i �tf|��|d8< t j%� r�|�'tg|�� � jjmdu� r�� jjm|dD< � jj� r$dE� jji|d9< | D ]} | �(| �|d9 | < � q�dFD ]0} | |d9 v� r�| | v � r�| �(| �|d9 | < � q�t�dG� |S )Hz� The primary workhorse of the executor system, this runs the task on the specified host (which may be the delegated_to host) and handles the retry/until and block rescue/always execution Nr} )rM r~ r� r� z,when evaluation is False, skipping this taskFTz Conditional result was False)rT rS Z skip_reasonrh �orig_excZ _raw_paramsz,No include file was specified to the includer� )Zinclude� include_args)r� )rT rU rh rj Z_variable_paramsz�Using a variable for a task's 'args' is unsafe in some situations (see https://docs.ansible.com/ansible/devel/reference_appendices/faq.html#argsplat-unsafe)z invalid or malformed argument: '�'Zansible_delegated_vars�ansible_connectionZ connectedZpersistent_command_timeoutz attempting to start connection�rL zusing connection plugin %sz local domain socket path is %sZ _socket_pathZansible_network_osZansible_python_interpreter)r� r� )Z action_groupsZomit� r r6 zstarting attempt loopzrunning the handler�r� )Z unreachablerW zRThe %s action failed to execute in the expected time frame (%d) and was terminatedzhandler run completerh z3Invalid variable name in 'register' specified: '%s'rS rU )�resultr� r� Zv2_runner_on_async_failedr� Zv2_runner_on_async_okc s> � j jd ur:� j jr:t� jd�}� j j|_|����| d< d S )N�rO rT )rB Z changed_whenr rF �when�evaluate_conditional)r� �cond�rK r� Z vars_copyr( r+ � _evaluate_changed_when_result� s z<TaskExecutor._execute.<locals>._evaluate_changed_when_resultc sD � j jr<t� jd�}� j j|_|����}| | d< | d< nd}|S )Nr� �failed_when_resultrU F)rB Z failed_whenr rF r� r� )r� r� r� r� r( r+ � _evaluate_failed_when_result� s z;TaskExecutor._execute.<locals>._evaluate_failed_when_resultZ ansible_factsZ_ansible_delegated_vars�rc)r �0ZattemptsrT z%s_when_resultr� Z_ansible_retry�retriesz Retrying task, attempt %d of %dZv2_runner_retryZ_ansible_notifyZansible_delegated_host)Z ansible_hostZ ansible_portZ ansible_userr� z'attempt loop complete, returning result)nrC r rF r� rD Z set_task_and_variable_overriderB r� � remote_addrrA �addressZ update_varsr rx r� r_ rl r< rJ r8 r Z delegate_tor; r r r� r� r� r� Z_ACTION_ALL_INCLUDE_TASKS�argsrr r� Z_ACTION_INCLUDE_ROLErw ry rz ZINJECT_FACTS_AS_VARSr` r� rq r� rH Z matches_name�_get_connection�_set_become_plugin�_set_connection_options�anyZsupports_persistenceZUSE_PERSISTENT_CONNECTIONSZforce_persistence� get_option�timeout�vvvvZ transportZ get_options�start_connectionrm r� �sys� executable�'_get_action_handler_with_module_contextZ_handlerZ resolved_fqcnZresolved_actionr Zmodule_defaultsr� Z_play�_action_groupsr7 Zuntilr� �delay�range�signal�SIGALRMr5 �alarmr| r r r� �cleanupr r/ �boolZ_ACTION_WITH_CLEAN_FACTSr! �registerr& � async_val�poll�_poll_async_resultrI r� r r� r� Z _ACTION_DEBUGZdelegate_factsr% r" r# r r� r� r� �_get_action_handler�notify) rK r~ Zcontext_validation_errorZtempvarsr{ rx Zraiseitr� r� Z include_fileZvariable_params�cvars�current_connectionZ plugin_vars�options� socket_pathZmodule_contextZmodule_defaults_fqcnr: r� r� r� ZattemptZold_sigrW r� r� �af�condnamer� rc Z requireshedr( r� r+ rt � s � �� � � � � � & ���� & �� zTaskExecutor._executec C sB |du r| j }|�d�}|du r,tddd�S t�tdd|i| jjd��}| jjjd || j | j | j || jd �}| jj }|d k�r�t �| jj� zF|j|d �}t|�d d ��dks�d|v r�|�dd�s�d|v r�W �q�W n� t�y\ } zpt�dt| � � t�dtt�� � � z|j �� W n t�y. Y n0 || jj8 }|d k�rH� W Y d} ~ qtd} ~ 0 0 || jj8 }| j� dt | j j |j ||�!� d�� qtt|�d d ��dk�r�|�d��r�tdd| jj |d�S tdd|d�S nft�|dd�| jjd ��} | jjjd | | j | j | j || jd �} | j|d � | j"dd � |j"dd � |S dS ) z< Polls for the specified JID to be complete NZansible_job_idTz(No job id was returned by the async taskr� � async_status�jid)r� r� � environmentzansible.legacy.async_status)rM r� rN rO r� rP r r� �finishedr6 rU Z_ansible_parsedFrS z-Exception during async poll, retrying... (%s)z Async poll exception was: %sZv2_runner_on_async_pollr� z;async task did not complete within the requested time - %ss)rU rW � async_resultz'async task produced unparseable resultsr� )r� �mode)r� r� )�force)#rC rq r< r �loadrB r� rG � action_loaderrH rD rF r� r� r� r� r| �intrw r_ r� r rl ry rz �resetrv rI r� r rA r� rm r� r� ) rK r� r� r� Z async_jidZ async_taskZ async_handlerZ time_leftr� r{ Z cleanup_taskZcleanup_handlerr( r( r+ r� 8 s� � � �� �� ��� � z TaskExecutor._poll_async_resultc C s t �|�}|std| ��|S )Nz�Invalid become method specified, could not find matching plugin: '%s'. Use `ansible-doc -t become -l` to list available plugins.)r rq r )rK r� r' r( r( r+ � _get_become� s �zTaskExecutor._get_becomec C sj || j _| j j}| jjj|| j | j| jjtt � � �d�\}}|sLt d| ��| � |||� | j � |� |S )z� Reads the connection property for the host, and returns the correct connection object from the list of connection plugins )� task_uuidZansible_playbook_pidz(the connection plugin '%s' was not found)rD r� rG r Zget_with_contextrE rB rm r �os�getppidr r� Zset_attributes_from_plugin)rK r� r� r� Z conn_typer� Zplugin_load_contextr( r( r+ r� � s � z TaskExecutor._get_connectionc C s� |� d�d ur"t|�|d ��}n| jj}|r^|� d�rN| �|�|d ��}qb| �| jj�}nd }z|�|� W n ty� Y n0 |r�t |jdd�r�t |dd�s�t d|j |j f ��| j �|j � d S )NZansible_becomeZansible_become_methodZ require_ttyFZhas_ttyz`The '%s' connection does not provide a TTY which is required for the selected become plugin: %s.)rq r r� rB r' r� Z become_methodZset_become_pluginrv r� r r� r� rD )rK r� r� r� r' Z become_pluginr( r( r+ r� � s( ��z TaskExecutor._set_become_pluginc C s� zt | jd| �}W n ty2 t | j|�}Y n0 |dkr@d}tj�||j�}i }|D ] }||v rX|�|| �||< qX|j||d� |S )Nz_%s� ssh_type_connr� �� task_keysZ var_options) r� rH rv r� r� r� r� r� � set_options) rK r� r~ r� r� Zplugin� option_varsr� rc r( r( r+ �_set_plugin_options� s z TaskExecutor._set_plugin_optionsc C s� g }t j�d| jj�}|�|� di i}|D ] }||v r,|�|| �||< q,t| jdd�r�|D ]4}|�d| jj �r^||vr^|�|| �|d |< q^| j � � }| j j |d< | j j r�| j j |d< |d= | jj||d � |�| �d |||�� | jjd u�rp| j j�r| j j|d < |�| �d |||�� d D ]8}z t| j || jj�|�� W n t�y\ Y n0 �q(| jjj| j _t| jdd �} | d u�r�| �d�dk�r�t| �d��} |�| �| |||�� t| jdd �} | d u�r�|�| �d|||�� |S )Nr� Z_extrasZ allow_extrasFz ansible_%s_r� �passwordr� r� r� � become_passr' )Z become_userZ become_flagsZ become_exer� Z _sub_plugin�typeZexternal�objr� )r� r� r� rH r� �extendr� r� � startswithrB r� rD r� r� r� r� r' r� r� r� �KeyError�promptrq r ) rK r~ r� Zvarnamesr� r� rc r� �option�subr� Zsub_connr( r( r+ r� sH z$TaskExecutor._set_connection_optionsc C s | � ||�d S )zX Returns the correct action plugin to handle the requestion task action r )r� )rK r� r� r( r( r+ r� F s z TaskExecutor._get_action_handlerc C s$ | j j�d�\}}}|�d�d }|r4d�||�}n|}| j j}| jjj| j j|d�} | j rb| j sfd} | durv| j } nn| jj j | j j|d�r�| j j} nNt |tjv | jj j ||d�f�r�|} tjdj| | j jd�| jjd � nd } d}| jj j| | j || j| j|| j|d �} | �s td | ��| | fS ) zo Returns the correct action plugin to handle the requestion task action and the module context �.�_r z{0}.{1})�collection_listNz1Using network group action {handler} for {action})�handlerr� r� zansible.legacy.normal)rM r� rN rO r� rP r z the handler '%s' was not found)rB r� � rpartition�split�format� collectionsrG Z module_loaderZfind_plugin_with_contextZresolvedZ action_pluginr� Z has_plugin�allr� ZNETWORK_GROUP_MODULESr_ r� rD r� rq rF r ) rK r� r� Zmodule_collection� separatorZ module_nameZ module_prefixZnetwork_actionr �moduleZ handler_namer r( r( r+ r� L sJ � ��� z4TaskExecutor._get_action_handler_with_module_context)N)N)r0 r1 r2 �__doc__rQ r| rn rp rt r� r� r� r� r� r� r� r� r( r( r( r+ r. L s$ h8 ) i $Fc C s� t jptj�tjd �g}|�tj� dd�� tj �� |D ]2}tj� |d�}tj� |�r:t�d�|�� qvq:td��tj�� }|�t�� t�� ttj � tj��t�� t�� t �� t �� d�� g }tj r�|� dd tj � tj }t!�"� \} } t#j$||g|�t%t�&� ��t%|��| t#j't#j'|d �} t�(| � t)�*| �} t)�*| �} | d t)j+ @ | d < zHt)�,| t)j-| � t.| |� t.| | �/� � | �0� \}}W t)�,| t)j-| � nt)�,| t)j-| � 0 t�(| � | j1dk�r�t2�3t%|d d ��}nFzt2�3t%|d d ��}W n. t4t2j5dt6��y dt%|d d �i}Y n0 d|v �r�|d D ]p\}}|dk�rVtj|dd� nL|dv �rvt4t|�|| j7d� n,t8t|��r�t4t|�|� ntj|| j7d� �q4d|v �r�tj dk�r�|� d��r�d|d }tj|t j9d� t|d ��|d S )z* Starts the persistent connection r �PATHri zansible-connectionz$Found ansible-connection at path {0}ziUnable to find location of 'ansible-connection'. Please set or check the value of ANSIBLE_CONNECTION_PATH)ZANSIBLE_BECOME_PLUGINSZANSIBLE_CLICONF_PLUGINSZANSIBLE_COLLECTIONS_PATHZANSIBLE_CONNECTION_PLUGINSZANSIBLE_HTTPAPI_PLUGINSZANSIBLE_NETCONF_PLUGINSZANSIBLE_TERMINAL_PLUGINSz-%sr8 )�stdinrk �stderr�envr� r] rZ ZJSONDecodeError�error�messages�logT)Zlog_only)rl r8 ZvvZvvvr� ZvvvvvZvvvvvvr� � rj zThe full traceback is: )Zcolorr� ):r� ZANSIBLE_CONNECTION_PATHr� �path�dirnamer� �argvr� �environrq r �pathsep�join�isfiler_ r� r r r� r� r Z print_pathsr r r Zcollection_pathsr r r r � verbosityr� r� �pty�openpty� subprocess�Popenr r� �PIPEru �termiosZ tcgetattrZICANONZ tcsetattrZTCSANOWr Z serializeZ communicate� returncode�json�loadsr� �decoder� ValueErrorr� �hasattrZ COLOR_ERROR)rN r� r� Zcandidate_pathsr r� r r ZpythonZmasterZslave�p�old�newrk r r� �level�messagerW r( r( r+ r� � sx � � $ r� )PZ __future__r r r r� Z __metaclass__r� r r� r# r� r r� r! ry Zansibler r� Zansible.errorsr r r r r r Z ansible.executor.task_resultr Z ansible.executor.module_commonr Z)ansible.module_utils.parsing.convert_boolr Zansible.module_utils.sixr Zansible.module_utils._textr r Z ansible.module_utils.connectionr Z ansible.playbook.conditionalr Zansible.playbook.taskr Zansible.pluginsr Zansible.plugins.loaderr r r r r r Zansible.templater Z ansible.utils.collection_loaderr r Zansible.utils.listifyr Zansible.utils.unsafe_proxyr r! Zansible.vars.cleanr" r# Zansible.utils.displayr$ Zansible.utils.varsr% r& r_ ZMAGIC_VARIABLE_MAPPINGr= Z RETURN_VARS�__all__� BaseExceptionr/ r5 r7 r. r� r( r( r( r+ �<module> sZ >