File: //lib/python3.9/site-packages/ansible/playbook/__pycache__/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