Dashboard
PHP:
8.2.30
OS:
Linux
User:
dh_nv8b2m
/
/
usr
/
local
/
lib
/
python3.10
/
dist-packages
/
ansible
/
vars
/
__pycache__
📤 Upload
📝 New File
📁 New Folder
Close
Editing: manager.cpython-310.pyc
o O�hח � @ sp d dl mZ d dlZd dlZd dlmZ d dlmZmZm Z d dl m Z d dl m Z d dlmZ d dlmZmZmZmZmZmZ d d lmZ d d lmZm Z d d l m 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+ d dl,m-Z-m.Z.m/Z/ d dl0m1Z1 d dl2m3Z3m4Z4 d dl5m6Z6m7Z7 d dl8m9Z9 e)� Z:dd� Z;G dd� d�Z<G dd � d e�Z=dS ) � )� annotationsN)� defaultdict)�Mapping�MutableMapping�Sequence)�sha1)�UndefinedError)� constants)� AnsibleError�AnsibleParserError�AnsibleUndefinedVariable�AnsibleFileNotFound�AnsibleAssertionError�AnsibleTemplateError)�Host)� sort_groups�get_group_vars)�to_text)� text_type� string_types)� lookup_loader)� FactCache)�Templar)�Display)�listify_lookup_plugin_terms)� combine_vars�load_extra_vars�load_options_vars)�wrap_var)�namespace_facts� clean_facts)� get_vars_from_inventory_sources�get_vars_from_path)�warn_if_reservedc C sN | du rdS t | t�s| g}n| }|D ]}t |t�s$td| t| �f ��q|S )z� Ensures that vars contained in the parameter passed in are returned as a list of dictionaries, to ensure for instance that vars loaded from a file conform to an expected state. Nzevariable files must contain either a dictionary of variables, or a list of dictionaries. Got: %s (%s))� isinstance�listr r �type)�a�data�item� r* �?/usr/local/lib/python3.10/dist-packages/ansible/vars/manager.py�preprocess_vars1 s �r, c @ s� e Zd Zeg d��Zd dd�Zdd� Zdd� Zed d � �Z d d � Z d!dd�Z d"dd�Z dd� Z dd� Zdd� Zdd� Zd d � Zd d � ZdS )#�VariableManager)�plugins_by_group�groups_plugins_play�groups_plugins_inventory�groups_inventory�all_plugins_play�all_plugins_inventory� all_inventoryNc C s� t t�| _t t�| _t t�| _t t�| _t t�| _|| _|| _d | _ dt t � d��� � | _t|�| _| j�dd�}t|du p@|�| _t| jd�| _zt� | _W d S tyn } zt�t|�� i | _W Y d }~d S d }~ww )N�__omit_place_holder__%s�@ �basedirF��loader)r �dict�_nonpersistent_fact_cache� _vars_cache� _extra_vars�_host_vars_files�_group_vars_files� _inventory�_loader� _hostvarsr �os�urandom� hexdigest� _omit_tokenr � _options_vars�get�bool� safe_basedirr r � _fact_cacher �display�warningr )�selfr9 � inventory� version_infor7 �er* r* r+ �__init__K s( ��zVariableManager.__init__c C s4 t | j| j| j| j| j| j| j| j| j | j d� }|S )N) � fact_cache� np_fact_cache� vars_cache� extra_vars�host_vars_files�group_vars_files� omit_token� options_varsrO rJ ) r: rK r; r< r= r> r? rF rG r@ rJ �rN r( r* r* r+ � __getstate__i s � z VariableManager.__getstate__c C s� |� dtt��| _|� dtt��| _|� dtt��| _|� dt� �| _|� dtt��| _|� dtt��| _|� ddt t � d ��� � �| _ |� d d �| _|� d t� �| _|� d d �| _d | _d | _d S )NrS rT rU rV rW rX rY r5 r6 rO rZ rJ F)rH r r: rK r; r< r= r> r? r rC rD rE rF r@ rG rJ rA rB r[ r* r* r+ � __setstate__x s z VariableManager.__setstate__c C s | j S �N)r= �rN r* r* r+ rV � s zVariableManager.extra_varsc C s || _ d S r^ )r@ )rN rO r* r* r+ � set_inventory� � z VariableManager.set_inventoryTF�taskc ! s t �d� t� } �j||||||d�} i ��fdd�� g ��jr&�j�� g�|r<|jD ]} | jr;� | | � � d| j �} q+|rt j dkrH|� � �nt j dv rU|� � d g�n t j d kratd t j ��|jd ur|sn|jt jv r� | |jj |�� d �d|jj �} |�r^�jj�d��td d� |�� D ����fdd�} ��fdd��� ���fdd���fdd�}��fdd�}��fdd�}�fdd �}��fd d �}��fd d �}� ���fd!d"�}t jD ]%}|�jv r�t �d#||j f � � | t� | � d$| �} q�t �d%| � qވ | |� � d&| �} � | �|g�d'| �} � | �|g�d(| �} z/t �j �|j i ��}| t |�O } t j �rD� | t t!|��d)�} n� | t d*|�d*i �i�d)�} W n t"�y] Y nw |�r]� | |� � d+�} |�#� }z�|D ]�}t$| �j%�}t$|| �}t&�j|d,�}|}t'|t(��s�|g}zd|D ]S} |�)| �} t'| t*��s�td-| ��z-|� � } �j�+| d.| �} t,�jj-| d/d0d1��} | d u�r�| D ] } � | | d2| �} �q�W n t.�y� Y �q� t/�y� � w |�r�|�r�t.d3| ��W n3 t0t1f�y& |d u�r �j �|j t� ��d4��r |d u�r t1d5| |d6��t �2d7| � Y �qpw t �2d8| � �qpW n t3�yC t/d9|t4|�f ��w |jD ]} | j�r[� | | j d:d/d;�d<| j �} �qG|�r|j�rw� | |jj |�� d:d:d;�d=|jj �} � | |� � d>�} |�r�� | �j5�|�6� t� �d?�} � | �j7�|j t� �d@�} |�r�|j�r�� | |j�8|�� �dA�} � | |�9� dB�} � | �j%dC�} t:| �;� � � | | dD�} |�r�|j<| dE< |�s�|�r�| �=� | d.< |�r�|�r�|j>d u�r�|�r���?||| �\| dF< | dG< t �dH� t j@�r tA�B| ��S | S )Ian Returns the variables, with optional "context" given via the parameters for the play, host, and task (which could possibly result in different sets of variables being returned due to the additional context). The order of precedence is: - play->roles->get_default_vars (if there is a play context) - group_vars_files[host] (if there is a host context) - host_vars_files[host] (if there is a host context) - host->get_vars (if there is a host context) - fact_cache[host] (if there is a host context) - play vars (if there is a play context) - play vars_files (if there's no host context, ignore file names that cannot be templated) - task->get_vars (if there is a task context) - vars_cache[host] (if there is a host context) - extra vars ``_hosts`` and ``_hosts_all`` should be considered private args, with only internal trusted callers relying on the functionality they provide. These arguments may be removed at a later date without a deprecation period and without warning. z in VariableManager get_vars())�play�hostrb �include_hostvars�_hosts� _hosts_allc s. |i kr| S t jr|D ]}|� |< q t| |�S )z� Wrapper function to update var sources dict and call combine_vars() See notes in the VarsWithSources docstring for caveats and limitations of the source tracking )�C� DEFAULT_DEBUGr )r( �new_data�source�key)� _vars_sourcesr* r+ �_combine_and_track� s z4VariableManager.get_vars.<locals>._combine_and_trackzrole '%s' defaults�all)�bottom� playbook_dirr �topz Unknown playbook vars logic: %sN)� dep_chainc S s g | ] }|j d vr|�qS ))ro ��name)�.0�gr* r* r+ � <listcomp>� � z,VariableManager.get_vars.<locals>.<listcomp>c s� i }z | � � j||�}W |S tyT z |D ]}t|t�r'|| �|j�O }q|| �|j�O }qW Y |S tyS t| d�rIt d| j | j f ��t d| j | j f ��w w )N�runz)Cannot use v1 type vars plugin %s from %sz Invalid vars plugin %s from %s) �get_varsrA �AttributeErrorr$ r � get_host_varsru r �hasattrr � _load_name�_original_path)�plugin�path�entitiesr( �entityr_ r* r+ �_get_plugin_vars� s$ � � � ��z2VariableManager.get_vars.<locals>._get_plugin_varsc s t � j� jj| ��S )z) merges all entities by inventory source )r! rA r@ �_sources)r� )rN �stager* r+ �_plugins_inventory� s z4VariableManager.get_vars.<locals>._plugins_inventoryc s. i }�D ]}� |t �j|| ��d| �}q|S )z& merges all entities adjacent to play z path '%s')r" rA )r� r( r� )rn �basedirsrN r� r* r+ � _plugins_play� s z/VariableManager.get_vars.<locals>._plugins_playc s � � � S r^ )r{ r* )� all_groupr* r+ r4 s z/VariableManager.get_vars.<locals>.all_inventoryc � � �g�S r^ r* r* )r� r� r* r+ r3 ra z7VariableManager.get_vars.<locals>.all_plugins_inventoryc r� r^ r* r* )r� r� r* r+ r2 ra z2VariableManager.get_vars.<locals>.all_plugins_playc s t � �S )z gets group vars from inventory )r r* )� host_groupsr* r+ r1 � z2VariableManager.get_vars.<locals>.groups_inventoryc � � ��S )z/ gets plugin sources from inventory for groups r* r* )r� r� r* r+ r0 r� z:VariableManager.get_vars.<locals>.groups_plugins_inventoryc r� )z* gets plugin sources from play for groups r* r* )r� r� r* r+ r/ r� z5VariableManager.get_vars.<locals>.groups_plugins_playc sJ i } �D ] }� | | �|�d| �| |< � | | �|�d| �| |< q| S )z� merges all plugin sources by group, This should be used instead, NOT in combination with the other groups_plugins* functions z inventory group_vars for '%s'z playbook group_vars for '%s'r* )r( �group)rn r� r� r� r* r+ �plugins_by_groups s z3VariableManager.get_vars.<locals>.plugins_by_groupsz Calling %s to load vars for %sz!group vars, precedence entry '%s'z.Ignoring unknown variable precedence entry: %szhost vars for '%s'z inventory host_vars for '%s'zplaybook host_vars for '%s'�facts� ansible_localz play vars�r9 � variablesz�Invalid vars_files entry found: %r vars_files entries should be either a string type or a list of string types after template expansion�varsT�vaulted)�unsafe�cachezplay vars_files from '%s'zvars file %s was not found� module_setupzTan undefined variable was found when attempting to template the vars_files item '%s')�objz4skipping vars_file '%s' due to an undefined variablezRead vars_file '%s'zXError while reading vars files - please supply a list of file names. Got '%s' of type %sF)�include_params� only_exportszrole '%s' exported varszrole '%s' all varsz task vars� include_vars�set_factz role paramszinclude paramsz extra varsz magic vars� environment�ansible_delegated_vars�_ansible_loop_cachezdone with get_vars())CrL �debugr: �_get_magic_variablesrJ rA � get_basedir�roles�public�get_default_varsru rh �PLAYBOOK_VARS_ROOT�get_search_pathr �_role�action�_ACTION_INCLUDE_ROLE� get_dep_chainr@ �groupsrH r � get_groups�VARIABLE_PRECEDENCE�_ALLOWED�localsrM r{ r rK r �INJECT_FACTS_AS_VARSr �KeyError�get_vars_filesr r= r r$ r% �templater �path_dwim_relative_stackr, �load_from_filer r r r �vvv� TypeErrorr& r< �get_namer; �get_role_params�get_include_paramsr# �keysr� �copy� delegate_to�_get_delegated_varsri �VarsWithSources�new_vars_with_sources)!rN rc rd rb re �include_delegate_to� use_cacherf rg r� �all_vars�magic_variables�roler� r4 r3 r2 r1 r0 r/ r� �entryr� � vars_files�vars_file_item� temp_vars�templar�vars_file_list� vars_file�play_search_stack� found_filer( r) r* ) rn r� r� rm r� r� r� rN r� r+ r{ � s � � " �� �� � �.��� �: �� � � zVariableManager.get_varsc s� i }t j�| j�� �|d< tj|d< tj|d< � rIt dd� � j D ��}dd� � j D �} t t || ��|d< | |d < ||d < |d |d < � � � |d < |rr|j rr|j j d d�|d< |j j|d< t|j j�|d< |j j|d< |j � � |d< | jdur�| j�� |d< � r�t| jd�} � js�| �� j�r�d} n� jp�d} |s�dd� | jj| dd�D �}|s�dd� | j�� D �}|dd� |d < � fd d�|d D �|d < � fd d�|D �|d < |d |d!< | j|d"< | j�� D ]\} } | || < q�| j dur�|r�| j |d#< |S )$z� Returns a dictionary of so-called "magic" variables in Ansible, which are special variables we set internally for use. rq �ansible_playbook_python�ansible_config_filec S s" h | ] }|� � D ]}|�� �qqS r* )�get_all_dependenciesr� )rv �r�dr* r* r+ � <setcomp>� s " z7VariableManager._get_magic_variables.<locals>.<setcomp>c S s g | ]}|� � �qS r* )r� )rv r� r* r* r+ rx � s z8VariableManager._get_magic_variables.<locals>.<listcomp>�ansible_role_names�ansible_play_role_names� ansible_dependent_role_names� role_names�ansible_play_nameF)�include_role_fqcn� role_name� role_path� role_uuid�ansible_collection_name�ansible_role_nameNr� r8 ro c S � g | ]}|j �qS r* rt �rv �hr* r* r+ rx � � T)�pattern�ignore_restrictionsc S r� r* rt r� r* r* r+ rx � r� �ansible_play_hosts_allc � g | ] }|� j vr|�qS r* ��_removed_hosts�rv �x�rc r* r+ rx � ry �ansible_play_hostsc r� r* r� r� r� r* r+ rx � ry �ansible_play_batch� play_hosts�omit�hostvars) rC r� �abspathrA r� �sys� executablerh � CONFIG_FILEr% r� �setr� r� � _role_pathr �_uuid�_role_collectionr@ �get_groups_dictr � finalized� is_template�hosts� get_hostsrF rG �itemsrB )rN rc rd rb re rf rg r� �dependency_role_names�play_role_namesr� r� �option� option_valuer* r� r+ r� � sP z$VariableManager._get_magic_variablesc C s� i }d}|j r[|j|j dd�}|| jkr[|s td|j ��| j�|�}|du r@| jjddd�D ] }|j|kr:|} nq/t|d�}|| j |� � ||ddd�i|d < |� d �|d | d < ||fS ) z�Get the delegated_vars for an individual task invocation, which may be in the context of an individual loop iteration. Not used directly be VariableManager, but used primarily within TaskExecutor NF��fail_on_undefinedz.Empty hostname produced from delegate_to: "%s"T�� ignore_limitsr� rt �rc rd rb r� re r� �inventory_hostname) r� r� rF r r@ �get_hostr �addressr r{ �get_playrH )rN r� rb r� �delegated_vars�delegated_host_name�delegated_hostr� r* r* r+ � get_delegated_vars_and_hostname s2 � �� z/VariableManager.get_delegated_vars_and_hostnamec s� t |d�s i d fS tjddd� |�� }|�� |d< | j�� |d vr-|d �| j�� � t| j|d�� g }d}|j d ur�|j t v r�d}|j dkrKd }z=t |j � |d d �}|s`� fd d �|D �}t j |j | j� d �} dD ] } | |jv ru nqlt| d| d � t| j||d��}W n2 ty� d g}Y n'w td|j ��|j d ur�z� �|j �}W n ty� d g}Y nw d }d g}t� } t|jdd�} d } |D ]�}|d ur�||| < |� _� j|jd d�}||jkr�d} |d u r�td|jd��t|t ��stdt |� |jd��|| v �rq�d }| j d u�r6| j � |�}|d u �r5| j j ddd�D ] }|j!|k�r.|} n�q"t"|d�}nt"|d�}| j#|||d dd�| |< |� d �| | d < q�d }|�r[| �r[|}| |fS ) N�loopzcGetting delegated variables via get_vars is no longer used, and is handled within the TaskExecutor.z2.18)�version�ansible_search_pathr� T� first_foundF)�termsr� r � convert_barec s g | ] }� � |�s|�qS r* )r )rv �t�r� r* r+ rx [ ry z7VariableManager._get_delegated_vars.<locals>.<listcomp>)r9 r� )r� �var�file�_subdir�s)r r� zDFailed to find the lookup named '%s' in the available lookup plugins�loop_varr) r z$Undefined delegate_to host for task:)�messager� z^the field 'delegate_to' has an invalid type (%s), and could not be converted to a string type.r rt r r )$r~ rL � deprecatedr� r� rA r� �appendr � loop_withr r r rH r� �setattrr rz r r r� r: �getattr� loop_control�available_variablesr� �_dsr$ r r& r@ r r r r r{ )rN rc rb �existing_variables� vars_copyr �has_loop�fail� loop_terms�mylookup�subdir�delegated_host_vars�item_var� cache_itemsr) r r r� r� r* r r+ r� 1 s� � � � � �� � � � z#VariableManager._get_delegated_varsc C s | j �|d� dS )z- Clears the facts for a host N)rK �pop)rN �hostnamer* r* r+ � clear_facts� s zVariableManager.clear_factsc C s� t |t�s tdt|� ��t|�� � z| j| }W n ty% |}Y nw t |t�s5t d� |t|����||O }|| j|< dS )�O Sets or updates the given facts for a host in the fact cache. zIthe type of 'facts' to set for host_facts should be a Mapping but is a %szCThe object retrieved for {0} must be a MutableMapping but was a {1}N) r$ r r r& r# r� rK r� r r� �format)rN rd r� � host_cacher* r* r+ �set_host_facts� s � �z VariableManager.set_host_factsc C s^ t |t�s tdt|� ��t|�� � z | j| |O < W dS ty. || j|< Y dS w )r8 zRthe type of 'facts' to set for nonpersistent_facts should be a Mapping but is a %sN)r$ r r r& r# r� r; r� )rN rd r� r* r* r+ �set_nonpersistent_facts� s �z'VariableManager.set_nonpersistent_factsc C s| t |g� || jvrt� | j|< || j| v r5t| j| | t�r5t|t�r5t| j| ||i�| j|< dS || j| |< dS )z< Sets a value in the vars_cache for a host. N)r# r< r: r$ r r )rN rd �varname�valuer* r* r+ �set_host_variable� s , z!VariableManager.set_host_variable)NNN) NNNTFTNNrb )NN)�__name__� __module__� __qualname__� frozensetr� rR r\ r] �propertyrV r` r{ r� r r� r7 r; r< r? r* r* r* r+ r- F s* � 6G) r- c @ s| e Zd ZdZdd� Zedd� �Zdd� Zdd � Zd d � Z d d � Z dd� Z dd� Z dd� Z dd� Zdd� Zdd� Zdd� Zd S ) r� a" Dict-like class for vars that also provides source information for each var This class can only store the source for top-level vars. It does no tracking on its own, just shows a debug message with the information that it is provided when a particular var is accessed. c O s t |i |��| _i | _dS )z Dict-compatible constructor N)r: r( �sources)rN �args�kwargsr* r* r+ rR � s zVarsWithSources.__init__c C s | |�}||_ |S )z@ Alternate constructor method to instantiate class with sources )rE )�clsr( rE �vr* r* r+ r� � s z%VarsWithSources.new_vars_with_sourcesc C s | j �|d �S r^ )rE rH �rN rl r* r* r+ � get_source � zVarsWithSources.get_sourcec C s* | j | }t�d|| j�|d�f � |S )Nz variable '%s' from source: %s�unknown)r( rL r� rE rH )rN rl �valr* r* r+ � __getitem__ s zVarsWithSources.__getitem__c C s || j |< d S r^ �r( )rN rl r> r* r* r+ � __setitem__ rL zVarsWithSources.__setitem__c C s | j |= d S r^ rP rJ r* r* r+ � __delitem__ � zVarsWithSources.__delitem__c C � t | j�S r^ )�iterr( r_ r* r* r+ �__iter__ ra zVarsWithSources.__iter__c C rT r^ )�lenr( r_ r* r* r+ �__len__ ra zVarsWithSources.__len__c C s | j �|�S r^ )r( � __contains__rJ r* r* r+ rY rS z VarsWithSources.__contains__c C s t �| j�� | j�� �S r^ )r� r� r( r� rE r_ r* r* r+ r� s zVarsWithSources.copyc C s& t |t�r| j�� }|�|� |S tS r^ )r$ r r( r� �update�NotImplemented�rN �other�cr* r* r+ �__or__" s zVarsWithSources.__or__c C s0 t |t�r| �� }|�|� |�| j� |S tS r^ )r$ r � __class__rZ r( r[ r\ r* r* r+ �__ror__) s zVarsWithSources.__ror__c C s | j �|� | j S r^ )r( rZ )rN r] r* r* r+ �__ior__1 s zVarsWithSources.__ior__N)r@ rA rB �__doc__rR � classmethodr� rK rO rQ rR rV rX rY r� r_ ra rb r* r* r* r+ r� � s r� )>� __future__r rC r� � collectionsr �collections.abcr r r �hashlibr �jinja2.exceptionsr �ansibler rh �ansible.errorsr r r r r r �ansible.inventory.hostr �ansible.inventory.helpersr r �+ansible.module_utils.common.text.convertersr �ansible.module_utils.sixr r �ansible.plugins.loaderr �ansible.vars.fact_cacher �ansible.templater �ansible.utils.displayr �ansible.utils.listifyr �ansible.utils.varsr r r �ansible.utils.unsafe_proxyr �ansible.vars.cleanr r �ansible.vars.pluginsr! r" �ansible.vars.reservedr# rL r, r- r� r* r* r* r+ �<module> s@ 1
Save
Cancel