Vh9'ddlmZddlZddlZddlZddlmZddlmZddl m Z m Z ddl m Z ddlmZddlmZdd lmZd gZeZdaGd d eZGd d ej2Zy)) annotationsN)TemplateNotFound)Queue)AnsibleConnectionFailure AnsibleError) TaskExecutor)to_text)Display)context WorkerProcessc"eZdZdZfdZxZS) WorkerQueuez.Queue that raises AnsibleError items on get().cRtt| |i|}t|tr||SN)superrget isinstancer)selfargskwargsresult __class__s O/home/dcms/DCMS/lib/python3.12/site-packages/ansible/executor/process/worker.pyrzWorkerQueue.get*s-{D-t>v> fl +L )__name__ __module__ __qualname____doc__r __classcell__rs@rrr(s8rrcJeZdZdZfdZdZfdZdZdZdZ dZ xZ S) r z The worker thread class, which uses TaskExecutor to run tasks read from a job queue and pushes results into a results queue for reading later. c tt| ||_||_||_||_||_||_||_ ||_ t|j_ tt|_| |_y)N)ctx)rr __init___final_q _task_vars_host_task _play_context_loader_variable_manager_shared_loader_objset _tempfilesrmultiprocessing_context worker_queue worker_id) rfinal_q task_varshosttask play_contextloadervariable_managershared_loader_objr1rs rr$zWorkerProcess.__init__8sp mT+- #  ) !1"3#&% ',CD"rcd|_ tjjrhtjj J t j t jtjj |_|jtt j|_yy#t$rY7wxYw#ttf$rYLwxYwr) _new_stdinsysstdinisattyfilenoosfdopendupOSErrorAttributeError ValueErroropendevnullrs r _save_stdinzWorkerProcess._save_stdinLs yy!cii&6&6&8&D&(iisyy7G7G7I0J&KDO ?? ""2::.DO # +   s0 ?      s!9 AAc |jttjdxt_t_S#t$r}|j|Yd}~nd}~wwxYw ttjdxt_t_y#ttjdxt_t_wxYw)a Wrap _run() to ensure no possibility an errant exception can cause control to return to the StrategyBase task loop, or any other code higher in the stack. As multiprocessing in Python 2.x provides no protection, it is possible a try/except added in far-away code can cause a crashed child process to suddenly assume the role and prior state of its parent. wN) _runrFr@rGr<stdoutstderrrRrVrTs rrunzWorkerProcess.runs <99; '+2::s&; ;CJ  OOA    '+2::s&; ;CJd2::s&; ;CJs)A A$ ABA$$B0Cc t tj|j|a tj d|j d|j t|j |j |j|j|j|j|j|j|j j}tj d|j d|j d|j jdt!|j _g|j _tj d|j jz |jj'|j j(|j j||j j+tj d |j jztj dy #t,$r}tj d|d |jj'|j j(|j jd |t/j0d iYd }~d }~wwxYw#t2$rt!|j _g|j _|jj'|j j(|j jt!d |j j+YAt,$rw}t5|t6t8t:t<frt5|t>r; t!|j _g|j _|jj'|j j(|j jt!d tAt/j0d|j j+nc#t,$rWtj dtA|ztj dtAt/j0zYnwxYw|jCn#|jCwxYwYd }~d }~wwxYw)z Called when the process is started. Pushes the result onto the results queue. We also remove the host from the blocked hosts list, to signify that they are ready for their next task. zrunning TaskExecutor() for /z done running TaskExecutor() for z []zsending task result for task %s) task_fieldszfailed to send task result (z), sending surrogate resultT)failedmsg exceptionNz$done sending task result for task %s) unreachable)rarcrZzWORKER EXCEPTION: %szWORKER TRACEBACK: %szWORKER PROCESS EXITING)"rK set_queuer%current_workerrQr'r(rr&r)r;r*r,r+r\_uuiddictvarsgroupssend_task_resultname dump_attrs Exception traceback format_excrrIOErrorEOFErrorKeyboardInterrupt SystemExitrr _clean_up)rexecutor_resultrUs rrYzWorkerProcess._runs[ $--(E % MM DJJW X*  "" '' && ce  MM$**VZV`V`bfblblbrbrs t"fDJJO "DJJ  MM;djj>N>NN O  ..JJOOJJ$$# $ 5 5 7 /( MM@4::CSCSS T:  ./W  rs]$# .(A7?)L   )%Q-+33Q-r