| Server IP : 85.193.89.191 / Your IP : 3.144.34.110 Web Server : Apache System : Linux 956367-cx40159.tmweb.ru 3.10.0-1160.105.1.el7.x86_64 #1 SMP Thu Dec 7 15:39:45 UTC 2023 x86_64 User : bitrix ( 600) PHP Version : 8.1.27 Disable Function : NONE MySQL : OFF | cURL : OFF | WGET : ON | Perl : ON | Python : ON | Sudo : ON | Pkexec : ON Directory : /lib/python2.7/site-packages/ansible/plugins/strategy/ |
Upload File : |
�
� �\c @` s) d d l m Z m Z m Z e Z d 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 d l m Z d d l m Z d d
l m Z d d l m Z d d l m Z y d d
l m Z Wn* e k
rd d l m Z e � Z n Xd e f d � � YZ! d S( i ( t absolute_importt divisiont print_functions
strategy: 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
( t AnsibleErrort AnsibleAssertionError( t PlayIterator( t iteritems( t to_text( t Block( t IncludedFile( t Task( t
action_loader( t StrategyBase( t Templar( t display( t Displayt StrategyModulec B` s; e Z d Z d � Z d � Z d � Z d � Z d � Z RS( c C` s� | j d k r t d � � n g } x^ | D]V } t | t � rS | j | j � q+ t | t � r+ | j | j | | j � � q+ q+ W| S( Ns= strategy.linear.StrategyModule.noop_task is None, need Task()( t noop_taskt NoneR t
isinstanceR
t appendR t _create_noop_block_fromt _parent( t selft targett resultt el( ( sC /usr/lib/python2.7/site-packages/ansible/plugins/strategy/linear.pyt _replace_with_noop9 s
#c C` sR t d | � } | j | j � | _ | j | j � | _ | j | j � | _ | S( Nt parent_block( R R t blockt alwayst rescue( R t original_blockt parentt
noop_block( ( sC /usr/lib/python2.7/site-packages/ansible/plugins/strategy/linear.pyR E s
c C` sN t � | _ d | j _ d | j j d <| j j | j j � | j | | � S( Nt metat noopt _raw_params( R
R t actiont argst
set_loadert _playt _loaderR ( R R R! t iterator( ( sC /usr/lib/python2.7/site-packages/ansible/plugins/strategy/linear.pyt# _prepare_and_create_noop_block_fromM s
c ` s� t � � d � _ d � j d <� j � j j � i � t j d � x* | D]" } � j | d t �� | j
<qL Wt j d � d } d } d } d } t j d � g t � � D]( \ } } | r� | d r� | | f ^ q� } | r"y t � f d
� | D� � }
Wq(t
k
r d }
q(Xn d }
x� | D]� \ } } | \ }
} � j |
� }
|
j |
k rkq/n |
j t j k r�| d 7} q/|
j t j k r�| d 7} q/|
j t j k r�| d 7} q/|
j t j k r/| d 7} q/q/Wt j d | | | | f � � � � f d � } | rCt j d
� | | |
t j � S| rit j d � | | |
t j � S| r�t j d � | | |
t j � S| r�t j d � | | |
t j � St j d � g | D] } | d f ^ q�S( s�
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.
R# R$ R% s% building list of next tasks for hostst peeks done building task listsi s) counting tasks in each state of executioni c 3` s? | ]5 \ } \ } } | j t j k r � j | � j Vq d S( N( t run_stateR t ITERATING_COMPLETEt get_active_statet cur_block( t .0t ht st t( R+ ( sC /usr/lib/python2.7/site-packages/ansible/plugins/strategy/linear.pys <genexpr>t s sn done counting tasks in each state of execution:
num_setups: %s
num_tasks: %s
num_rescue: %s
num_always: %sc ` s� g } t j d � x� | D]� } � j | j � } | d k rD q n | \ } } � j | � } | d k rq q n | j | k r� | j | k r� � j | � } | j | | f � q | j | � f � q Wt j d � | S( s
This helper returns the task for all hosts in the requested
state, otherwise they get a noop dummy task. This also advances
the state of the host, since the given states are determined
while using peek=True.
s starting to advance hostss! done advancing hosts to next taskN(
R t debugt gett nameR R0 R. R1 t get_next_task_for_hostR ( t hostsR1 t cur_statet rvalst hostt host_state_taskR4 R5 t new_t( t
host_tasksR+ R ( sC /usr/lib/python2.7/site-packages/ansible/plugins/strategy/linear.pyt _advance_selected_hosts� s
s" advancing hosts in ITERATING_SETUPs" advancing hosts in ITERATING_TASKSs# advancing hosts in ITERATING_RESCUEs# advancing hosts in ITERATING_ALWAYSs5 all hosts are done, so returning None's for all hostsN( R
R& R' R( R) R* R R6 R9 t TrueR8 R t mint
ValueErrorR R0 R1 R. R t ITERATING_SETUPt ITERATING_TASKSt ITERATING_RESCUEt ITERATING_ALWAYS( R R: R+ R= t
num_setupst num_taskst
num_rescuet
num_alwayst
state_taskt host_tasks_to_runt lowest_cur_blockt kt vR4 R5 RA ( ( R@ R+ R sC /usr/lib/python2.7/site-packages/ansible/plugins/strategy/linear.pyt _get_next_task_lockstepU sp
"
c ( C` sj
| j j } t } x9
| rM
| j j rM
y� t j d � | j | � } t j d � t } t } g } | j | | � } t } t }
t } g } x`| D]X\ }
} | s� q� n | j j r� Pn t } t } y t j
| j d t �} Wn t k
r d= } n X| j rd| j j |
� rd| j j d= k sJ| j j rd| j j j rdt j d | � q� qdn | j d k r�| j | j | | | |
� � | j j
d d= � d> k r�t } n | j s�| r�| j r�t } q�n�| j r |
r | j | � rt }
q t } Pn t j d � | j j d
| j d |
d | � } | j | d
| j �t d
| j d | � } t j d � | j | j � p�| o�t! | d t � } | j s�| r�| j r�t } n | s�t j d � | j" } t j d � y8 t# | j | j" d t �d d �| _" t j d � Wn t j d � n Xt j d � | j j$ d | d t �| | _" t } t j d � n t | j% |
j& � <| j' |
| | | � ~ | r�Pn | | j( | d t) d t* t+ | j j, � d � � �7} q� W| r�w n t j d � | j- d k r1| | j. | � 7} n | j | � | j/ | � y+ t0 j1 | d! | d
| j d" | j �} Wn t2 k
r�} | j j3 SXt } t+ | � d k r1t j d# � t j d$ � t4 d% � | D� � } t j d& � x�| D]�} t j d' | j5 � yi| j6 r�| j7 | � } | j8 d
| j d" | j d
| j � \ } } | j j9 g | D] } | j: D] } | ^ qnqa� n | j; | d! | �} t j d( � x� | D]� } | j j d
| j d | j< � } t j d) � | j= | | � } t j d* � | j> | | j< | � } xB | D]: }
|
| j? k rK| |
j@ | � q"| |
j@ | � q"Wq�Wt j d+ � Wq�t2 k
r�} x1 | j? D]& }
t | j jA |
j" <| jB |
� q�Wt jC t# | � d, t �t } q�q�Xq�Wt j d- � x" | D] }
| jD |
| |
� q�Wt j d. � t j d/ � n t j d0 � t j d1 � g }! g }" xv | D]n }# |# jE � s�|# jF j d k r�| jE |# jG � r�|! j@ |# jG j" � q^|# jH � r^|" j@ |# jG j" � q^q^W| r�t+ |! � d k s�t+ |" � d k r�tI | jJ | jK g � }$ x� | D]~ }
| jL |
d2 t �\ }% }& |% jM |$ k sq|% jM | jJ k r|% jN | jO @d k rt | j jA |
j" <| | j jP O} qqWn t j d3 � t j d4 � | j jQ d= k r� t+ | � d k r� | j jQ d5 }' t+ | j jA � | jR |' k rq x@ | D]8 }
|
j" |! k r t | j jA |
j" <| jB |
� q q W| j j$ d6 � | | j jP O} n t j d7 t+ | j jA � | jR |' f � n t j d8 � t j d9 � | | j j k r
t+ | j jA � t+ | � k r
t j d: � | j j$ d6 � | St j d; � Wq tS tT f k
rI
} t j d< | � | j jU SXq WtV tW | � jX | | | � S(? s�
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
s) getting the remaining hosts for this loops. done getting the remaining hosts for this loopt
class_onlys) '%s' skipped because role has already runR# R% R$ t reset_connections getting variablest playR= t taskt loadert variabless done getting variablest BYPASS_HOST_LOOPsO sending task start callback, copying the task so we can template it temporarilys# done copying, going to template nowt fail_on_undefinedt nonstringt emptys done templatings! templating failed for some reasons here goes the callback...t v2_playbook_on_task_startt is_conditionals sending task start callbackt
max_passesi g�������?s> done queuing things up, now waiting for results queue to draini R+ t variable_managers! we have included files to processs generating all_blocks datac s` s | ] } | g f Vq d S( N( ( R2 R= ( ( sC /usr/lib/python2.7/site-packages/ansible/plugins/strategy/linear.pys <genexpr>[ s s done generating all_blocks datas processing included file: %ss2 iterating over new_blocks loaded from include files filtering new block on tagss done filtering new block on tagss7 done iterating over new_blocks loaded from include filet wrap_texts7 extending task lists for all hosts with included blockss done extending task listss done processing included filess results queue emptys checking for any_errors_fatalR- s" done checking for any_errors_fatals checking for max_fail_percentageg Y@t! v2_playbook_on_no_hosts_remainings$ (%s failed / %s total )> %s max fails% done checking for max_fail_percentagesI checking to see if all hosts have failed and the running result is not oks! ^ not ok, so returning result nows- done checking to see if all hosts have faileds% got IOError/EOFError in task loop: %sN( s noopRT (Y t _tqmt RUN_OKRB t _terminatedR R6 t get_hosts_leftt FalseRR R R7 R& t KeyErrorR t _rolet has_runt _metadatat allow_duplicatest extendt
_execute_metaR' t any_errors_fatalt
ignore_errorst _stept
_take_stept _variable_managert get_varsR) t add_tqm_variablesR
R* t templatet run_oncet getattrR8 R t
send_callbackt _blocked_hostst get_namet _queue_taskt _process_pending_resultst maxt intt lent _workerst _pending_resultst _wait_on_pending_resultst update_active_connectionsR t process_include_resultsR t RUN_ERRORt dictt _filenamet _is_rolet _copy_included_filet get_block_listt update_handler_listR t _load_included_fileR t filter_tagged_tasksR, t _hostsR t
_failed_hostst mark_host_failedt errort add_taskst is_failedt _taskt _hostt is_unreachablet frozensetRG RH R9 R. t
fail_statet
FAILED_RESCUEt RUN_FAILED_BREAK_PLAYt max_fail_percentaget
batch_sizet IOErrort EOFErrort RUN_UNKNOWN_ERRORt superR t run(( R R+ t play_contextR t
work_to_dot
hosts_leftt
callback_sentt host_resultsR@ t skip_restt choose_stepRo t resultsR= RV Rw R& t task_varst templart
saved_namet included_filest et include_failuret
all_blockst
included_filet new_irt
new_blockst handler_blockst
handler_blockt handlert new_blockt final_blockR" t failed_hostst unreachable_hostst rest dont_fail_statesR4 t _t
percentage( ( sC /usr/lib/python2.7/site-packages/ansible/plugins/strategy/linear.pyR� � sN
.
$
*
'
<
6
0 *
(
$
,
0
N( t __name__t
__module__R R R R R, RR R� ( ( ( sC /usr/lib/python2.7/site-packages/ansible/plugins/strategy/linear.pyR 5 s uN(" t
__future__R R R t typet
__metaclass__t
DOCUMENTATIONt ansible.errorsR R t ansible.executor.play_iteratorR t ansible.module_utils.sixR t ansible.module_utils._textR t ansible.playbook.blockR t ansible.playbook.included_fileR t ansible.playbook.taskR
t ansible.plugins.loaderR t ansible.plugins.strategyR t ansible.templateR
t __main__R t ImportErrort ansible.utils.displayR R ( ( ( sC /usr/lib/python2.7/site-packages/ansible/plugins/strategy/linear.pyt <module> s$