관리-도구
편집 파일: __init__.cpython-39.pyc
a �)g�� � @ s( d dl mZmZmZ eZd dlZd dlZd dlZd dl Z d dl Z d dl Z d dl Z d dl Z d dlmZ d dlmZ d dlmZ d dlmZ d dlmZ d dlmZmZmZm Z d d l m Z d d l m Z d d l!m"Z" d d l#m$Z$ d d l%m&Z&m'Z' d dl(m)Z) d dl*m+Z+ d dl,m-Z-m.Z. d dl/m0Z0 d dl1m2Z2 d dl3m4Z4 d dl5m6Z6 d dl7m8Z8 d dl9m:Z; d dl<m=Z= d dl>m?Z? d dl@mAZA d dlBmCZC d dlDmEZEmFZF d d lGmHZHmIZI e?� ZJd gZKeLd �ZMG d d � d �ZNeN� ZOd!d"� ZPd#d$� ZQd%d&� ZRd'd(� ZSG d)d � d �ZTG d*d+� d+eU�ZVG d,d-� d-ejW�ZXdS ).� )�absolute_import�division�print_functionN)�deque)�Lock)�UndefinedError)� constants)�context)� AnsibleError�AnsibleFileNotFound�AnsibleUndefinedVariable�AnsibleParserError)�action_write_locks)�IteratingStates)� WorkerProcess)� TaskResult)� CallbackSend� DisplaySend)� string_types)�to_text)� Connection�ConnectionError)� Conditional)�Handler)�load_list_of_blocks)�Task)� TaskInclude��loader)�Templar)�Display)�add_internal_fqcns)�wrap_var)� combine_vars� isidentifier)�strip_internal_keys�module_response_deepcopy� StrategyBase)Zdiscovered_interpreter_c @ s e Zd ZdS )�StrategySentinelN)�__name__� __module__� __qualname__� r, r, �E/usr/lib/python3.9/site-packages/ansible/plugins/strategy/__init__.pyr( G s r( c C s� d }|j r\|j|d��6 t|jd�}|j |_|�||j�| d< W d � n1 sR0 Y |jr�|j|d��J |d u r�t|jd�}|j|_|�||j�}| | d< | d< W d � n1 s�0 Y d S )N)�available_variablesr �changed�failed_when_result�failed)Z changed_whenZset_temporary_contextr �_loader�when�evaluate_conditionalr. Z failed_when)�result�task�templar� task_varsZcondr0 r, r, r- �post_process_whensN s 0 r9 c C s~ i }|j s|jrz| �dd�}| �d�}|| v r:| | ||< |rR|| v rR| | ||< d| v rf| d |d< d| v rz| d |d< |S )NZansible_loop_var�itemZansible_index_varZ_ansible_item_labelZ ansible_loop)�loop� loop_with�get)r5 r6 � item_varsZloop_varZ index_varr, r, r- �_get_item_vars_ s r? c C s( z�| j �� }t|t�r W �q$n�t|t�r>tj|ji |j�� n�t|t�r�|jD ] }t|t �rN| � |� qlqN| j j |j g|j�R i |j�� n^t|t �r�| � |� | j� | j�|� W d � q�1 s�0 Y nt�dt|�|f � W q ttf�y Y �q$Y q tj�y Y q 0 q d S )Nz7Received an invalid object (%s) in the result queue: %r)�_final_qr= � isinstancer( r �display�args�kwargsr r �normalize_task_result�_tqm� send_callbackZ method_name� _results_lock�_results�append�warning�type�IOError�EOFError�queueZEmpty)�strategyr5 �argr, r, r- �results_thread_maino s* " , rR c s t �� �d� fdd� �}|S )zVClosure to wrap ``StrategyBase._process_pending_results`` and invoke the task debuggerFNc s� d}|j �� }� | |||d�}g }|D �]�}|j} |j} | j�| j| jfd �} | d } | d } z|| j }W n ty� |� | �}Y n0 |j | j d��r�t � }t | | | | ||�}|�� |jt jk�r�| j�� | j�r0|jjtd�v �r0|�� �r0|�� D ]0\}}|| jk�rq�|�||� |jj�|� q�|�| j|� |D ]*\}}t ||�� �rB| jj � || j� �qB| jj � d| j� | � | | | | � |� t!� �| ||�� q&q�|jt j"k�r�|�#|� q&q�|jt j$kr�t%�&d� q�|�#|� q&|S ) N))� is_failed�failures)�is_unreachable�dark)� is_changedr/ )� is_skipped�skipped)�one_pass� max_passesr8 � play_context)Zglobally_enabled)Zlinear�ok�c )'Z host_states�copy�_task�_host�_queued_task_cache�pop�name�_uuid�KeyErrorZget_host_stateZneeds_debugger�debugger_active� NextAction�Debugger�cmdloopr5 �REDOrF Zclear_failed_hosts�run_once�_playrP r! rS �itemsZset_state_for_host�_removed_hosts�remove�getattr�_statsZ decrement� _queue_task�extend� debug_closure�CONTINUErJ �EXIT�sys�exit)�self�iteratorrZ r[ Zstatus_to_stats_mapZprev_host_states�resultsZ_processed_resultsr5 r6 �hostZ_queued_task_argsr8 r\ Zprev_host_state� next_actionZdbg� host_name�state�methodZwhat��funcr, r- �inner� sR $ z debug_closure.<locals>.inner)FN)� functools�wraps)r� r� r, r� r- ru � s =ru c @ s� e Zd ZdZdZdd� Zd0dd�Zdd� Zd1d d �Zd d � Z dd� Z dd� Z dd� Z dd� Z dd� Zdd� Zdd� Zed2d d ��Zd d!� Zd"d#� Zd3d$d%�Zd4d&d'�Zd(d)� Zd*d+� Zd,d-� Zd.d/� Zd S )5r' z� This is the base class for strategy plugins, which contains some common code useful to all strategies like running handlers, cleanup actions, etc. Tc C s� || _ |�� | _|j| _|�� | _|�� | _|j| _t j � dd�| _ t j � dd�| _ i | _t| _d| _d| _t� | _t� | _t�t�� �| _tjt | fd�| _ d| j _ | j � � t� | _ g | _!g | _"t#j$| _%d S )N�stepF�diffr )�targetrC T)&rF Z get_inventory� _inventory�_workersZget_variable_manager�_variable_manager� get_loaderr2 r@ r ZCLIARGSr= �_step�_diffrb rB Z_display�_pending_results� _cur_worker�dict�_blocked_hostsr rI � threading� Conditionr rH �ThreadrR �_results_thread�daemon�start�_active_connections� _hosts_cache�_hosts_cache_all�CZENABLE_TASK_DEBUGGERrg )rz Ztqmr, r, r- �__init__� s, zStrategyBase.__init__c C s~ |st | j| jf�rdS |js4td��|j�r4d}n |jp<d}dd� | jj|dd�D �| _dd� | jj|j|j d�D �| _dS ) z�Responsible for setting _hosts_cache and _hosts_cache_all See comment in ``__init__`` for the purpose of these caches N�allc S s g | ] }|j �qS r, �rd ��.0�hr, r, r- � <listcomp> � z1StrategyBase._set_hosts_cache.<locals>.<listcomp>T)�patternZignore_restrictionsc S s g | ] }|j �qS r, r� r� r, r, r- r� r� )�order) r� r� r� Z finalizedr � is_template�hostsr� � get_hostsr� )rz �play�refreshZ_patternr, r, r- �_set_hosts_cache s z StrategyBase._set_hosts_cachec C sr | j �� D ]L}zt|�}|�� W q tyT } zt�d| � W Y d }~q d }~0 0 q | j�t � | j � � d S )N�4got an error while closing persistent connection: %s) r� �valuesr �resetr rB �debugr@ Zput� _sentinelr� �join)rz ZsockZconn�er, r, r- �cleanup s & zStrategyBase.cleanupr c C s� | j D ]L}|| jjvrz|�| jj| � W q tyP |�| j�|�� Y q0 qt|t �sn|| jj krn|S t | jj� � �dkr�| jj S t |�� �dkr�| jjS | jj S d S )Nr )r� rF �_unreachable_hosts�get_next_task_for_hostr� r� rf �get_hostrA �boolZRUN_OK�len�keysZRUN_UNREACHABLE_HOSTS�get_failed_hostsZRUN_FAILED_HOSTS)rz r{ r\ r5 r} r, r, r- �run! s zStrategyBase.runc s8 | j |dd� t| jj��| jj�� � fdd�| jD �S )NF�r� c s g | ]}|� vr|�qS r, r, �r� r} ��ignorer, r- r� ; r� z4StrategyBase.get_hosts_remaining.<locals>.<listcomp>)r� �setrF � _failed_hosts�unionr� r� �rz r� r, r� r- �get_hosts_remaining8 s z StrategyBase.get_hosts_remainingc s" � j |dd� � fdd�� jD �S )NFr� c s g | ]}|� j jv r|�qS r, )rF r� r� �rz r, r- r� ? r� z1StrategyBase.get_failed_hosts.<locals>.<listcomp>)r� r� r� r, r� r- r� = s z StrategyBase.get_failed_hostsc C s | � |�|d< | �|�|d< dS )z� Base class method to add extra variables/information to the list of task vars sent through the executor engine regarding the task queue manager state. Zansible_current_hostsZansible_failed_hostsN)r� r� )rz �varsr� r, r, r- �add_tqm_variablesA s z StrategyBase.add_tqm_variablesc C sT t �d|j|jf � |jtjvr@t �d|j � t� tj|j< t| j|d�}zt|� |j ��}W n4 t y� } z t d|j |d��W Y d}~n d}~0 0 �zbt| j�}|dkr�| jr�|jr�t �d|�� � n"||kr�t �d |�� |f � |}d } | j} | j|k�r d| _| j| j } | du �s,| �� �s�||||d �| j|j|jf< t| j||||| j| jt�} | | j| j< | j� d ||� | � � t �d | jd t| j�f � d} | jd7 _| j|k�r�d| _| �rq�q�| j| kr�t � d� q�| j d7 _ W n< t!t"t#f�y8 } z t �d| � W Y d}~dS d}~0 0 t �d|j|jf � dS )z5 handles queueing the task up to be sent to a worker z entering _queue_task() for %s/%szCreating lock for %s�r � variablesz3Failed to convert the throttle value to an integer.)�objZorig_excNr z6Ignoring 'throttle' as 'run_once' is also set for '%s'ztask: %s, throttle: %dF)r} r6 r8 r\ Zv2_runner_on_startz"worker is %d (out of %d available)� Tg-C ��6?z got an error while queuing: %sz exiting _queue_task() for %s/%s)$rB r� rd �actionr r r r2 �int�template�throttle� Exceptionr �_dsr� r� �ALLOW_BASE_THROTTLINGrl �get_namer� �is_aliverb re r r@ r� � plugin_loaderrF rG r� �time�sleepr� rN rM �AssertionError) rz r} r6 r8 r\ r7 r� r� Z rewind_pointZqueuedZstarting_workerZ worker_prcr, r, r- rs I s\ & � zStrategyBase._queue_taskc s( |j r � fdd�� jD �}n|jg}|S )Nc s g | ]}|� j jvr|�qS r, )rF r� r� r� r, r- r� � r� z/StrategyBase.get_task_hosts.<locals>.<listcomp>)rl r� rd )rz r{ Z task_hostr6 � host_listr, r� r- �get_task_hosts� s zStrategyBase.get_task_hostsc C s |� di �� dd �}|p |jgS )NZ_ansible_delegated_varsZansible_delegated_host)r= � delegate_to)rz r5 r6 r r, r, r- �get_delegated_hosts� s z StrategyBase.get_delegated_hostsc s� |j du rdS |d }t� ��j}|D ] }tD ]}|�|�r.||� q.q&�r�|j� dt� �fdd�t|�D ��i}| �||�}| j j } |D ]} | | |� q�dS )z�Sets host facts for ``delegate_to`` hosts for facts that should always be delegated This operation mutates ``result`` to remove the always delegated facts See ``ALWAYS_DELEGATE_FACT_PREFIXES`` N� ansible_factsc 3 s" | ]}|�v r|� |�fV qd S �Nr, )r� �k�Z_popZ always_keysr, r- � <genexpr>� r� z;StrategyBase._set_always_delegated_facts.<locals>.<genexpr>) r� r� �add� ALWAYS_DELEGATE_FACT_PREFIXES� startswithrc r� �listr� r� �set_host_facts) rz r5 r6 ZfactsZ_addZfact_keyZ always_keyZ always_factsr� Z_set_host_facts� target_hostr, r� r- �_set_always_delegated_facts� s" � z(StrategyBase._set_always_delegated_factsc C s� t |jt�r | j�t|j��|_t |jt�r�|jj|jf}z| j| d }W n* t yv |j � d�dkrl� t � }Y n0 |j ddd�}|j|_|�|j � ||_|S )aL Normalize a TaskResult to reference actual Host and Task objects when only given the ``Host.name``, or the ``Task._uuid`` Only the ``Host.name`` and ``Task._uuid`` are commonly sent back from the ``TaskExecutor`` or ``WorkerProcess`` due to performance concerns Mutates the original object r6 r� Z async_statusT)�exclude_parentZ exclude_tasks)rA ra r r� r� r r` rd rb rf � _task_fieldsr= r r_ �_parentZ from_attrs)rz � task_resultZqueue_cache_entryZ found_task� original_taskr, r, r- rE � s z"StrategyBase.normalize_task_resultFNc , s� g }t �j�� � ��fdd�}d}zLz�j�� �j�� }W n$ ty` Y W �j�� �q�Y n0 W �j�� n �j�� 0 |j}|j �d} |� � �r d} �j } | �s��� |j �} t�d|j � �jr��j��jj�D ] } | j �jjvr؈�| � q�n ��|� �j|dd�\} }�� |��rB| �rB| jtjk�rBd�jj |j < �� | ��r��jj � d|j � �jj �!|j � �j"�#|j t$t%��&� �|j'd �� n�jj � d |j � nN�jj � d |j � �jj � d |j � d |j'v �r�|j'd �r��jj � d |j � �jj(d|| d� �np|�)� �r��j*}|�sTd�jj|j < �jj �+|j � �jj � d|j � n$�jj � d |j � �jj � d |j � �j�(d|� �n�|�,� �r��jj � d|j � �j�(d|� �n�d} �j-�r�|j'�.dg �}n|j'g}|D �]}d|v �r�|�/� �r�|d D ]�}d}||�jj0�}|du�rBd}|�1|��rB�j�(d||� �jj0D ]x}|j2D ]j}t3|dg ��phg }|�st�qT|�4d|j5�.d�|� �}||v�r��qTnd}|�1|��rT�j�(d||� �qT�qJ|�sd| }t6j7�r�t8|��n t�9|� �qd|v �rF|�.dt$� �}�j�:||� |�.d ��r^|d �j;v�r^�j;�+|d � nd |v �r^�j�<||� d|v �srd |v �r*t=|��}�j>�.|j |j j?f�d }|�r�t@||�} n|} t%|�| �jA< tB|�� | � �j-�s؈jC�r*tD|j|j ||jE�} �j�(d | � |�.d d��rd|j'd < |�.d d��r*d|j'd < d |v �r$�jFt6jGv�r$�jHdu�rd�jI�rd��J|��} n��K|�� ��L�|��} �jFt6jMv �r�|d �N� D ]&\} } | D ]}!�j"�O|!| | � �q��q�nb|�Pd!d�}"| D ]P}!�jFt6jQv }#|#�r�|"�r�j"�R|!|d �S� � |#�r҈j"�#|!|d �S� � �q�d"|v �r�d#|d" v �r�|d" d# �r�d$|d" v�sf|d" d$ �rv��L�|��} ndg} |d" d# }$d%|d" v �o�|d" d% }%| D ]J}&|$�T� D ]:}'|%�rԈjj �U|'|$|' |&� n�jj �V|'|$|' |&� �q��q��q�d&|j'v �r&�jW�st3�d&d��r&�j�(d'|� tX�tY��sn�jj � d |j � d |j'v �rn|j'd �rn�jj � d |j � �j�(d(|� �jA�r�tZ�jA��s�t8d)�jA ����L�|��} t[t\|j'��}(d*|(v �r�|(d*= | D ]}!�j"�#|!�jA|(i� �qΈ j]d+8 _]|j �j^v �r�j^|j = �j_du�r`| �r`�jj`�j_�a� �N� D ]&\})}*|*j?�j_j?k�r8d|*jb|j < �q8|�+|� tX�tc��r��fd,d-��jj0D �D ]}+|+�d|� �q�|�s�|du�r�|d+ |k�r��q�|d+7 }q"|S ).z� Reads results off the final queue and takes appropriate action based on the result (executing callbacks, updating state, etc.). c s� t |�D ]�}|jD ]�}|jrzx|js`� �|j�rZ�jj�j|�j�j d�� _ � � |j�|_d|_|j|j dd�|j dd�f}| |v r�|W S W q t tfy� } z6|js�t�d|jt|�f � W Y d }~qW Y d }~qd }~0 0 qqd S )N)r� r6 �_hosts� _hosts_allTF)Zinclude_role_fqcnz�Handler '%s' is unusable because it has no listen topics and the name could not be templated (host-specific variables are not supported in handler names). The error: %s)�reversed�blockrd Z cached_namer� r� �get_varsrm r� r� r. r� r� r r �listenrB rK r )� handler_nameZhandler_blocksZ handler_blockZ handler_taskZ candidatesr� )�handler_templarr{ rz r, r- � search_handler_blocks_by_name� s6 � � ��zLStrategyBase._process_pending_results.<locals>.search_handler_blocks_by_namer FTzmarking %s as failed)�peekZrescued)Zansible_failed_taskZansible_failed_resultrT r] Zignoredr/ �v2_runner_on_failed)� ignore_errorsrV Zv2_runner_on_unreachablerY �v2_runner_on_skippedr| Z_ansible_notifyNZv2_playbook_on_notifyr� zlThe requested handler '%s' was not found in either the main handlers list nor in the listening handlers listZadd_hostr � add_groupr8 Zv2_runner_item_on_okr1 r� Z_ansible_facts_cacheableZ ansible_stats�dataZper_host� aggregater� Zv2_on_file_diffZv2_runner_on_okz3Invalid variable name in 'register' specified: '%s'Z invocationr� c 3 s* | ]"}|j D ]}|j� jkr |V q qd S r� )r� re )r� �br� )r� r, r- r� r� z8StrategyBase._process_pending_results.<locals>.<genexpr>)er r2 rH �acquirerI �popleft� IndexError�releasera r` rS r� �get_state_for_hostrd rB r� rl r� r� rm r� rF r� Zmark_host_failedr� � run_stater �COMPLETEr� Zis_any_block_rescuingrr � incrementro rp r� Zset_nonpersistent_factsr� r" Z serialize�_resultrG rU �ignore_unreachablerJ rX r; r= rW �handlersZ notify_hostr� rq Zget_validated_valueZ fattributesr� ZERROR_ON_MISSING_HANDLERr rK Zadd_dynamic_hostr� Zadd_dynamic_groupr? rb re r# �registerr9 r< r r� r� Z _ACTION_DEBUGr� Zdelegate_factsr� r� r� Z_ACTION_INCLUDE_VARSrn Zset_host_variablerc Z_ACTION_SET_FACTr� r_ r� Zupdate_custom_statsZset_custom_statsr� rA r r$ r% r& r� r� �_roleZ ROLE_CACHEr� � _had_task_runr � remove_host),rz r{ rZ r[ � ret_resultsr� Zcur_passr� Z original_hostZrole_ranr� Zstate_when_failedr� r� �_r Z result_itemsZ result_itemr� �foundZtarget_handlerZlistening_handler_blockZlistening_handlerZ listeners�msgZ new_host_infor> Zfound_task_varsZ all_task_varsZnew_item_resultr� Zvar_nameZ var_valuer� Z cacheableZ is_set_factr� r� Zmyhostr� Z clean_copy�entryZrole_objZhandlerr, )r� r{ r� rz r- �_process_pending_results� sb ( � �� � � � & " z%StrategyBase._process_pending_resultsc C sl g }t �d� | jdkr^| jjs^| j�� r2td��| �|�}|�|� | jdkrt � t j � qt �d� |S )z� Wait for the shared counter to drop to zero, using a short sleep between checks to ensure we don't spin lock z waiting for pending results...r z"A worker was found in a dead statez/no more pending results, returning what we have) rB r� r� rF Z _terminatedZhas_dead_workersr r rt r� r� r� Z DEFAULT_INTERNAL_POLL_INTERVAL)rz r{ r r| r, r, r- �_wait_on_pending_results s z%StrategyBase._wait_on_pending_resultsc C s. |j jdd�}|j j|_|j|jB }||_|S )zW A proven safe and performant way to create a copy of an included file T)r� )r` r_ r� r� Z_vars)rz � included_file�ti_copyZ temp_varsr, r, r- �_copy_included_file/ s z StrategyBase._copy_included_filec C sj t �d|j � z~| j�|j�}|du r.g W S t|t�s@td��| �|�}t ||j |� � |j j || j| jd�}|jD ]}| jj�d|j� qtW n� ty� � Y n� t�yL } z�t|t�r�dt|j� } nt|�} |jD ]} d| jd< q�|jD ]<}t||j td| d �d �} | jj�d |j� | j� d | � q�t| �|�W Y d}~n d}~0 0 | j� d |� t �d� |S )a4 Loads an included YAML file of tasks, applying the optional set of variables. Raises AnsibleError exception in case of a failure during including a file, in such case the caller is responsible for marking the host(s) as failed using PlayIterator.mark_host_failed(). zloading included file: %sNz0included task files must contain a list of tasks)r� Z parent_blockZroleZ use_handlersr Zvariable_managerr] z8Could not find or access '%s' on the Ansible Controller.Tr1 )r1 �reason)r} r6 Z return_datarT r� Zv2_playbook_on_includez done processing included file) rB r� Z _filenamer2 Zload_from_filerA r� r r r rm Zbuild_parent_blockr` r r� r� rF rr r rd r r r � file_namerI r r r� rG ) rz r r{ Z is_handlerr� r Z block_listr} r� r �r�trr, r, r- �_load_included_file< sF � z StrategyBase._load_included_filec C s� d}d| }|r |d| 7 }|d7 }t �|�}|�� dv rJt �d� d}n,|�� dv rlt �d � d| _d}n t �d � t �|� |S ) NFzPerform task: %s zon %s z(N)o/(y)es/(c)ontinue: )�yZyesz User ran taskT)�c�continuez$User ran task and canceled step modezUser skipped task)rB �prompt�lowerr� r� Zbanner)rz r6 r} �retr Zrespr, r, r- � _take_stepr s zStrategyBase._take_stepc C s t �d| � d S )Nz)%s task does not support when conditional)rB rK )rz Z task_namer, r, r- �_cond_not_supported_warn� s z%StrategyBase._cond_not_supported_warnc s �j �d�}� ��fdd�}d}|}d| } t�t�rF�j�d�� n�jjd�dd� |d v rp�jrp��|� |d kr�d }�n�|d kr�||�rڈ �|j �} | j t j kr�t d ��|j �jjvr�| j | _t j | _ d |j }nd}| d|j 7 } �n�|dk�r�j�� ��� j� d}�n^|dk�rt||��r^�j�� jj�D ]} | �� } �j�| � �q<d}nd}| d|j 7 } �n|dk�r�||��rԈj�� jj�D ]4} �jj�| j d� �jj�| j d� � �| � �q�d}nd}| d|j 7 } �n�|dk�rL||��r<�j�� jj�D ]&} | j �jjv�r� � | j t j � �qd}n d}| d7 } �n*|dk�r�||��r��j�� jj�D ],} | j �jjv�rp� � | j t j � d� _ �qpd }n d}| d 7 } �n�|d k�r||��r� � |j t j � � jj � |j � d |j }n d}| d |j 7 } d!|j }�nb|d"k�rR�j!�rv|j �j"j#v �rvd�j"j$|j < d#|j }�n$|d$k�rd�jj%� j|��j&�j'd%�} t(�j)| d&�}|j*�| |d'�}|j+|d(� |j,�s�|j-|_,|�.| � |�j/v �r�t0�j/| �}�j/|= n0t1j2�|j3|t4j5�}|j6��7� | d)� |�8|� |�r^z|�9� d*}W n4 t:�yZ } zt;�<d+| � W Y d }~n d }~0 0 nd,}nt d-| �j=d.��d/|i}|�r�d|d0< | |d1< nd|d2< �j!�s�|�r�| n|}t;�>d3|� �� t�t��rڈ�?|� t@|�|�}|�r��j�d4|� |gS )5NZ _raw_paramsc s6 �j j� j| ��j�jd�}t�j|d�}��||�S )N�r� r} r6 r� r� r� )r� r� rm r� r� r r2 r4 )r� �all_varsr7 �r{ rz r6 r, r- �_evaluate_conditional� s �z9StrategyBase._execute_meta.<locals>._evaluate_conditionalFz!%s conditional evaluated to FalseZ!v2_playbook_on_handler_task_startZv2_playbook_on_task_start)Zis_conditional)�noop�refresh_inventory�reset_connectionr+ Zflush_handlersz*flush_handlers cannot be used as a handlerz!triggered running handlers for %sTz , not running handlers for %sr, z inventory successfully refreshed� clear_factsz facts clearedz*, not clearing facts and fact cache for %s�clear_host_errorszcleared host errorsz&, not clearing host error state for %sZ end_batchz ending batchz, continuing current batch�end_playz ending playz, continuing playZend_hostzending play for %sz , continuing execution for %szDend_host conditional evaluated to false, continuing execution for %sZ role_completezrole_complete for %sr- r' r� )r6 r� r7 )r7 )Z task_keysZ var_optionszreset connectionr� z no connection, nothing to resetz!invalid meta action requested: %s)r� r rY � skip_reasonr/ zMETA: r� )ArC r= rA r rF rG r3 r& r rd r r ZHANDLERSr r� Zpre_flushing_run_stater� r, r� rm r� r� r� r� r. r� rc r/ Zset_run_state_for_hostr r0 ro rJ Zimplicitr r Z _completedr� r� r� r r2 Z set_task_and_variable_override� post_validateZ remote_addr�addressZ update_varsr� r r� Zconnection_loader� connection�os�devnullZ set_optionsZ dump_attrsZset_attributes_from_pluginr� r rB r� r� Zvvr r )rz r6 r\ r{ r� Z meta_actionr* rY r r1 Z host_stater} �hostnamer( r7 r4 r� r5 �header�resr, r) r- � _execute_meta� s� � & zStrategyBase._execute_metac C s\ g }| j D ]L}|| jjvr z|�| jj| � W q tyT |�| j�|�� Y q 0 q |S )zQ returns list of available hosts for this iterator by filtering out unreachables )r� rF r� rJ r� r� rf r� )rz r{ Z hosts_leftr} r, r, r- �get_hosts_left. s zStrategyBase.get_hosts_leftc C sD |D ]:}d|j v r|j d �d�}|r|j| jvr|| j|j< qdS )z3 updates the current active persistent connections rC Z_ansible_socketN)r� r= ra r� )rz r| r Z socket_pathr, r, r- �update_active_connections: s z&StrategyBase.update_active_connections)T)r )FN)F)N)r) r* r+ �__doc__r� r� r� r� r� r� r� r� rs r� r� r� rE ru r r r r r% r& r: r; r< r, r, r, r- r' � s6 . S " 4 6 # c @ s( e Zd ZdZdZdZdZefdd�ZdS )rh z. The next action after an interpreter's exit. r� � � c C s || _ d S r� )r5 )rz r5 r, r, r- r� J s zNextAction.__init__N)r) r* r+ r= rk rv rw r� r, r, r, r- rh D s rh c @ s� e Zd ZdZdd� Zdd� ZejjZ dd� Z dd � Z e Z d d � Z e Zd d � ZeZdd� ZeZdd� Zdd� ZeZdd� Zdd� ZdS )ri z> c C sb t j�| � d||f | _d | _i | _|| jd< || jd< || jd< || jd< || jd< || _d S )Nz[%s] %s (debug)> r6 r8 r} r\ r5 )�cmd�Cmdr� r" Zintro�scoper~ )rz r6 r} r8 r\ r5 r~ r, r, r- r� Q s zDebugger.__init__c C s( zt j�| � W n ty" Y n0 d S r� )r@ rA rj �KeyboardInterruptr� r, r, r- rj _ s zDebugger.cmdloopc C s | � |�S )�Quit)�do_quit�rz rC r, r, r- �do_EOFg s zDebugger.do_EOFc C s t � d� tj| j_dS )rD zUser interrupted executionT)rB rh rw r~ r5 rF r, r, r- rE k s zDebugger.do_quitc C s t j| j_dS )zContinue to next resultT)rh rv r~ r5 rF r, r, r- � do_continues s zDebugger.do_continuec C s t j| j_dS )zKSchedule task for re-execution. The re-execution may not be the next resultT)rh rk r~ r5 rF r, r, r- �do_redoz s zDebugger.do_redoc C s@ t d| jd d�}| jd }|�|j�}|�|� || jd< dS )zLRecreate the task from ``task._ds``, and template with updated ``task_vars``Nr8 )r� r6 )r rB Z load_datar� r2 )rz rC r7 r6 r, r, r- �do_update_task� s zDebugger.do_update_taskc C sl zt |t� | j�W S tyf t�� d d� \}}t|t�rD|}n|j}t � d|t |�f � � Y n0 d S )Nr> �***%s:%s) �eval�globalsrB r� rx �exc_inforA �strr) rB �repr)rz rC �t�v� exc_type_namer, r, r- �evaluate� s zDebugger.evaluatec C s6 z | � |�}t�t�|�� W n ty0 Y n0 dS )z Pretty PrintN)rT rB �pprintZpformatr� )rz rC r5 r, r, r- � do_pprint� s zDebugger.do_pprintc C s~ z$t |d dd�}t|t� | j� W nT tyx t�� d d� \}}t|t�rV|}n|j }t � d|t |�f � � Y n0 d S )N� z<stdin>Zsingler> rK ) �compile�execrM rB r� rx rN rA rO r) rB rP )rz rC �coderQ rR rS r, r, r- �execute� s zDebugger.executec C s& z| � |� W n ty Y n0 d S r� )r[ r� )rz �liner, r, r- �default� s zDebugger.defaultN)r) r* r+ Zprompt_continuousr� rj r@ rA Zdo_helpZdo_hrG rE Zdo_qrH Zdo_crI Zdo_rrJ Zdo_urT rV Zdo_pr[ r] r, r, r, r- ri N s$ ri )YZ __future__r r r rL Z __metaclass__r@ r� r5 rU rO rx r� r� � collectionsr Zmultiprocessingr Zjinja2.exceptionsr Zansibler r� r Zansible.errorsr r r r Zansible.executorr Z ansible.executor.play_iteratorr Z ansible.executor.process.workerr Z ansible.executor.task_resultr Z#ansible.executor.task_queue_managerr r Zansible.module_utils.sixr Zansible.module_utils._textr Z ansible.module_utils.connectionr r Z ansible.playbook.conditionalr Zansible.playbook.handlerr Zansible.playbook.helpersr Zansible.playbook.taskr Z ansible.playbook.task_includer Zansible.pluginsr r� Zansible.templater Zansible.utils.displayr Zansible.utils.fqcnr! Zansible.utils.unsafe_proxyr" Zansible.utils.varsr# r$ Zansible.vars.cleanr% r& rB �__all__� frozensetr� r( r� r9 r? rR ru r' �objectrh rA ri r, r, r, r- �<module> sj C ~