File: //usr/lib/python3.9/site-packages/ansible/playbook/__pycache__/play.cpython-39.pyc
a
�)ge= � @ s d dl mZmZmZ eZd dlmZ d dlm Z d dl
m Z m Z d dl
mZ d dlmZ d dlmZmZmZ d dlmZ d d lmZ d d
lmZ d d lm Z d d l m Z m Z d d
l m!Z! d dl"m#Z# d dl$m%Z% d dl&m'Z' d dl(m)Z) e)� Z*dgZ+G dd� dee%e �Z,dS )� )�absolute_import�division�print_function)� constants)�context)�AnsibleParserError�AnsibleAssertionError)� to_native)� is_sequence)� binary_type� string_types� text_type)� NonInheritableFieldAttribute)�Base)�Block)�CollectionSearch)�load_list_of_blocks�load_list_of_roles)�Role)�Task)�Taggable)�preprocess_vars)�Display�Playc s� e Zd ZdZeddeddd�Zedddd�Zedd d
� edd �Zed e j
dd�Z ed
e j d�Z
ededd�Zededd�Zededd�Zededd�Zededd�Zededd�Zededd�Zede�d�dd�Zeddd�Zededd�Zed
e jdd�Z ed
dd�Z � fdd�Z dd� Z dd � Z d d � Z!e"dEd d ��Z#� fd!d"�Z$d#d$� Z%d%d&� Z&d'd(� Z'd)d*� Z(d+d,� Z)d-d.� Z*d/d0� Z+d1d2� Z,d3d4� Z-d5d6� Z.d7d8� Z/d9d:� Z0d;d<� Z1d=d>� Z2� fd?d@�Z3� fdAdB�Z4� fdCdD�Z5� Z6S )Fr z�
A play is a language feature that represents a list of roles and/or
task/handler blocks to execute on a given set of hosts.
Usage:
Play.load(datastructure) -> Play
Play.something(...)
�listT���)�isa�required�listof�always_post_validate�priority�boolN)r �defaultr c C s t jS �N)�CZDEFAULT_GATHER_SUBSET� r% r% �9/usr/lib/python3.9/site-packages/ansible/playbook/play.py�<lambda>@ � z
Play.<lambda>)r r" r r �int�string)r r" �c )r r" r F�Z ����force_handlers�percent)r r c sf t t| ��� d | _d | _g | _i | _ttj �
dg ��p>t d�| _ ttj �
dg ��| _
i | _i | _d S )N�tags)�all� skip_tags)�superr �__init__�_included_conditional�_included_pathZ_removed_hosts�
ROLE_CACHE�setr ZCLIARGS�get� frozensetZ only_tagsr2 �_action_groups�_group_actions��self�� __class__r% r& r4 Z s z
Play.__init__c C s | � � S r# )�get_namer= r% r% r& �__repr__h s z
Play.__repr__c C st d| j v rp|std��t|�rZ|D ]4}|d u r8td��q"t|ttf�s"tdj|d���q"nt|ttf�sptd��d S )N�hostsz6Hosts list cannot be empty. Please check your playbookzFHosts list cannot contain values of 'None'. Please check your playbookz5Hosts list contains an invalid host value: '{host!s}')�hostzDHosts list must be a sequence or string. Please check your playbook.)�_dsr r
�
isinstancer r
�format)r> Z attribute�name�value�entryr% r% r& �_validate_hostsk s
zPlay._validate_hostsc C s8 | j r | j S t| j�r&d�| j�| _ n | jp.d| _ | j S )z return the name of the Play �,� )rH r
rC �joinr= r% r% r& rA | s
z
Play.get_namec C s$ t � }|r|�� |_|j| ||d�S )N)�variable_manager�loader)r �copy�varsZ load_data)�datarO rP rR �pr% r% r& �load� s
z Play.loadc s\ t |t�s td|t|�f ��d|v rLd|v r:td|d��|d |d< |d= tt| ��|�S )zH
Adjusts play datastructure to cleanup old/legacy items
z?while preprocessing data (%s), ds should be a dict but was a %s�userZ remote_userzkboth 'user' and 'remote_user' are set for this play. The use of 'user' is deprecated, and should be removed��obj)rF �dictr �typer r3 r �preprocess_data)r> �dsr? r% r& r[ � s
� zPlay.preprocess_datac
C sX zt || | j| jd�W S tyR } z$tdt|� | j|d��W Y d}~n
d}~0 0 dS )��
Loads a list of blocks from a list which may be mixed tasks/blocks.
Bare tasks outside of a block are given an implicit block.
�r\ �playrO rP z9A malformed block was encountered while loading tasks: %s�rX Zorig_excN)r �_variable_manager�_loader�AssertionErrorr r rE �r> �attrr\ �er% r% r& � _load_tasks� s zPlay._load_tasksc
C sP zt || | j| jd�W S tyJ } z td| j|d��W Y d}~n
d}~0 0 dS )r] r^ z9A malformed block was encountered while loading pre_tasksr` N�r ra rb rc r rE rd r% r% r& �_load_pre_tasks� s zPlay._load_pre_tasksc
C sP zt || | j| jd�W S tyJ } z td| j|d��W Y d}~n
d}~0 0 dS )r] r^ z:A malformed block was encountered while loading post_tasksr` Nrh rd r% r% r& �_load_post_tasks� s zPlay._load_post_tasksc
C s` z&| j | jt|| d| j| jd�dd�W S tyZ } z td| j|d��W Y d}~n
d}~0 0 dS )z�
Loads a list of blocks from a list which may be mixed handlers/blocks.
Bare handlers outside of a block are given an implicit block.
T)r\ r_ Z use_handlersrO rP )Zprependz8A malformed block was encountered while loading handlersr` N)Z
_extend_value�handlersr ra rb rc r rE rd r% r% r& �_load_handlers� s �zPlay._load_handlersc
C s� |du r g }z t || | j| j| jd�}W n4 ty\ } z td| j|d��W Y d}~n
d}~0 0 g }|D ]}|�tj || d�� qf|| j
dd�< | j
S )z�
Loads and returns a list of RoleInclude objects from the datastructure
list of role definitions and creates the Role from those objects
N)r_ rO rP Zcollection_search_listz-A malformed role declaration was encountered.r` �r_ r ) r ra rb � collectionsrc r rE �appendr rU �roles)r> re r\ Z
role_includesrf rp Zrir% r% r& � _load_roles� s
�
&zPlay._load_rolesc C sb t |�}g }|d ur^|D ]D}d|vr0td|d��|D ] }|dvr4td| |d��q4|�|� q|S )NrH z6Invalid vars_prompt data structure, missing 'name' keyrW ) rH �promptr" ZprivateZconfirmZencryptZ salt_sizeZsaltZunsafez>Invalid vars_prompt data structure, found unsupported key '%s')r r ro )r> re r\ Znew_dsZ vars_promptsZ prompt_data�keyr% r% r& �_load_vars_prompt� s zPlay._load_vars_promptc C s< g }t | j�dkr8| jD ] }|jr$q|�|j| d�� q|S )a|
Handles the role compilation step, returning a flat list of tasks
with the lowest level dependencies first. For example, if a role R
has a dependency D1, which also has a dependency D2, the tasks from
D2 are merged first, followed by D1, and lastly by the tasks from
the parent role R last. This is done for all roles in the Play.
r rm )�lenrp � from_include�extend�compile�r> �
block_list�rr% r% r& �_compile_roles� s
zPlay._compile_rolesc C s< g }t | j�dkr8| jD ] }|jr$q|�|j| d�� q|S )z�
Handles the role handler compilation step, returning a flat list of Handlers
This is done for all roles in the Play.
r rm )ru rp rv rw Zget_handler_blocksry r% r% r& �compile_roles_handlers s
zPlay.compile_roles_handlersc C s@ t jddi| | j| jd�}|jD ]
}d|_q g }| jr�t� }d|_d|j d< d|_|�
| j� t | d�}| j pr|g|_|g|_ |�
|� | �� | j }t | d�}|p�|g|_|g|_ |�
|� t | d�}| jp�|g|_|g|_ |�
|� |S |�| j � |�
|� |�| �� � |�| j� |�
|� |�| j� |�
|� |S )z�
Compiles and returns the task list for this play, compiled from the
roles (which are themselves compiled recursively) and/or the list of
tasks specified in the play.
�metaZflush_handlers)rS r_ rO rP TZnoopZ _raw_paramsrm )r rU ra rb �blockZimplicitr. r �action�args�
set_loader� pre_tasks�alwaysro r| �tasks�
post_tasksrw )r> Z flush_block�taskrz Z noop_task�br� r% r% r& rx sJ
�
z Play.compilec C s
| j �� S r# )rR rQ r= r% r% r& �get_varsS s z
Play.get_varsc C s( | j d u rg S t| j t�s"| j gS | j S r# )�
vars_filesrF r r= r% r% r& �get_vars_filesV s
zPlay.get_vars_filesc C s | j d d � S r# )rk r= r% r% r& � get_handlers] s zPlay.get_handlersc C s | j d d � S r# )rp r= r% r% r& � get_roles` s zPlay.get_rolesc C sN g }| j | j | j D ]2}t|t�r>|�|j|j |j � q|�|� q|S r# ) r� r� r� rF r ro r Zrescuer� )r> Ztasklistr� r% r% r& � get_tasksc s
zPlay.get_tasksc sX t t| ��� }g }| �� D ]}|�|�� � q||d< | j|d< | j|d< | j|d< |S )Nrp �
included_path�
action_groups�
group_actions)r3 r � serializer� ro r6 r; r< )r> rS rp �roler? r% r& r� l s
zPlay.serializec s� t t| ��|� |�dd �| _|�di �| _|�di �| _d|v r�|�dg �}g }|D ] }t� }|�|� |�|� qVt | d|� |d= d S )Nr� r� r� rp )
r3 r � deserializer9 r6 r; r< r ro �setattr)r> rS Z role_datarp r� r{ r? r% r& r� y s
zPlay.deserializec s> t t| ��� }| j�� |_| j|_| j|_| j|_| j|_|S r# )r3 r rQ r7 r5 r6 r; r< )r> Znew_mer? r% r& rQ � s z Play.copy)NNN)7�__name__�
__module__� __qualname__�__doc__r r rC Z gather_factsZ
gather_subsetr$ ZDEFAULT_GATHER_TIMEOUTZgather_timeoutZDEFAULT_FACT_PATHZ fact_pathr r� Z vars_promptrp rk r� r� r� r Zcliargs_deferred_getr. Zmax_fail_percentage�serialZDEFAULT_STRATEGYZstrategy�orderr4 rB rK rA � staticmethodrU r[ rg ri rj rl rq rt r| r} rx r� r� r� r� r� r� r� rQ �
__classcell__r% r% r? r& r - sT
8
N)-Z
__future__r r r rZ Z
__metaclass__Zansibler r$ r Zansible.errorsr r Zansible.module_utils._textr Z'ansible.module_utils.common.collectionsr
Zansible.module_utils.sixr r r
Zansible.playbook.attributer Zansible.playbook.baser Zansible.playbook.blockr Z!ansible.playbook.collectionsearchr Zansible.playbook.helpersr r Zansible.playbook.roler Zansible.playbook.taskr Zansible.playbook.taggabler Zansible.vars.managerr Zansible.utils.displayr Zdisplay�__all__r r% r% r% r& �<module> s(