VhT PddlmZddlmZddlmZmZmZm Z ddl m Z ddl m Z ddlmZddlmZmZddlmZdd lmZdd lmZdd lmZdd lmZdd lmZddlm Z ddl!m"Z"ddl#m$Z$ddl%m&Z&ddl'm(Z(ddl)m*Z*ddl+m,Z,ddl-m.Z.ddl/m0Z0dgZ1e,Z2Gddeee(ee$e Z3y)) annotations) constants) AnsibleErrorAnsibleParserErrorAnsibleUndefinedVariableAnsibleAssertionError) to_native) string_types)ModuleArgsParser)AnsibleBaseYAMLObjectAnsibleMapping) lookup_loader)NonInheritableFieldAttribute)Base)Block)CollectionSearch) Conditional) Delegatable) LoopControl) Notifiable)Role)Taggable)AnsibleCollectionConfig)Display)Sentinel) isidentifierTaskc eZdZdZedeZedZeddd Zed e Z ed d Z ed e Z ed Z ed eeZedej"ZeddZedZed e ZeddZd/fd Zd0dZdZed1dZdZdZfdZdZfdZ dZ!dZ"dZ#fdZ$dZ%d Z&d!Z'd"Z(d#Z)d$Z*d%Z+d&Z,d2fd' Z-fd(Z.fd)Z/d*Z0d3d+Z1d,Z2d-Z3d.Z4xZ5S)4rz A task is a language feature that represents a call to a module, with given arguments and other parameters. A handler is a subclass of a task. Usage: Task.load(datastructure) -> Task Task.something(...) dict)isadefaultstring)r intrasync)r r!aliaslistfloatclass)r class_typer!T)r static)r privatec||_d|_d|_d|_|r||_n||_tt |y)zQ constructors a task, without the Task.load classmethod, it will be pretty blank NF)_role_parentimplicitresolved_actionsuperr__init__)selfblockrole task_include __class__s E/home/dcms/DCMS/lib/python3.12/site-packages/ansible/playbook/task.pyr3z Task.__init__Ws@   # 'DL DL dD"$c(|jr|jj|}|jr|jrd|jS|jr |jS|jrd|jS|jS)z return the name of the task )include_role_fqcnz : )r.get_namenameaction)r4r< role_names r9r=z Task.get_namefsp :: ++>O+PI ::$)) )4995 5 YY99 zz$-t{{;;#{{,r:c|yt|tr|St|trId}|jD]"\}}|j dr||d|dz}$|j }|Sy)N_= ) isinstancer ritems startswithstrip)r4dsbufkvs r9 _merge_kvzTask._merge_kvvsv : L )I D !C((* .A<<$1-- .))+CJ"r:cFt|||}|j|||S)N)r5r6r7)variable_managerloader)r load_data)datar5r6r7rPrQts r9loadz Task.loads& u4l C{{42B6{RRr:c|jtjvrd|jdzSd|j zS)z5 returns a human-readable representation of the task zTASK: meta (%s) _raw_paramszTASK: %s)r?C _ACTION_METAargsr=r4s r9__repr__z Task.__repr__s7 ;;!.. ($tyy'?? ? / /r:c|jd}|jd|jdtd|z||td|z|||d<||d<y)z2 take a lookup plugin name and store it correctly with_loopN loop_withzduplicate loop in task: %sobjz&you must specify a value when using %s) removeprefixgetr)r4rJnew_dsrLrM loop_names r9_preprocess_with_loopzTask._preprocess_with_loopsnNN7+ ::f  )VZZ -D-P;iGRP P 9G!KQST T'{vr:cXt|tstd|dt|t }t|t r|j |_tj}|jd}| |j}n-|jd|jjd|d}|r(|js|r||vr|jd|n|g}|rd|vrd|vr|jd|r||d<t!||} |j#\}}}|j$|_|t,j.vr:d |vr6|jd d d k7r t1d ||j3d |d <||d<||d<||d<d|vr%|j5d|jd|d<n t|d<|j7D]\} } | dvs | |k(s| dk(r| j9dr,| j;dt<vr|j?||| | Rt,j@s| |jvr| || <vtBjEd| ztFtH||S#t&$r)} | j(rt't+| || d} ~ wwxYw)zg tasks are especially complex arguments so need pre-processing. keep it short. zds (z) should be a dict but was a collectionsNrzansible.builtinzansible.legacy)task_dscollection_list)rborig_exccmdrWrBz{The 'cmd' argument cannot be used when other raw parameters are specified. Please put everything in one or the other place.rar?rZ delegate_tovars)r? local_actionrZrnshellr^zIgnoring invalid attribute: %s)&rFrrtyper r ansible_posrdefault_collectionrdriget_validated_value fattributesr.insertappendr parser1rrbr rX_ACTION_HAS_CMDrpop _load_varsrGrHrcrrgINVALID_TASK_ATTRIBUTE_FAILEDdisplaywarningr2rpreprocess_data) r4rJrertcollections_list args_parserr?rZrnerLrMr8s r9rzTask.preprocess_datas "d#'SUW[\^W_(`a a  ! b/ 0!#F 5GG66-0  ##//  $77 tGWGWG[G[\iGjl|C D  djj%-==$++A/AB$6#7  19I IN^fvNv  # #$4 5  0B}  'rCST  ?*5*;*;*= 'VT;$/#>#>D Q&& &}88M2."4&([`bdd&*hhuo]#!xv +} R<"__T266&>BF6N!VF6Nhhj FFQEEfXY]dXdg&1>>'+Bm+S**2vq!<00A9I9I4Iq  @1 DE FT4088_" Guu$Yq\rAF F  GsI77 J)$J$$J)ct|ts td|tj||j |j S)Nz|the `loop_control` value must be specified as a dictionary and cannot be a variable itself (though it can contain variables)ra)rSrPrQ)rFrrrrU_variable_manager_loader)r4attrrJs r9_load_loop_controlzTask._load_loop_controlsF"d#$I  R$:P:PY]YeYeffr:c~ tt| |y#t$r}|xjdz c_|d}~wwxYw)Nzb This error can be suppressed as a warning using the "invalid_task_attribute_failed" configuration)r2r_validate_attributesrmessage)r4rJrr8s r9rzTask._validate_attributess;  $ 22 6!  II~ ~IG s <7<cBt|tst|||gyyNrFr&setattrr4rr>values r9_validate_changed_whenzTask._validate_changed_when%& D$ ('r:cBt|tst|||gyyrrrs r9_validate_failed_whenzTask._validate_failed_whenrr:c>|t|std|dyy)Nz0Invalid variable name in 'register' specified: '')rrrs r9_validate_registerzTask._validate_registers/  \%%8$'WX]W^^_%`a a&9 r:c|jr|jj|tjr tt ||y)z Override of base class post_validate, to also do final validation on the block and task include (if any) to which this task belongs. N)r/ post_validaterrtr2r)r4templarr8s r9rzTask.post_validates9 << LL & &w / " 5 5  dD'0r:c||_|j|}d|vrj|jd}t|tr:t j rtjd|j||}|Std|d|S)N_variable_paramszUsing a variable for a task's 'args' is unsafe in some situations (see https://docs.ansible.com/ansible/devel/reference_appendices/faq.html#argsplat-unsafe)z invalid or malformed argument: 'r) untemplated_argstemplater{rFrrXINJECT_FACTS_AS_VARSr~rupdater)r4rrrrZvariable_paramss r9_post_validate_argszTask._post_validate_args(s!&&  %"hh'9:O/40))OO%AB&&t,&  #%EoEVVW#XYY r:c|S)z Override post validation for the loop field, which is templated specially in the TaskExecutor class when evaluating loops. r4rrrs r9_post_validate_loopzTask._post_validate_loop@  r:ci|Ljfd}t|trn|D]g}t|tr|D]}||||'j|d}t|tr|zPtj d|ziSt|trt|D]}||||Sj|dS)zu Override post validation of vars on the play, as we don't want to template these too early. c j|d|<y#t$r:}t|}jtj vrd|vsd|vrYd}~yd}~wwxYw)NF convert_barezansible_facts.env ansible_env)rrr r?rX_ACTION_FACT_GATHERING)rLrMrerrorenvr4rs r9 _parse_env_kvz6Task._post_validate_environment.._parse_env_kvOsd$--ae-DCF/%aLE{{a&>&>>CVZ_C_cptycy s A/AAAFrz/could not parse environment value, skipping: %s)rFr&rrr~r) r4rrrrenv_itemrLisdictrs ` ` @r9_post_validate_environmentzTask._post_validate_environmentGs    %& % gH!(D1!):A)!Xa[9:")!1!1(!1!O%fd36MC#OO,]`e,ef g( E4(f %=H!(E(O<=  &&u5&A r:c|S)z changed_when is evaluated after the execution of the task is complete, and should not be templated during the regular post_validate step. rrs r9_post_validate_changed_whenz Task._post_validate_changed_whenprr:c|S)z failed_when is evaluated after the execution of the task is complete, and should not be templated during the regular post_validate step. rrs r9_post_validate_failed_whenzTask._post_validate_failed_whenwrr:c|S)z until is evaluated after the execution of the task is complete, and should not be templated during the regular post_validate step. rrs r9_post_validate_untilzTask._post_validate_until~rr:ct}|jr||jjz}||jz}d|vr|d=d|vr|d=|S)Ntagswhen)rr/get_varsror4all_varss r9rz Task.get_varssZ6 <<  --/ /HDII X  X  r:ct}|jr||jjz}|jtj vr||j z}|Sr)rr/get_include_paramsr?rX_ACTION_ALL_INCLUDESrors r9rzTask.get_include_paramssL6 <<  779 9H ;;!00 0  !Hr:cFtt| }d|_|jr#|s!|jj||_d|_|jr|j|_|j |_|j |_|j|_|S)N) exclude_tasks)r2rcopyr/r.r0r1_uuid)r4exclude_parentrnew_mer8s r9rz Task.copys}tT') <<!\\..].KFN ::::FL--!%!5!5zz  r:ctt| }|js|js|j r@|j j|d<|j j j|d<|jr|jj|d<|j|d<|j|d<|S)Nparent parent_typer6r0r1) r2r serialize _squashed _finalizedr/r8__name__r.r0r1)r4rSr8s r9rzTask.serializesT4*,~~doo||!%!7!7!9X&*ll&<&<&E&E]#zz#zz335V #}}D &*&:&:D" # r:cddlm}ddlm}|j dd}|rU|j d}|dk(r t }n|dk(r|}n |dk(r|}j |||_|d=|j d }|r%t}|j |||_ |d =|j d d |_ |j d |_ tt||y) Nr TaskInclude)HandlerTaskIncluderrrrrr6r0Fr1)ansible.playbook.task_includer%ansible.playbook.handler_task_includerrdr deserializer/rr.r0r1r2r) r4rSrr parent_datarp role_datarr8s r9rzTask.deserializes >Lhhx. ((=1Kg%G -M 44&( MM+ &DLXHHV$ A MM) $DJV U3 #xx(9: dD%d+r:cb||_|jr|jj|yy)z Sets the loader on this object and recursively on parent, child objects. This is used primarily after the Task has been serialized/deserialized, which does not preserve the loader. N)rr/ set_loader)r4rQs r9rzTask.set_loaders) << LL # #F + r:c|j|}|j}|j} |rt}nt |d|t}t |j ddr |j }n|j j }|rg|tus|r]t |ddrP|dk7rt |dr|j|}nt |d|t}|r|j|||}|S|}|S#t$rYSwxYw)zZ Generic logic to get the attribute or parent attribute for a task value. rCstatically_loadedTro_get_parent_attribute) rvextendprependrgetattrr/hasattrr _extend_valueKeyError) r4romitfattrrrrr/ parent_values r9rzTask._get_parent_attributes  &--  $j(;t||%8$?,,,,..EX-7$7>v~'';R*S'.'D'DT'J '.w!D6 H'M  $ 2 25, P  !-     sB ,&P r:N)4 __future__ransiblerrXansible.errorsrrrr+ansible.module_utils.common.text.convertersr ansible.module_utils.sixr ansible.parsing.mod_argsr ansible.parsing.yaml.objectsr r ansible.plugins.loaderransible.playbook.attributeransible.playbook.baseransible.playbook.blockr!ansible.playbook.collectionsearchransible.playbook.conditionalransible.playbook.delegatableransible.playbook.loop_controlransible.playbook.notifiableransible.playbook.roleransible.playbook.taggableransible.utils.collection_loaderransible.utils.displayransible.utils.sentinelransible.utils.varsr__all__r~rrr:r9rss$#"llA15N0C&(>4452&.C)++ ( )q4h(8*kqr: