U Ld/@sddlZddlmZddlmZddlmZmZmZm Z ddl m Z m Z ddl m Zddl mZmZddlmZdd lmZdd lmZdd lmZdd lmZeeZd ZGdddeZddZ ddZ!ee"e#dddZ$GdddZ%dS)N) signature) ModuleType)DictList NamedTupleOptional)configimporter)log) type_utilsutil) ALL_DISTROS) ConfigMerger)ReportEventStack) FREQUENCIES)InitZcc_c@s2eZdZUeed<eed<eed<eeed<dS) ModuleDetailsmodulename frequencyrun_argsN)__name__ __module__ __qualname__r__annotations__strrrr:/usr/lib/python3/dist-packages/cloudinit/config/modules.pyr s rcCsX|dd}|dr.|dt|d}|}|s>dS|tsTdt|f}|S)N-_z.pyrz%s%s)replacelowerendswithlenstrip startswith MOD_PREFIX)rZ canon_namerrrform_module_name's   r(cCst|drd|jksd|jkr4td|d|d|jdtkrdtd|d|d|jddt|d rtd|d|d dS) NmetardistroszModule 'z ' with name 'z4' MUST have a 'meta' attribute of type 'MetaSchema'.z' has an invalid frequency .ZschemazX' has a JSON 'schema' attribute defined. Please define schema in cloud-init-schema,json.)hasattrr) ValueErrorr)modrrrrvalidate_module3s" r/)module_detailscfgreturncCs2t|jjdi}|sdS||s.dSdS)NZactivate_by_schema_keysTF) frozensetrr)get intersectionkeys)r0r1Zactivate_by_schema_keys_keysrrr _is_activeIsr7c@sxeZdZdedddZeejdddZe e ddd Z e e dd d Z e e d d dZdddZddZdS)ModulesN)initcCs2||_||_d|_|dkr(tdddd}||_dS)Nzmodule-reporterz module-descF)r descriptionZreporting_enabled)r9 cfg_files _cached_cfgrreporter)selfr9r;r=rrr__init__UszModules.__init__)r2cCs<|jdkr0t|jj|jj|j|jjd}|j|_t|jS)N)paths datasourceZadditional_fnsZbase_cfg) r<rr9r@rAr;r1copydeepcopy)r>Zmergerrrrr1bs z Modules.cfgcCs`g}||jkr|S|j|}|s&|S|D].}|s6q*t|trT|d|iq*t|tri}t|dkr~|d|d<t|dkr|d|d<t|dkr|dd|d<|r||q*t|trDi}d }d |kr|d |d<d }d |kr|d |d<d|kr,|dp&g|d<|rZ|rZ||q*t d |t |fq*|S)aURead the modules from the config file given the specified name. Returns a list of module definitions. E.g., [ { "mod": "bootcmd", "freq": "always", "args": "some_arg", } ] Note that in the default case, only "mod" will be set. r.rfreqr NargsFrTrz3Failed to read '%s' item in config, unknown type %s) r1r4 isinstancerappendr%listr$dict TypeErrorr obj_name)r>rZ module_listZcfg_modsitemcontentsZvalidrrr _read_modulespsV               zModules._read_modulesc Csg}|D]}|d}|d}|dp*g}t|}|s:q|rX|tkrXtd||d}t|dtt gdg\}} |std|| qt |d } t | ||dkr| j d }| t| |||d q|S) zConvert list of returned from _read_modules() into new format. Invalid modules and arguments are ignored. Also ensures that the module has the required meta fields. r.rFrGz6Config specified module %s has an unknown frequency %sNhandlez,Could not find module named %s (searched %s)rr)rrrr)r4r(rLOGZwarningr find_moduler rMr import_moduler/r)rIr) r>raw_mods mostly_modsZraw_modZraw_namerFrmod_nameZmod_locsZ looked_locsr.rrr_fixup_modulessP     zModules._fixup_modules)rWc Cs@|j}g}g}|D]\}}}}ztd|||||d|} d| |f} t| | |jd} ||j||d} | pt|j } | j }t |dkrt j ddd | d ti|j| |j | |d \}}|rd | | _n d | | _W5QRXWqtk r4}z"t td|||||fW5d}~XYqXq||fS)Nz(Running module %s (%s) with frequency %szconfig-zrunning %s with frequency %s)rr:parent)rr1ZcloudrGz%Config modules with a `log` parameterz23.2)Z deprecatedZdeprecated_versionr )rFz%s ran successfullyz%s previously ranzRunning module %s (%s) failed)r9ZcloudifyrSdebugrIrr=r1rrRZ parametersr$r Z deprecateupdaterunmessage ExceptionZlogexc)r>rWZccZfailuresZ which_ranr.rrFrGrun_nameZdescZmyrepZ func_argsZfunc_signatureZ func_paramsZranZ_rerrr _run_moduless\        "zModules._run_modulescCs&|||d}|g}||}||S)N)r.rGrF)rYrc)r>rXrGrFZ mod_to_berVrWrrr run_single s zModules.run_singlecCs||}||}|jjj}g}g}|jdg}g}g} |D]} | \} } } }| dkrZq@| jd}t| |js|| | q@|r|t gkr||kr| |kr| | q@| | | | | | |gq@|rt dd ||rt dd |||r t dd ||| S) zRuns all modules in the given section. section_name - One of the modules lists as defined in /etc/cloud/cloud.cfg. One of: - cloud_init_modules - cloud_config_modules - cloud_final_modules Zunverified_modulesNr*z?Skipping modules '%s' because no applicable config is provided.,zSkipping modules '%s' because they are not verified on distro '%s'. To run anyway, add them to 'unverified_modules' in config.z running unverified_modules: '%s'z, )rPrYr9Zdistrorr1r4r)r7rIr rSinfojoinrc)r>Z section_namerVrWZ distro_nameZskippedZforcedZ overriddenZinapplicable_modsZ active_modsr0r.rZ_freqZ_argsZworked_distrosrrr run_sectionsJ         zModules.run_section)NN)NN)rrrrr?propertyrZConfigr1rrrPrrYrcrdrhrrrrr8Ts  ;02 r8)&rBinspectrtypesrtypingrrrrZ cloudinitrr r Zloggingr r Zcloudinit.distrosr Zcloudinit.helpersrZcloudinit.reporting.eventsrZcloudinit.settingsrZcloudinit.stagesrZ getLoggerrrSr'rr(r/rKboolr7r8rrrr s$