관리-도구
편집 파일: 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