Dashboard
PHP:
8.2.30
OS:
Linux
User:
dh_nv8b2m
/
/
usr
/
local
/
lib
/
python3.10
/
dist-packages
/
ansible
/
playbook
/
__pycache__
📤 Upload
📝 New File
📁 New Folder
Close
Editing: block.cpython-310.pyc
o O�h�@ � @ s� d dl mZ d dlmZ d dlmZ d dlmZ d dl m Z d dl m Z d dl mZ d dlmZ d d lmZ d d lmZ d d lmZ d d lmZ d d lmZ G dd� de e eeee�ZdS )� )� annotationsN)�AnsibleParserError)� NonInheritableFieldAttribute)�Base)� Conditional)�CollectionSearch)� Delegatable)�load_list_of_tasks)� Notifiable)�Role)�Taggable)�Sentinelc s e Zd Zeded�Zeded�Zeded�Zd5� fdd� Zdd� Z d d � Z d d � Z d d� Z e d6dd��Ze dd� �Z� fdd�Zdd� Zdd� Zdd� Zdd � ZeZd d � Zd7� fd d � Zd!d"� Zd#d$� Zd%d&� Zd8d'd(�Zd)d*� Z d+d,� Z d-d.� Z d/d0� Z d1d2� Z d3d4� Z!� Z"S )9�Block�list)�isa�defaultNFc sL || _ || _d | _d | _|| _|| _|r|| _n|r || _tt| ��� d S �N) �_play�_role�_parent� _dep_chain� _use_handlers� _implicit�superr �__init__)�self�play� parent_block�role� task_include� use_handlers�implicit�� __class__� �A/usr/local/lib/python3.10/dist-packages/ansible/playbook/block.pyr - 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__< s zBlock.__repr__c C s | j |j kS �z object comparison based on _uuid�r& �r �otherr$ r$ r% �__eq__? � z Block.__eq__c C s | j |j kS r* r+ r, r$ r$ r% �__ne__C r/ 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% r1 G s zBlock.get_varsc C s0 t �| � }t ||||||d�} | j| ||d�S )N)r r r r r r! )�variable_manager�loader)r �is_block� load_data) �datar r r r r r6 r7 r! �br$ r$ r% �loadV s z Block.loadc C s. d}t | t�rdD ] }|| v rd} |S q |S )NF��block�rescue�alwaysT)� isinstance�dict)�dsr8 �attrr$ r$ r% r8 \ s �zBlock.is_blockc sR t �|�s!t|t�rtt | ��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 r8 rA r r �preprocess_datarB )r rC r" r$ r% rE f s zBlock.preprocess_datac C �N zt || j| | jd | j| j| jd�W S ty& } ztd| j|d��d }~ww )N�r r> r r r6 r7 r z7A malformed block was encountered while loading a block��obj�orig_exc� r r r �_variable_manager�_loaderr �AssertionErrorr �_ds�r rD rC �er$ r$ r% � _load_blockt � � ��zBlock._load_blockc C rF )NrG z7A malformed block was encountered while loading rescue.rH rK rP r$ r$ r% � _load_rescue� rS zBlock._load_rescuec C rF )NrG z6A malformed block was encountered while loading alwaysrH rK rP r$ r$ r% � _load_always� rS zBlock._load_alwaysc C s$ |r| j std| | jd��d S d S )Nz+'%s' keyword cannot be used without 'block')rI )r> r rO )r rD �name�valuer$ r$ r% �_validate_always� s �zBlock._validate_alwaysc C s, | j d u r| jr | j�� S d S | j d d � S r )r r � get_dep_chainr( r$ r$ r% rY � s zBlock.get_dep_chainc s� dd� }t t| ��� }| j|_| j|_| jd ur | jd d � |_d |_| jr0|s0| jjdd�|_|sM|| jp7g |�|_|| jp@g |�|_|| j pIg |�|_ d |_ | j rW| j |_ |� � |S )Nc S s� g }| D ]>}|j dd�}|jr:|jj dd�|_|j|kr ||_n |j}|jr6|j|kr6|j}|jr6|j|ks+||_n||_|�|� q|S )NT)�exclude_parent�� exclude_tasks)r3 r �append)� task_list� new_block� new_task_list�task�new_task�cur_objr$ r$ r% �_dupe_task_list� s � z#Block.copy.<locals>._dupe_task_listTr[ ) r r r3 r r r r r> r? r@ r �validate)r rZ r\ rd �new_mer" r$ r% r3 � s$ z Block.copyc C s~ t � }| jD ] }|dvrt| |�||< q| �� |d< | jdur&| j�� |d< | jdur=| 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 Tr[ �parent� parent_type) rB � fattributes�getattrrY r � serializer r3 r# �__name__)r r: rD r$ r$ r% rl � s � zBlock.serializec C s� ddl m} ddlm} | jD ]}||v r"|dvr"t| ||�|�� q|�dd�| _|�d�}|r<t� }|� |� || _ |�d�}|ro|�d �}|d krPt � } n|d krX|� } n|d kr_|� } | � |� | | _ | j � � | _dS dS ) zt Override of the default deserialize method, to match the above overridden serialize method r �� TaskInclude)�HandlerTaskIncluder= rg Nr rh ri r ro rp )� ansible.playbook.task_includero �%ansible.playbook.handler_task_includerp rj �setattr�getr r � deserializer r r rY ) r r: ro rp rD � role_data�r� parent_datari �pr$ r$ r% ru � s2 � �zBlock.deserializec C sT || _ | jr | j�|� n | jr| j�|� | �� }|r&|D ] }|�|� q d S d S r )rM r � set_loaderr rY )r r7 rg �depr$ r$ r% rz s �zBlock.set_loaderc C s | j | }|j}|j}z�|rt}n t| d|� �t�}t| jdd�r%| j}n| jj}|rc|tu s1|rcz(t|dd�rXt|d�rC|�|�}n t|d|� �t�}|rV| �|||�}n|}W n t yb Y nw | j r�|tu sl|r�zJt| j d|� �t�}|r�| �|||�}n|}| � � } | r�|tu s�|r�| � � | D ] } t| d|� �t�} |r�| �|| |�}n| }|tur�|s� nq�W n t y� Y nw | j r�|tu s�|r�z&t| j d|� �t�} | tur�|r�| �|| |�}n | }W W |S W W |S W W |S t y� Y W |S w W |S W |S t�y Y |S w )z[ Generic logic to get the attribute or parent attribute for a block value. �_�statically_loadedT�_get_parent_attribute)rj �extend�prependr rk r �hasattrr~ � _extend_value�AttributeErrorr rY �reverser �KeyError) r rD �omit�fattrr r� rW r � parent_valuerg r{ � dep_value� play_valuer$ r$ r% r~ $ s� � � � �� � ��� � ��zBlock._get_parent_attributec s$ � ��fdd���fdd�����S )zR Creates a new block, with task lists filtered based on the tags. c sl g }| D ]/}t |t�r�|�}|�� r|�|� q|jtjv r"|js.|j�j j �j j � d�r3|�|� q|S )N)r5 ) rA r � has_tasksr] �action�C� _ACTION_METAr! � evaluate_tagsr � only_tags� skip_tags)�target�tmp_listra �filtered_block)r5 �evaluate_blockr r$ r% �evaluate_and_append_taskr s �� �z;Block.filter_tagged_tasks.<locals>.evaluate_and_append_taskc s> | j ddd�}| j|_� | j�|_� | j�|_� | j�|_|S )NT)rZ r\ )r3 r r> r? r@ )r> r_ �r� r$ r% r� ~ s z1Block.filter_tagged_tasks.<locals>.evaluate_blockr$ r4 r$ )r5 r� r� r r% �filter_tagged_tasksm s zBlock.filter_tagged_tasksc s �fdd�� � fdd���| �S )Nc s6 g }| D ]}t |t�r|�� |�� q|�|� q|S r )rA r r r] )r� r� ra )r� r$ r% r� � s z1Block.get_tasks.<locals>.evaluate_and_append_taskc s. � | j �}|�� | j�� |�� | j�� |S r )r> r 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�dkpt | j�dkpt | j�dkS )Nr )�lenr> r? r@ r( r$ r$ r% r� � s *zBlock.has_tasksc C s | j r| j �� S t� S r )r �get_include_paramsrB r( r$ r$ r% r� � s zBlock.get_include_paramsc C s8 ddl m} | jrt| j|�r| jjsdS | 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 rn FT)rq ro r rA r} �all_parents_static�r ro r$ r$ r% r� � s zBlock.all_parents_staticc C s2 ddl m} | jrt| j|�r| jS | j�� S d S )Nr rn )rq ro r rA �get_first_parent_includer� r$ r$ r% r� � s z Block.get_first_parent_include)NNNNFF)NNNNFNN)FF)F)#rm � __module__� __qualname__r r r> r? r@ r r) r. r0 r1 � staticmethodr< r8 rE rR rT rU rX �_validate_rescuerY r3 rl ru rz r~ r� r� r� r� r� r� � __classcell__r$ r$ r" r% r " s> -& Ir ) � __future__r �ansible.constants� constantsr� �ansible.errorsr �ansible.playbook.attributer �ansible.playbook.baser � ansible.playbook.conditionalr �!ansible.playbook.collectionsearchr � ansible.playbook.delegatabler �ansible.playbook.helpersr �ansible.playbook.notifiabler �ansible.playbook.roler �ansible.playbook.taggabler �ansible.utils.sentinelr r r$ r$ r$ r% �<module> s
Save
Cancel