관리-도구
편집 파일: __init__.cpython-39.pyc
a �)g�m � @ s. d dl mZmZmZ eZd dlZd dlmZm Z m Z m Z d dl m Z d dlmZmZmZ d dlmZ d dlmZmZ d dlmZ d d lmZ d d l m Z d d l m Z d d l m!Z! d d l"m#Z# d dl$m%Z% d dl&m'Z' d dl(m)Z) d dl*m+Z+ d dl,m-Z- d dl.m/Z/ ddgZ0dd� Z1G dd� dee e%e �Z2dS )� )�absolute_import�division�print_functionN)� Container�Mapping�Set�Sequence)� constants)� AnsibleError�AnsibleParserError�AnsibleAssertionError)�to_text)� binary_type� text_type)�FieldAttribute)�Base)�CollectionSearch)� Conditional)�load_list_of_blocks)� RoleMetadata)�Taggable)�add_all_plugin_dirs)�AnsibleCollectionConfig)� is_subpath)�Sentinel)� combine_vars�Role� hash_paramsc C s� t | t�r�t | ttf�s�t | t�rzzt| �� �}W q� tyv t� }| �� D ]\}}|� |t |�f� qNt|�}Y q�0 n^t | t t f�r�z t| �}W q� ty� t� }| D ]}|� t |�� q�t|�}Y q�0 nt| �}|S t| f�S )a� Construct a data structure of parameters that is hashable. This requires changing any mutable data structures into immutable ones. We chose a frozenset because role parameters have to be unique. .. warning:: this does not handle unhashable scalars. Two things mitigate that limitation: 1) There shouldn't be any unhashable scalars specified in the yaml 2) Our only choice would be to return an error anyway. ) � isinstancer r r r � frozenset�items� TypeError�set�addr r r )�params� new_params�k�v� r( �B/usr/lib/python3.9/site-packages/ansible/playbook/role/__init__.pyr 3 s( c s e Zd Zedd�Zedd�Zd9� fdd� Zd d � Zd:d d �Ze d;d d��Z d<dd�Z dd� Z dd� Z dd� Zd=dd�Zdd� Zdd � Zd d � Zd>d d �Zd?d!d"�Zd@d#d$�ZdAd%d&�Zd'd(� Zd)d*� Zd+d,� ZdBd-d.�Zd/d0� ZdCd1d2�Z dD� fd3d4� Z dE� fd5d6� Z d7d8� Z � Z S )Fr �string)Zisa�boolNFTc s� d | _ d | _d | _t� | _d | _d | _|| _g | _g | _ g | _ g | _ d | _ t� | _ t� | _t� | _t� | _|| _|d u r|i }|| _|| _tt| ��� d S �N)� _role_name� _role_path�_role_collection�dict� _role_params�_loader� _metadata�_play�_parents� _dependencies� _task_blocks�_handler_blocks�_compiled_handler_blocks� _default_vars� _role_vars� _had_task_run� _completed�_should_validate� _from_files� from_include�superr �__init__)�self�play� from_filesr@ �validate�� __class__r( r) rB h s, z Role.__init__c C s | � � S r, )�get_name�rC r( r( r) �__repr__� s z Role.__repr__c C s& |r d� dd� | j| jfD ��S | jS )N�.c s s | ]}|r|V qd S r, r( )�.0�xr( r( r) � <genexpr>� � z Role.get_name.<locals>.<genexpr>)�joinr/ r- )rC Zinclude_role_fqcnr( r( r) rI � s z Role.get_namec C s4 |d u r i }� z�| � � }| jd ur,| j|d< | jd ur@| j|d< |d urP||d< | jr`| j|d< ||d< t|�}| �� |jv r�|j| �� �� D ](\}} ||kr�|r�| �|� | W S q�t ||||d�} | j | |d� | �� |jvr�t � |j| �� < | |j| �� |< | W S t �y. t d| jd ��Y n0 d S ) N�when�tagsrE �varsr@ )rD rE r@ rF )� parent_rolezvA recursion loop was detected with the roles specified. Make sure child roles do not have dependencies on parent roles)�obj)�get_role_paramsrR rS rT r rI Z ROLE_CACHEr � add_parentr �_load_role_datar0 � RuntimeErrorr Z_ds) � role_includerD rU rE r@ rF r$ Z hashed_params�entryZrole_obj�rr( r( r) �load� s< �z Role.loadc s� |j � _|�� � _|j� _|�� � _|�� � _|� � � _ |rF� � |� � j D ]$}t � d|� �t|d|� �t�� qL� jd� j�d�dd�� _� jd u r�i � _nt� jt�s�td� j ��� jd� j�d�dd�� _� jd u r�i � _nt� jt�s�td� j ��� �d�}|�r2tj|� � j� j d �� _� �� � _ nt� � _g � _ � j�rZ� j � d � j� n$t j }|�rt� j � d |� t!� j� � jj �r�� j �"� fd d �� jj D �� � j �r� j�r�d nd}d � j v�r�d� j v�r� j �#|� � jd� j�d�d�}� j$�r� �%� }� �&||�}|�rtz t'|� j(� � j � jd�� _)W n: t*�yr } z td� j || d��W Y d } ~ n d } ~ 0 0 � jd� j�d�d�} | �r�z t'| � j(� d� j � jd�� _+W n: t*�y� } z td� j | | d��W Y d } ~ n d } ~ 0 0 d S )N�_rT T)�main� allow_dirzKThe vars/main.yml file for role '%s' must contain a dictionary of variables�defaultszOThe defaults/main.yml file for role '%s' must contain a dictionary of variables�meta)�owner�variable_manager�loaderr c 3 s | ]}|� j vr|V qd S r, )� collections)rM �crJ r( r) rO � rP z'Role._load_role_data.<locals>.<genexpr>zansible.builtinzansible.legacy�tasks�r` )rD �rolerf re zBThe tasks/main.yml file for role '%s' must contain a list of tasks)rV Zorig_exc�handlers)rD rk Z use_handlersrf re zEThe handlers/main.yml file for role '%s' must contain a list of tasks),rk r- Z get_role_pathr. r/ rW r1 Zget_variable_manager�_variable_manager� get_loaderr2 rX Z fattributes�setattr�getattrr �_load_role_yamlr? �getr; r r r r: r r^ r3 �_load_dependenciesr6 rg �insertr �default_collectionr �extend�appendr> �_get_role_argspecs�_prepend_validation_taskr r4 r7 �AssertionErrorr8 ) rC r[ rU Z attr_name�metadataru Zdefault_append_collection� task_dataZ role_argspecs�eZ handler_datar( rJ r) rY � sv " � � �zRole._load_role_datac C s~ t j�| jdd�}tjD ]V}|| }| j�|�r| jddd�}z|� d�pLi W S t yl i Y S 0 qt | j di �S )a� Get the role argument spec data. Role arg specs can be in one of two files in the role meta subdir: argument_specs.yml or main.yml. The former has precedence over the latter. Data is not combined between the files. :returns: A dict of all data under the top-level ``argument_specs`` YAML key in the argument spec file. An empty dict is returned if there is no argspec data. rc �argument_specsrj ) �os�pathrQ r. �CZYAML_FILENAME_EXTENSIONSr2 � path_existsrq rr �AttributeErrorrp r3 )rC Zbase_argspec_path�ext� full_pathr~ r( r( r) rx s zRole._get_role_argspecsc C sD |r@| j �dd�}|�|�}|r@| �||�}|s4g }|�d|� |S )a� Insert a role validation task if we have a role argument spec. This method will prepend a validation task to the front of the role task list to perform argument spec validation before any other tasks, if an arg spec exists for the entry point. Entry point defaults to `main`. :param task_data: List of tasks loaded from the role. :param argspecs: The role argument spec data dict. :returns: The (possibly modified) task list. ri r` r )r? rr �_create_validation_taskrt )rC r| ZargspecsZ entrypointZentrypoint_arg_specZvalidation_taskr( r( r) ry / s z Role._prepend_validation_taskc C sP d| }d|v r |d |d }d|� di �| jd| j|| jd�d�|d gd �S ) a� Create a new task data structure that uses the validate_argument_spec action plugin. :param argument_spec: The arg spec definition for a particular role entry point. This will be the entire arg spec for the entry point as read from the input file. :param entrypoint_name: The name of the role entry point associated with the supplied `argument_spec`. z*Validating arguments against arg spec '%s'Zshort_descriptionz - z&ansible.builtin.validate_argument_spec�optionsrk )�type�nameZargument_spec_namer� )�module� argument_specZprovided_argumentsZvalidate_args_context�always)�actionr� rS )rr r1 r- r. )rC r� Zentrypoint_nameZ task_namer( r( r) r� L s �� �z Role._create_validation_taskc C s� d}t j�| j|�}| j�|�r�| j�|�r�g d�}|du rLd}|�d� n|}|�dd� | j� ||||�}|r�|D ]d} t | |�s�t dt | �| j t |�f ��| j�| �} | rv|dur�t| t�r�t|| �}n| }|sv q�qvn|dur�t d||f ��|S )aj Find and load role YAML files and return data found. :param subdir: subdir of role to search (vars, files, tasks, handlers, defaults) :type subdir: string :param main: filename to match, will default to 'main.<ext>' if not provided. :type main: string :param allow_dir: If true we combine results of multiple matching files found. If false, highlander rules. Only for vars(dicts) and not tasks(lists). :type allow_dir: bool :returns: data from the matched file(s), type can be dict or list depending on vars or tasks. N)z.ymlz.yamlz.jsonr` � r zRFailed loading '%s' for role (%s) as it is not inside the expected role path: '%s'z,Could not find specified file in role: %s/%s)r r� rQ r. r2 r� Z is_directoryrw rt Zfind_vars_filesr r r r- Zload_from_filer r r ) rC Zsubdirr` ra �dataZ file_path� extensionsZ_mainZ found_files�foundZnew_datar( r( r) rq k s4 � zRole._load_role_yamlc C s8 g }| j r4| j jD ] }tj|| j| d�}|�|� q|S )zr Recursively loads role dependencies from the metadata list of dependencies, if it exists )rD rU )r3 Z dependenciesr r^ r4 rw )rC �depsr[ r] r( r( r) rs � s zRole._load_dependenciesc C s* t |t�st� �|| jvr&| j�|� dS )z/ adds a role to the list of this roles parents N)r r r r5 rw )rC rU r( r( r) rX � s zRole.add_parentc C s | j S r, )r5 rJ r( r( r) � get_parents� s zRole.get_parentsc C s\ |d u r g n|}t � }| �� D ]}t||�� �}q |rL|D ]}t||j�}q:t|| j�}|S r, )r0 �get_all_dependenciesr �get_default_varsr: )rC � dep_chainZ default_vars�dep�parentr( r( r) r� � s zRole.get_default_varsc C s@ |d u r g n|}t � }|r<|D ] }t||j�}t||j�}q |S r, )r0 r rT r; )rC r� Zinherited_varsr� r( r( r) �get_inherited_vars� s zRole.get_inherited_varsc C s> |d u r g n|}i }|r.|D ]}t ||j�}q t || j�}|S r, )r r1 )rC r� r$ r� r( r( r) rW � s zRole.get_role_paramsc C sl |d u r g n|}| � |�}| �� D ]}t||j|d��}q"t|| j�}t|| j�}|rht|| j|d��}|S )N)�include_params)r� )r� r� r �get_varsrT r; rW )rC r� r� Zall_varsr� r( r( r) r� � s z Role.get_varsc C s | j d d � S r, )r6 rJ r( r( r) �get_direct_dependencies� s z Role.get_direct_dependenciesc C s8 g }| � � D ]&}|�� D ]}|�|� q|�|� q |S )z� Returns a list of all deps, built recursively from all child dependencies, in the proper order in which they should be executed or evaluated. )r� r� rw )rC Z child_depsr� Z child_depr( r( r) r� � s zRole.get_all_dependenciesc C s | j d d � S r, )r7 rJ r( r( r) �get_task_blocks� s zRole.get_task_blocksc C s� | j r | j S g | _ }|d u r"g }|| g }| �� D ] }|j||d�}|�|� q4| jD ]"}|�� }||_||_|�|� qX|S )N�rD r� ) r9 r� �get_handler_blocksrv r8 �copy� _dep_chainr4 rw ) rC rD r� � block_list� new_dep_chainr� � dep_blocks� task_block�new_task_blockr( r( r) r� s zRole.get_handler_blocksc C s |j | jv o| jj S )zs Returns true if this role has been iterated over completely and at least one task was run )r� r= r3 Zallow_duplicates)rC �hostr( r( r) �has_run s z Role.has_runc C s� ddl m} ddlm} g }|du r(g }|| g }| �� }|D ] }|j||d�} |�| � q>| jD ]"} | �� } || _ || _ |� | � qb||d�} | j | _ | | _ | j| _d| _|| d�} | | _ d | _d d i| _d | _d g| _d | _| g| _|� | � |S )a� Returns the task list for this role, which is created by first recursively compiling the tasks for all direct dependencies, and then adding on the tasks for this role. The role compile() also remembers and saves the dependency chain with each task, so tasks know by which route they were found, and can correctly take their parent's tags/conditionals into account. r )�Block)�TaskNr� )rD F)�blockrc Z _raw_paramsZ role_completeTr� )Zansible.playbook.blockr� Zansible.playbook.taskr� r� �compilerv r7 r� r� r4 rw r2 Z_rolerm Zrun_oncer� �argsZimplicitrS rR r� )rC rD r� r� r� r� r� r� r� r� r� r� Z eor_blockZeor_taskr( r( r) r� % s< z Role.compilec s� t t| ��� }| j|d< | j|d< | j|d< | j|d< | j|d< | j� � |d< | j � � |d< | j rp| j �� |d< |r�g }| � � D ]}|� |�� � q�||d < g }| jD ]}|� |jd d �� q�||d < |S ) Nr- r. r; r1 r: r< r= r3 r6 F�� include_depsr5 )rA r � serializer- r. r; r1 r: r< r� r= r3 r� rw r5 )rC r� �resr� rk �parentsr� rG r( r) r� W s( zRole.serializec s* |� dd�| _|� dd�| _|� dt� �| _|� dt� �| _|� dt� �| _|� dt� �| _|� dt� �| _|r�g }|� d g �D ] }t � }|� |� |� |� q�t | d |� |� d g �}g }|D ]"}t � }|j |d d � |� |� q�t | d |� |� d �} | �rt � } | � | � | | _tt | �� |� d S )Nr- r� r. r; r1 r: r< r= r6 r5 Fr� r3 )rr r- r. r0 r; r1 r: r< r= r � deserializerw ro r r3 rA ) rC r� r� r� r� r] Z parent_datar� r� Z metadata_data�mrG r( r) r� r s6 zRole.deserializec C s8 || _ | jD ]}|�|� q | �� D ]}|�|� q$d S r, )r2 r5 � set_loaderr� )rC rf r� r� r( r( r) r� � s zRole.set_loader)NNFT)T)NNFT)N)NF)N)N)N)NT)N)N)T)T)!�__name__� __module__� __qualname__r Z delegate_toZdelegate_factsrB rK rI � staticmethodr^ rY rx ry r� rq rs rX r� r� r� rW r� r� r� r� r� r� r� r� r� r� � __classcell__r( r( rG r) r c s8 0 U 6 2!)3Z __future__r r r r� Z __metaclass__r �collections.abcr r r r Zansibler r� Zansible.errorsr r r Zansible.module_utils._textr Zansible.module_utils.sixr r Zansible.playbook.attributer Zansible.playbook.baser Z!ansible.playbook.collectionsearchr Z ansible.playbook.conditionalr Zansible.playbook.helpersr Z ansible.playbook.role.metadatar Zansible.playbook.taggabler Zansible.plugins.loaderr Z ansible.utils.collection_loaderr Zansible.utils.pathr Zansible.utils.sentinelr Zansible.utils.varsr �__all__r r r( r( r( r) �<module> s, 0