관리-도구
편집 파일: block.cpython-39.pyc
a �)g�A � @ s� d dl mZmZmZ eZd dlmZ d dl m Z d dl m Z m Z d dlmZ d dlmZ d dlmZ d dlmZ d d lmZ d d lmZ d d lmZ G d d � d eeee�Z dS )� )�absolute_import�division�print_functionN)�AnsibleParserError)�FieldAttribute� NonInheritableFieldAttribute)�Base)� Conditional)�CollectionSearch)�load_list_of_tasks)�Role)�Taggable)�Sentinelc s2 e Zd Zeded�Zeded�Zeded�Zedd�Z edd�Z edd�Z d8� fdd � Z d d � Z d d � Zdd� Zdd� Zed9dd��Zedd� �Z� fdd�Zdd� Zdd� Zd d � Zd d � ZeZd d!� Zd:� fd"d#� Zd$d%� Z d&d'� Z d(d)� Z d;d*d+�Z d,d-� Z d.d/� Z!d0d1� Z"d2d3� Z#d4d5� Z$d6d7� Z%� Z&S )<�Block�list)�isa�default)r �string�boolNFc sL || _ || _d | _d | _|| _|| _|r0|| _n |r:|| _tt| ��� d S �N) �_play�_role�_parent� _dep_chain� _use_handlersZ _implicit�superr �__init__)�self�play� parent_block�role� task_include� use_handlers�implicit�� __class__� �:/usr/lib/python3.9/site-packages/ansible/playbook/block.pyr 2 s zBlock.__init__c C s d| j t| �| jf S )Nz BLOCK(uuid=%s)(id=%s)(parent=%s))�_uuid�idr �r r& r& r' �__repr__A s zBlock.__repr__c C s | j |j kS �z object comparison based on _uuid�r( �r �otherr& r& r' �__eq__D s z Block.__eq__c C s | j |j kS r, r- r. r& r& r' �__ne__H s z Block.__ne__c C s* i }| j r|| j �� O }|| j�� O }|S )z� Blocks do not store variables directly, however they may be a member of a role or task include which does, so return those if present. )r �get_vars�vars�copy�r �all_varsr& r& r' r2 L s zBlock.get_varsc C s0 t �| � }t ||||||d�} | j| ||d�S )N)r r r r! r" r# )�variable_manager�loader)r �is_blockZ load_data) �datar r r r! r" r7 r8 r# �br& r& r' �load[ s z Block.loadc C s, d}t | t�r(dD ]}|| v rd} q(q|S )NF��block�rescue�alwaysT)� isinstance�dict)�dsr9 �attrr& r& r' r9 a s zBlock.is_blockc sR t �|�sBt|t�r*tt | ��t|d��S tt | ��t|gd��S tt | ��|�S )z� If a simple task is given, an implicit block for that single task is created, which goes in the main portion of the block )r> )r r9 rA r r �preprocess_datarB )r rC r$ r& r' rE k s zBlock.preprocess_datac C s^ z$t || j| | jd | j| j| jd�W S tyX } z td| j|d��W Y d }~n d }~0 0 d S )N�r r> r r! r7 r8 r" z7A malformed block was encountered while loading a block��objZorig_exc� r r r Z_variable_manager�_loaderr �AssertionErrorr �_ds�r rD rC �er& r& r' � _load_blocky s � zBlock._load_blockc C s^ z$t || j| | jd | j| j| jd�W S tyX } z td| j|d��W Y d }~n d }~0 0 d S )NrF z7A malformed block was encountered while loading rescue.rG rI rM r& r& r' � _load_rescue� s � zBlock._load_rescuec C s^ z$t || j| | jd | j| j| jd�W S tyX } z td| j|d��W Y d }~n d }~0 0 d S )NrF z6A malformed block was encountered while loading alwaysrG rI rM r& r& r' � _load_always� s � zBlock._load_alwaysc C s |r | j s td| | jd��d S )Nz+'%s' keyword cannot be used without 'block')rH )r> r rL )r rD �name�valuer& r& r' �_validate_always� s zBlock._validate_alwaysc C s2 | j d u r | jr| j�� S d S n| j d d � S d S r )r r � get_dep_chainr* r& r& r' rU � s zBlock.get_dep_chainc s� dd� }t t| ��� }| j|_| j|_| jd ur@| jd d � |_d |_| jr`|s`| jjdd�|_|s�|| jpng |�|_|| jp�g |�|_|| j p�g |�|_ d |_ | j r�| j |_ |� � |S )Nc S s| g }| D ]n}|j dd�}|jrf|jj dd�|_|j|kr@||_ql|j}|jr^|j|kr^|j}qF||_n||_|�|� q|S )NT)�exclude_parent�� exclude_tasks)r4 r �append)Z task_list� new_blockZ new_task_list�taskZnew_taskZcur_objr& r& r' �_dupe_task_list� s z#Block.copy.<locals>._dupe_task_listTrW ) r r r4 r r r r r> r? r@ r Zvalidate)r rV rX r\ Znew_mer$ r& r' r4 � s$ z Block.copyc C s~ t � }| jD ]}|dvr t| |�||< q | �� |d< | jdurL| j�� |d< | jdurz| jjdd��� |d< | jjj |d< |S ) z� Override of the default serialize method, since when we're serializing a task we don't want to include the attribute list of tasks. r= � dep_chainNr TrW �parent� parent_type) rB � fattributes�getattrrU r � serializer r4 r% �__name__)r r: rD r& r& r' rb � s zBlock.serializec C s� ddl m} ddlm} | jD ]&}||v r |dvr t| ||�|�� q |�dd�| _|�d�}|rxt� }|� |� || _ |�d�}|r�|�d �}|d kr�t � } n |d kr�|� } n|d kr�|� } | � |� | | _ | j � � | _dS ) zt Override of the default deserialize method, to match the above overridden serialize method r �� TaskInclude)�HandlerTaskIncluder= r] Nr r^ r_ r re rf )� ansible.playbook.task_includere Z%ansible.playbook.handler_task_includerf r` �setattr�getr r � deserializer r r rU ) r r: re rf rD Z role_data�rZ parent_datar_ �pr& r& r' rj � s. zBlock.deserializec C sP || _ | jr| j�|� n| jr,| j�|� | �� }|rL|D ]}|�|� q<d S r )rJ r � set_loaderr rU )r r8 r] �depr& r& r' rm s zBlock.set_loaderc C s | j | }|j}|j}�z�|r$t}nt| d|� �t�}t| jdd�rL| j}n| jj}|r�|tu sd|r�zPt|dd�r�t|d�r�|�|�}nt|d|� �t�}|r�| �|||�}n|}W n t y� Y n0 | j �r�|tu s�|�r�z�t| j d|� �t�}|�r | �|||�}n|}| � � } | �r�|tu �s,|�r�| � � | D ]H} t| d|� �t�} |�rd| �|| |�}n| }|tu�r8|�s8 �q��q8W n t �y� Y n0 | j �r|tu �s�|�rz<t| j d|� �t�} | tu�r�|�r�| �|| |�}n| }W n t �y Y n0 W n t�y Y n0 |S )z[ Generic logic to get the attribute or parent attribute for a block value. �_�statically_loadedT�_get_parent_attribute)r` �extend�prependr ra r �hasattrrq Z _extend_value�AttributeErrorr rU �reverser �KeyError) r rD ZomitZfattrrr rs rS r Z parent_valuer] rn Z dep_valueZ play_valuer& r& r' rq ) sf zBlock._get_parent_attributec s$ � ��fdd���fdd�����S )zR Creates a new block, with task lists filtered based on the tags. c s� g }| D ]~}t |t�r2�|�}|�� r�|�|� q|jtjv rD|js||jtjv rd|j g �j j � d�s||j �j j �j j � d�r|�|� q|S )N)r6 ) rA r � has_tasksrY �action�CZ _ACTION_METAr# Z_ACTION_INCLUDEZ evaluate_tagsr Z skip_tagsZ only_tags)�target�tmp_listr[ Zfiltered_block)r6 �evaluate_blockr r& r' �evaluate_and_append_taskw s ��� z;Block.filter_tagged_tasks.<locals>.evaluate_and_append_taskc s> | j ddd�}| j|_� | j�|_� | j�|_� | j�|_|S )NT)rV rX )r4 r r> r? r@ )r> rZ �r~ r& r' r} � s z1Block.filter_tagged_tasks.<locals>.evaluate_blockr& r5 r& )r6 r~ r} r r' �filter_tagged_tasksr s zBlock.filter_tagged_tasksc s �fdd�� � fdd���| �S )Nc s6 g }| D ](}t |t�r&|�� |�� q|�|� q|S r )rA r rr rY )r{ r| r[ )r} r& r' r~ � s z1Block.get_tasks.<locals>.evaluate_and_append_taskc s. � | j �}|�� | j�� |�� | j�� |S r )r> rr r? r@ )r> �rvr r& r' r} � s z'Block.get_tasks.<locals>.evaluate_blockr& r* r& )r~ r} r' � get_tasks� s zBlock.get_tasksc C s* t | j�dkp(t | j�dkp(t | j�dkS )Nr )�lenr> r? r@ r* r& r& r' rx � s zBlock.has_tasksc C s | j r| j �� S t� S d S r )r �get_include_paramsrB r* r& r& r' r� � s zBlock.get_include_paramsc C s8 ddl m} | jr4t| j|�r*| jjs*dS | j�� S dS )a7 Determine if all of the parents of this block were statically loaded or not. Since Task/TaskInclude objects may be in the chain, they simply call their parents all_parents_static() method. Only Block objects in the chain check the statically_loaded value of the parent. r rd FT)rg re r rA rp �all_parents_static�r re r& r& r' r� � s zBlock.all_parents_staticc C s2 ddl m} | jr.t| j|�r$| jS | j�� S d S )Nr rd )rg re r rA �get_first_parent_includer� r& r& r' r� � s z Block.get_first_parent_include)NNNNFF)NNNNFNN)FF)F)'rc � __module__� __qualname__r r r> r? r@ r �notifyZ delegate_toZdelegate_factsr r+ r0 r1 r2 � staticmethodr< r9 rE rO rP rQ rT Z_validate_rescuerU r4 rb rj rm rq r� r� rx r� r� r� � __classcell__r& r& r$ r' r " sB -& I r ) Z __future__r r r �typeZ __metaclass__Zansible.constantsZ constantsrz Zansible.errorsr Zansible.playbook.attributer r Zansible.playbook.baser Z ansible.playbook.conditionalr Z!ansible.playbook.collectionsearchr Zansible.playbook.helpersr Zansible.playbook.roler Zansible.playbook.taggabler Zansible.utils.sentinelr r r& r& r& r' �<module> s