File: //lib/python3.9/site-packages/ansible/plugins/strategy/__pycache__/free.cpython-39.pyc
a
�)gX> � @ s� d dl mZmZmZ eZdZd dlZd dlm Z
d dl m Z m
Z
d dlmZ d dlmZ d dlmZ d d lmZ d d
lmZ d d lmZ d d lmZ e� Z G d
d� de�Z dS )� )�absolute_import�division�print_functiona�
name: free
short_description: Executes tasks without waiting for all hosts
description:
- Task execution is as fast as possible per batch as defined by C(serial) (default all).
Ansible will not wait for other hosts to finish the current task before queuing more tasks for other hosts.
All hosts are still attempted for the current task, but it prevents blocking new tasks for hosts that have already finished.
- With the free strategy, unlike the default linear strategy, a host that is slow or stuck on a specific task
won't hold up the rest of the hosts and tasks.
version_added: "2.0"
author: Ansible Core Team
N)� constants)� AnsibleError�AnsibleParserError)�Handler)� IncludedFile)�
action_loader)� StrategyBase)�Templar)�to_text)�Displayc s, e Zd ZdZ� fdd�Z� fdd�Z� ZS )�StrategyModuleFc s t t| ��|� d| _d S )NF)�superr �__init__� _host_pinned)�selfZtqm�� __class__� �A/usr/lib/python3.9/site-packages/ansible/plugins/strategy/free.pyr 6 s zStrategyModule.__init__c " s d}| j j}t| j�}| �|j� |jjdur8t�d� d}|�r�| j j �s�| �
|�}t|�dkrv| j � d� d}�q�d}|}g } || }
t� d|
� |
�
� } |j|
dd�\} }
tj d | | d
� tj d |
| d
� |
s�| j�| d��r| j j�| d��stj d | d
� d}| j j�| d��sB|
�rB| j�| d��s4tj d
| d
� | jj|j|
|
| j| jd�}| j||jd� t| j|d�}tj d| d
� zt|�|
j��}W n6 t �y� } z t d|
j |d��W Y d}~n
d}~0 0 |dk�r@d}| jD ].}|�r�|� � �r�|j j!|
j!k�r�|d7 }�q�t� d|
�
� |f � ||k�r@�q�d| j| < |�"|
j#| � zt$j|
j%d|
j&d�}W n t'�y� d}Y n0 z,t(|j|
j#dd�dd�|
_#tj d| d
� W n" t �y� tj d| d
� Y n0 |�|
j)��p�|�o�t*|d d�}|�r4|�r*t*|d d��r*t d |
j% |
j d ��n
t�d � t+|
t,��s�|
j-�r�|
j-�.|
��r�|
j-j/du �sz|
j-j/�r�|
j-j/j0�s�tj d |
| d
� | j| = q�|
j%t1j2v �r�| j3|
|||
d!� d| j| < np| j4�r�| �5|
| ��rB|
j6�r�t�d"� t+|
t,��r| j � d#|
� n| j j d$|
dd%� | �7|
|
||� |d8 }~nt� d&| � | j8�rb|dk�rb|�rb|}�q�|d7 }|t|�d k�r�d}||kr��q�q�| �9|�}| �:|� |t|�7 }| �;|� t<j=| || j| jd'�}t|�dk�r�t>d(d)� |D ��}t?� }|D �]�}t� d*| � d}zb|j@�r@| �A|�} | jB|j| j| jd+�\} } n t+|j t,�}| jC|||d,�} d-d.� |jjDD �|_DW n� tE�y� � Y nr t �y� } zX|j@�r�tjFt(|�dd/� |jGD ] } d| jHd0< |�I| jJ� �q�W Y d}~�q�W Y d}~n
d}~0 0 | D ]~} |�r,| jKD ]}
|jLdd� |
_M�q| }!n(| jj|j| �N� | j| jd1�}| �O|�}!|D ] }
|
|jLv �rX||
�P|!� �qX�q�t� d2| � �q�|D ] }
d| j jQ|
j#< |�R|
� �q�t� d3t|� � |D ]}
|�S|
||
� �q�t� d4� tT�Ut1jV� q<| �W|�}tXtY| ��Z|||�S )5am
The "free" strategy is a bit more complex, in that it allows tasks to
be sent to hosts as quickly as they can be processed. This means that
some hosts may finish very quickly if run tasks result in little or no
work being done versus other systems.
The algorithm used here also tries to be more "fair" when iterating
through hosts by remembering the last host in the list to be given a task
and starting the search from there as opposed to the top of the hosts
list again, which would end up favoring hosts near the beginning of the
list.
r NzsUsing max_fail_percentage with the free strategy is not supported, as tasks are executed independently on each hostTZ!v2_playbook_on_no_hosts_remainingFznext free host: %s)�peekzfree host state: %s)�hostzfree host task: %szthis host has work to dozgetting variables)�playr �task�_hosts�
_hosts_all)r )�loaderZ variableszdone getting variablesz3Failed to convert the throttle value to an integer.)�objZorig_exc� ztask: %s, same_tasks: %d)Z
class_onlyZcollection_list)Zfail_on_undefined�empty)Z nonstringzdone templatingz!templating failed for some reasonZBYPASS_HOST_LOOPz�The '%s' module bypasses the host loop, which is currently not supported in the free strategy and would instead execute for every host in the inventory list.)r z�Using run_once with the free strategy is not currently supported. This task will still be executed for every host in the inventory list.z)'%s' skipped because role has already run)Z target_hostzpUsing any_errors_fatal with the free strategy is not supported, as tasks are executed independently on each hostZ!v2_playbook_on_handler_task_startZv2_playbook_on_task_start)Zis_conditionalz %s is blocked, skipping for now)�iteratorr �variable_managerc s s | ]}|g fV qd S )Nr )�.0r r r r � <genexpr>� � z%StrategyModule.run.<locals>.<genexpr>z collecting new blocks for %s)r r# r )r" �
is_handlerc S s g | ]}|j D ]}|�qqS r )�block)r$ �b�hr r r �
<listcomp> r& z&StrategyModule.run.<locals>.<listcomp>)Z wrap_textZfailed)r r r r z!done collecting new blocks for %sz@adding all collected blocks from %d included file(s) to iteratorz(done adding collected blocks to iterator)[Z_tqmZRUN_OK�lenZ_workersZ_set_hosts_cacheZ_playZmax_fail_percentage�displayZwarningZ _terminatedZget_hosts_leftZ
send_callback�debugZget_nameZget_next_task_for_hostZ_blocked_hosts�getZ_unreachable_hostsZ_variable_managerZget_varsZ _hosts_cacheZ_hosts_cache_allZadd_tqm_variablesr Z_loader�int�template�throttle� Exceptionr Z_ds�is_aliveZ_taskZ_uuidZset_state_for_host�namer
�action� collections�KeyErrorr
�run_once�getattr�
isinstancer Z_roleZhas_runZ _metadataZallow_duplicates�CZ _ACTION_METAZ
_execute_metaZ_stepZ
_take_stepZany_errors_fatalZ _queue_taskr Z_process_pending_results�extendZupdate_active_connectionsr Zprocess_include_results�dict�setZ_is_roleZ_copy_included_fileZget_block_listZ_load_included_file�handlersr �errorZ_resultsZ_result�addZ_hostr( r Znotified_hostsZget_first_parent_includeZfilter_tagged_tasks�appendZ
_failed_hostsZmark_host_failedZ add_tasks�time�sleepZ DEFAULT_INTERNAL_POLL_INTERVALZ_wait_on_pending_resultsr r �run)"r r" Z play_contextZ last_host�resultZ workers_freeZ
work_to_doZ
hosts_leftZ
starting_hostZ host_resultsr Z host_name�stater Z task_varsZtemplarr2 �eZ
same_tasksZworkerr6 r9 �resultsZincluded_filesZ
all_blocksZfailed_includes_hostsZ
included_filer' Znew_irZ
new_blocksZhandler_blocks�rZ new_blockZ final_blockr r r rF : s6
&�&
��
"$
�
�
$
�
zStrategyModule.run)�__name__�
__module__� __qualname__ZALLOW_BASE_THROTTLINGr rF �
__classcell__r r r r r 1 s r ) Z
__future__r r r �typeZ
__metaclass__Z
DOCUMENTATIONrD Zansibler r< Zansible.errorsr r Zansible.playbook.handlerr Z ansible.playbook.included_filer Zansible.plugins.loaderr
Zansible.plugins.strategyr Zansible.templater Zansible.module_utils._textr
Zansible.utils.displayr r- r r r r r �<module> s