VhYFddlmZdZddlmZddlmZmZm Z ddl m Z ddl m Z ddlmZddlmZdd lmZdd lmZdd lmZeZGd d eZy)) annotationsa 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) AnsibleErrorAnsibleAssertionErrorAnsibleParserError)to_text)Handler) IncludedFile) action_loader) StrategyBase)Templar)Displayc$eZdZdZfdZxZS)StrategyModuleci}|D]"}|j|d\}}|||f||<$|sgS|jDchc]\}}|j} }}d} | dkrD |j|j} |xjdz c_| j| vrn| dkrDt dg} |jD]Q\}\}}| j|jk(s#|j|j|| j||fS| jtjvrv| jjddk(rX|j j"D cgc]} | j$D]}|c}} |j|j|j| Scc}}w#t $rd|_| dz } Y)wxYwcc}} w)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. T)peekrzOBUG: There seems to be a mismatch between tasks in PlayIterator and HostStates. _raw_paramsflush_handlers)get_next_task_for_hostvalues_uuid all_taskscur_task IndexErrorritemsset_state_for_hostnameappendactionC _ACTION_METAargsget_playhandlersblock)selfhostsiteratorstate_task_per_hosthoststatetaskst task_uuids _loop_cntr host_tasksbhs O/home/dcms/DCMS/lib/python3.12/site-packages/ansible/plugins/strategy/linear.py_get_next_task_lockstepz&StrategyModule._get_next_task_lockstep/s ! 8D"99$T9JKE4,14K#D) 8 #I*=*D*D*FG$!QaggG G 1n #--h.?.?@ !!Q&!>>Z/1n(a  #6#<#<#> 0 D-5$~~+++DIIu=!!4,/ 0 ??ann ,1B1B=1QUe1eRZR`R`RiRiF{QstszszF{noqF{qF{H  x001B1B C9H  $%!Q  *G|sF*"F0)G 0G G cR|jj}d}|j|j| rT|jj s= t j d|j|}t j dd}d}|j||}d}d} d} g} |D]\} } |jjrnd}d}t| tst| jrh|j| |j}|j| r;| jjjdurt j d| zt j d|j j#|j| | |j$|j&}|j)||jt+|j,| }t j d |j/| j0} t3j4|d| j6 }|t:j<vrc| j?|jA| ||| | jBj5d d dvrd}| jDs|r1| jFs$d} n |jHr| r|jK| rd} nd}n|xr tM|ddxs|j/| jN} tQ|j/| jRdd| _)| jDs|r| jFsd} |sMt| tr|jjWd| n|jjWd| dd}d|jX| j[<|j]| | ||~t| tr$|r| j_n| ja| |rnX| j?|jc|tedtgti|jjjdz|r!t j d|jldkDr | j?|jo||jq| tsjt| ||j,|j }ti|dkDrt j dt j dtwd |D}t j d!g}ty}|D]m}t j d"|jzzd} |j|rG|j|}|j|j|j |j,#\}}n/t|jt}|j|||d$}|jjDcgc]}|jD]}|c}}|_Ct j d%|D]} |r(| jD]} |jd d | _F| }!n|j j#|j| j|j$|j&&}t j d'| j|}!t j d(|j?|!j|D]%} | |jvs|| j|!'t j d)|jD]2} |jjjd*| jR4|jjWd+|p|D]6} d|jj| jR<|j| 8t j d1|D]} |j| || ||j|j|jt j d2t j d3t j d4t j d5g}#g}$| D]n}%|%jr&|#j|%jjR9|%jsJ|$j|%jjRp| rN|#s|$rJ|D]E} | jR|#vsd|jj| jR<|j| Gt j d6t j d7|jjti| dkDr |jjd8z }&ti|jj|jz |&kDr~|D]E} | jR|#vsd|jj| jR<|j| G|jjWd9||jjz}t j d:ti|jjd;|jd<|&d=t j d>t j d?||jjk7r]ti|jjti|k\r2t j d@|jjWd9|St j dA|r|jjs =tt||||S#t8$rd }Y wxYw#tT$r0}t j d| jRd|Yd }~d }~wwxYwcc}}w#t$rt$r}t jtQ|d,|jD]}"d|"jd-<t||"jd.<|jjjd/|"jjR|jjWd0|"|j|"jYd }~d }~wwxYw#ttf$r8}t j dB|z|jjcYd }~Sd }~wwxYw)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 loopFz)'%s' skipped because role has already runzgetting variables)playr,r._hosts _hosts_all)r9)loader variableszdone getting variables) class_onlycollection_listNr)noopreset_connectionend_host role_completerend_roleBYPASS_HOST_LOOP)fail_on_undefinedempty) nonstringzFailed to templalte task name (z"), ignoring error and continuing: !v2_playbook_on_handler_task_startv2_playbook_on_task_start)is_conditionalrg?) max_passesz>done queuing things up, now waiting for results queue to drainr)r*r<variable_managerz!we have included files to processzgenerating all_blocks datac3$K|]}|gf yw)N).0r,s r6 z%StrategyModule.run..s%HTtRj%Hszdone generating all_blocks datazprocessing included file: %s)r9rMr<)r* is_handlerhandle_stats_and_callbacksz2iterating over new_blocks loaded from include file)r9r.r:r;zfiltering new block on tagsz done filtering new block on tagsz7done iterating over new_blocks loaded from include fileokv2_playbook_on_include) wrap_textfailedreasonfailuresv2_runner_on_failedz7extending task lists for all hosts with included blockszdone extending task listszdone processing included fileszresults queue emptyzchecking for any_errors_fatalz"done checking for any_errors_fatalz checking for max_fail_percentagegY@!v2_playbook_on_no_hosts_remaining(z failed / z total )> z 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)e_tqmRUN_OK_set_hosts_cacher% _terminateddisplaydebugget_hosts_leftr7 isinstancer _role_get_cached_rolehas_run _metadataallow_duplicates_variable_managerget_vars _hosts_cache_hosts_cache_alladd_tqm_variablesr _loadertemplater r r$ collectionsKeyErrorr!r"extend _execute_metar#any_errors_fatal ignore_errors_step _take_stepgetattrrun_oncerr Exception send_callback_blocked_hostsget_name _queue_task clear_hosts remove_host_process_pending_resultsmaxintlen_workers_pending_results_wait_on_pending_resultsupdate_active_connectionsr process_include_resultsdictset _filename_is_role_copy_included_fileget_block_list_task_load_included_filer&r'r:notified_hostsget_first_parent_includefilter_tagged_tasks get_tasksr_stats incrementrrerror_results_resultstr_hostadd _failed_hostsmark_host_failed add_tasksrr is_failedis_unreachablemax_fail_percentage batch_sizeRUN_FAILED_BREAK_PLAYIOErrorEOFErrorRUN_UNKNOWN_ERRORsuperrrun)(r(r* play_contextresult work_to_do hosts_left callback_sentr3 skip_rest choose_stepruresultsr,r.rzrole_obj task_varstemplar task_actionr eincluded_files all_blocksincluded_tasksfailed_includes_hosts included_filerRnew_ir new_blockshandler_blocksr4r5 new_block final_blockr failed_hostsunreachable_hostsres percentage __class__s( r6rzStrategyModule.run\sM !!  hnn-!6!6~ 3 IJ!00:  NO!& " !99*hO " " $) $.RCLT4yy,,$H!%J&dG4#'#8#8x~~#N#++D1djj6J6J6[6[_d6d#MM*UX\*\]$MM"56 $ 6 6 ? ?X^^Z^eiGKGXGXeiezez!@!|I**98>>*J%T\\YOGMM":; #*"2"24;;"?K&!.!2!2;4aeaqaq!r #ann4 t'9'9$ hX\']^99===F]]'+H 11XtGYGY/3, ::+#t4.3 ,0 %#)#Xgf>PRW.X#{\c\l\lmqmzmz\{~(/0@0@^c0@0dpw(xDI!11XtGYGY/3,,)$8 $ 7 78[]a b $ 7 78SUYjo 7 p,0M?C++DMMO<((tY M%!$0# ,,. ,,T2 NN4#@#@VYZ[]`adeienenewewax{~a~]WA#@$BCeRCj ^_((1,NN4#@#@#JK..w7!-!E!E%<<%)%;%; "~&*MM"EFMM">?!%%HZ%H!HJMM"CD%'N,/E))7@]  &D}G^G^&^_%* =],55)-)A)A-)P=C=R=R)1595K5K+/<<>S>" : N .8 8K8KW-U -1-E-E$1-5/9?D .F." =ENNK>R>RST>U(;%V2;K040F0F0O0O-5^^-6-O-O-Q/3/@/@373H3H 1P1&I %,MM2O$P2;2O2OPY2ZK$+MM2T$U . 5 5k6K6K6M N,6!MD'+}/C/C'C(24(8(?(? (L!M%M,$MM*cd)6(<(<L $ 0 0 : :4 KL II334Lm\A@]D!68=A // : 11$78 MM"[\ *C **4D1ABCO]H&&x'8'89J9JKMM"=>MM"BC 34 =>! $&!"AC}}$++CIINN;++-)00@ A $9J *<99L8AEDII33DII>$55d;< BC @A>>55Ac'lUVFV!)!C!Ce!KJDII334x7J7JJjX$.@D $yy rsH"#  #RR?,701$) )AO\AOr