File: //usr/lib/python3.9/site-packages/ansible/plugins/strategy/__pycache__/linear.cpython-39.pyc
a
�)g�O � @ s� d dl mZmZmZ eZdZd dlmZ d dl
m Z m Z m
Z
d dlmZmZ d dlmZ d dlmZ d dlmZ d d lmZ d d
lmZ d d lm Z d d l m Z d d
l m Z e � Z!G dd� de �Z"dS )� )�absolute_import�division�print_functiona
name: linear
short_description: Executes tasks in a linear fashion
description:
- Task execution is in lockstep per host batch as defined by C(serial) (default all).
Up to the fork limit of hosts will execute each task at the same time and then
the next series of hosts until the batch is done, before going on to the next task.
version_added: "2.0"
notes:
- This was the default Ansible behaviour before 'strategy plugins' were introduced in 2.0.
author: Ansible Core Team
)� constants)� AnsibleError�AnsibleAssertionError�AnsibleParserError)�IteratingStates� FailedStates)�to_text)�Handler)� IncludedFile)�Task)�
action_loader)� StrategyBase)�Templar)�Displayc s0 e Zd Z� fdd�Zdd� Z� fdd�Z� ZS )�StrategyModulec s t � j|i |�� d| _d S )NF)�super�__init__� _in_handlers)�self�args�kwargs�� __class__� �C/usr/lib/python3.9/site-packages/ansible/plugins/strategy/linear.pyr 3 s zStrategyModule.__init__c
C s� t � }d|_d|jd< d|_|�|jj� i }|D ]*}|j|dd�\}}|dur2||f||< q2|spdd� |D �S | jr�t t
d d
� d d � |� � D ���s�d
| _| jr�t dd � |� � D ��}nzdd� |� � D �} d}
|
dk�r,z|j
|j } W n" t�y d|_|
d7 }
Y q�0 | jd7 _| j| v rАq4q�td��g } |�� D ]d\}\}}| j�r`||jk�sv| j�s�| j|jk�r�|�|j|� | �||f� n| �||f� �q@| j�s�| jtjv �r�| j�d�dk�r�d| _| S )z�
Returns a list of (host, task) tuples, where the task may
be a noop task to keep the iterator in lock step across
all hosts.
�meta�noop� _raw_paramsT��peekNc S s g | ] }|d f�qS �Nr )�.0�hr r r �
<listcomp>L � z:StrategyModule._get_next_task_lockstep.<locals>.<listcomp>c S s
| t jkS r# )r �HANDLERS)Zrsr r r �<lambda>O r' z8StrategyModule._get_next_task_lockstep.<locals>.<lambda>c s s | ]\}}|j V qd S r# )� run_state)r$ �s�_r r r � <genexpr>P r' z9StrategyModule._get_next_task_lockstep.<locals>.<genexpr>Fc s s$ | ] \}}|j tjkr|jV qd S r# )r* r r( �cur_handlers_task�r$ r+ �tr r r r- U s �c S s g | ]\}}|j �qS r )�_uuidr/ r r r r& Z r' r � zOBUG: There seems to be a mismatch between tasks in PlayIterator and HostStates.�flush_handlers)r �actionr Zimplicit�
set_loader�_play�_loader�get_next_task_for_hostr �any�filter�values�min� all_tasks�cur_task�
IndexErrorr1 r �itemsr. Zset_state_for_host�name�append�C� _ACTION_META�get)
r �hosts�iteratorZ noop_taskZstate_task_per_host�host�state�taskZlowest_cur_handlerZ
task_uuidsZ _loop_cntr> �
host_tasksr r r �_get_next_task_lockstep9 sd
��
��
��z&StrategyModule._get_next_task_lockstepc ( s� | j j}d}| �|j� |�rz| j j�sz�z t�d� | �|�}t�d� d}d}| �||�}d}d} d}
g } |D �]�\} }
|
s�qr| j jr� �q4d}d}t |
t
�s�|
j r�|
j � | �r�|
j j
du s�|
j j
r�|
j j
js�t�d|
� qrt�d� | jj|j| |
| j| jd�}| j||jd � t| j|d
�}t�d � |�|
j�}ztj|d|
jd �}W n t�yj d}Y n0 |t j v �r�| � | � |
||| �� |
j �d
d�dv�r�d}|
j!�s�|�r�|
j"�s�d}
�n8| j#�r�| �r�| �$|
��r�d} n
d} �q4|�|
j%��p |�o t&|dd�}|
j!�s |�r(|
j"�s(d}
|�s�t�d� |
j'}t�d� z(t(|j|
j'dd�dd�|
_'t�d� W n t)�y� t�d� Y n0 t�d� t |
t
��r�| j �*d|
� n| j j*d|
dd� ||
_'d}t�d� d| j+| �,� < | �-| |
||� ~|�r �q4| � | j.|t/d t0t1| j j2�d ��d �� qr|�r>W qt�d � | j3d k�rd| � | �4|�� | �5| � t6j7| || j| jd!�}t1|�d k�rt�d"� t�d#� t8d$d%� |D ��}t�d&� g }t9� }|D �]�}t�d'|j: � d}�z |j;�r | �<|�}|j=|j| j| jd(�\}} n t |j>t
�}| j?|||d)�}d*d+� |jj@D �|_@t�d,� |D ]�} |�r�| jAD ]}
|jBdd� |
_C�qj| } nJ| jj|j| �D� | j| jd-�}t�d.� | �E|�} t�d/� |� | �F� � |D ] } | |jBv �r�|| �G| � �qqZt�d0� W n� tH�y � Y nr tI�y� } zX|j;�rHtjJt(| �dd1� |jKD ] } d| jLd2< |�M| jN� �qNW Y d} ~ �q�W Y d} ~ n
d} ~ 0 0 �q�|D ] } d| j jO| j'< |�P| � �q�t�d3� |D ]} |�Q| || � �q�||jR|jS|jS�< t�d4� t�d5� t�d6� t�d7� g }!g }"| D ]V}#|#�T� �sB|#j>jt j v �r`|�T|#jN��r`|!�G|#jNj'� n|#�U� �r$|"�G|#jNj'� �q$|
�r t1|!�d k�s�t1|"�d k�r tVtWjXtWjYg�}$|D ]h} |jZ| dd8�\}%}&|�[|%�}%|%j\|$v�s�|%j\tWjXk�r�|%j]t^jX@ d k�r�d| j jO| j'< || j j_O }�q�t�d9� t�d:� |jj`du�r�t1| �d k�r�|jj`d; }'t1| j jO�|ja |'k�r�|D ]*} | j'|!v�rtd| j jO| j'< |�P| � �qt| j �*d<� || j j_O }t�d=t1| j jO�|ja|'f � t�d>� t�d?� || j jk�r*t1| j jO�t1|�k�r*t�d@� | j �*d<� |W S t�dA� W q tbtcf�yv } z"t�dB| � | j jdW Y d} ~ S d} ~ 0 0 qtetf| ��g|||�S )Cz�
The linear strategy is simple - get the next task and queue
it for all hosts, then wait for the queue to drain before
moving on to the next task
Tz)getting the remaining hosts for this loopz.done getting the remaining hosts for this loopFNz)'%s' skipped because role has already runzgetting variables)�playrH rJ �_hosts�
_hosts_all)rM )�loaderZ variableszdone getting variables)Z
class_onlyZcollection_listr )r Zreset_connectionZend_hostZ
role_completer3 ZBYPASS_HOST_LOOPzOsending task start callback, copying the task so we can template it temporarilyz#done copying, going to template now)Zfail_on_undefined�empty)Z nonstringzdone templatingz!templating failed for some reasonzhere goes the callback...Z!v2_playbook_on_handler_task_startZv2_playbook_on_task_start)Zis_conditionalzsending task start callbackr2 g�������?)Z
max_passesz>done queuing things up, now waiting for results queue to drainr )rG rP �variable_managerz!we have included files to processzgenerating all_blocks datac s s | ]}|g fV qd S r# r )r$ rH r r r r- r' z%StrategyModule.run.<locals>.<genexpr>z done generating all_blocks dataz processing included file: %s)rM rR rP )rG �
is_handlerc S s g | ]}|j D ]}|�qqS r )�block)r$ �br% r r r r& ' r' z&StrategyModule.run.<locals>.<listcomp>z2iterating over new_blocks loaded from include file)rM rJ rN rO zfiltering new block on tagsz done filtering new block on tagsz7done iterating over new_blocks loaded from include file)Z wrap_textZfailedz7extending task lists for all hosts with included blockszdone extending task listsz done processing included fileszresults queue emptyz checking for any_errors_fatalr! z"done checking for any_errors_fatalz checking for max_fail_percentageg Y@Z!v2_playbook_on_no_hosts_remainingz$(%s failed / %s total )> %s max failz%done checking for max_fail_percentagezIchecking to see if all hosts have failed and the running result is not okz!^ not ok, so returning result nowz-done checking to see if all hosts have failedz%got IOError/EOFError in task loop: %s)hZ_tqmZRUN_OKZ_set_hosts_cacher6 Z _terminated�display�debugZget_hosts_leftrL �
isinstancer Z_roleZhas_runZ _metadataZallow_duplicatesZ_variable_managerZget_varsZ _hosts_cacheZ_hosts_cache_allZadd_tqm_variablesr r7 �templater4 r rE � collections�KeyErrorrC rD �extendZ
_execute_metar �any_errors_fatal�
ignore_errorsZ_stepZ
_take_step�run_once�getattrrA r � ExceptionZ
send_callbackZ_blocked_hostsZget_nameZ _queue_taskZ_process_pending_results�max�int�lenZ_workersZ_pending_resultsZ_wait_on_pending_resultsZupdate_active_connectionsr
Zprocess_include_results�dict�setZ _filenameZ_is_roleZ_copy_included_fileZget_block_listZ_taskZ_load_included_file�handlersrT rN Znotified_hostsZget_first_parent_includeZfilter_tagged_tasksZ get_tasksrB r r �errorZ_resultsZ_result�addZ_hostZ
_failed_hostsZmark_host_failedZ add_tasksr= r> Z is_failedZis_unreachable� frozensetr ZRESCUEZALWAYSr8 Zget_active_stater* Z
fail_stater
ZRUN_FAILED_BREAK_PLAYZmax_fail_percentageZ
batch_size�IOError�EOFErrorZRUN_UNKNOWN_ERRORr r �run)(r rG Z play_context�resultZ
work_to_doZ
hosts_leftZ
callback_sentrK Z skip_restZ choose_stepr] �resultsrH rJ r_ Z task_varsZtemplarZ task_actionr4 Z
saved_nameZincluded_filesZ
all_blocksZincluded_tasksZfailed_includes_hostsZ
included_filerS Znew_irZ
new_blocksZhandler_blocksZ new_blockZ final_block�e�rZ failed_hostsZunreachable_hosts�resZdont_fail_statesr+ r, Z
percentager r r rm sz
�
,
�
�
�
(
(
"
��
$
zStrategyModule.run)�__name__�
__module__� __qualname__r rL rm �
__classcell__r r r r r 1 s Fr N)#Z
__future__r r r �typeZ
__metaclass__Z
DOCUMENTATIONZansibler rC Zansible.errorsr r r Z ansible.executor.play_iteratorr r
Zansible.module_utils._textr Zansible.playbook.handlerr Z ansible.playbook.included_filer
Zansible.playbook.taskr Zansible.plugins.loaderr Zansible.plugins.strategyr Zansible.templater Zansible.utils.displayr rV r r r r r �<module> s