File manager - Edit - /opt/saltstack/salt/lib/python3.10/site-packages/salt/client/ssh/wrapper/__pycache__/saltcheck.cpython-310.pyc
Back
o ;j� � @ s� d Z ddlZddlZddlZddlZddlZddlmZ ddlZ ddl Z ddl Z ddl Z e� e�Zd dd�Zd dd �Zd d d �ZdS )zL Wrap the saltcheck module to copy files to ssh minion before running tests � N)�closing�basec s. t d }tj�|d|��t�� � tjj� � }tj � t ���=}tjj � td � �}tj�� d�}tjj�|d�� }|�|� W d � n1 sGw Y g }tjj�| �} | D ]�} tj�� | d �} tjj � td | ��} tjj�| d�� }|�| � W d � n1 s�w Y | �d tj�} | |v r�t�d | � qWtj�� | d �} t�d | � � tjj�| |�}|�|� |�}|r� �fd d�|D �}tjj � |�}tjj�| d�� }|�|� W d � n1 s�w Y |�| � qWtj�| �} tj�� | d �} | |v �r t�d | � qWtjj�| |�}|�|� |�}|�rR� �fdd�|D �}tjj � |�}tjj�| d�� }|�|� W d � n 1 �sHw Y |�| � qWW d � n 1 �s^w Y zt� � }W n t �yu d}Y nw t� � � t t �!|d���2}tjj�"� �D ]"\}}}|D ]}tj�||�}|�#|t$� �d� �%tj�� �q��q�W d � n 1 �s�w Y |�r�t� |� t&�'� � tj(j)j*t dfi tj+��}t d }|j,�-||�}zt�.|� W n t �y� Y nw tj�|tj�/|��}td ��}td d|�d�}td |�}|S )z� Replace standard saltcheck version with similar logic but replacing cp.cache_dir with generating files, tar'ing them up, copying tarball to remote host, extracting tar to state cache directory, and cleanup of files Zcachedir�fileszcp.list_statesz cp_output.txt�wNz.lowzstate.show_low_sls�.zAlready cached state for %sz.copyzcopying %s to %sc � g | ]}|� � ���qS � ��replace��.0�dir�ZgendirZ state_cacher �U/opt/saltstack/salt/lib/python3.10/site-packages/salt/client/ssh/wrapper/saltcheck.py� <listcomp>> � �z'update_master_cache.<locals>.<listcomp>c r r r r r r r r Q r zw:gz� �thin_dirz file.mkdirz archive.tarZxf)�destz file.remove)0Z__opts__�os�path�join�tempfileZmkdtemp�salt�utilsr ZmkstempZ fileclientZget_file_client�json�dumps�__salt__Zfopen�write�argsZ split_inputr �sep�log�debug�url�createZget_dir�append�dirname�getcwd�OSError�chdirr �tarfile�openZos_walk�add�len�lstrip�shutil�rmtree�clientZssh�Single�kwargs�shell�send�remove�basename) �states�saltenv�cacheZ trans_tarZ cp_fileclientZ cp_outputZcp_output_file�fpZalready_processedZsls_listZ state_nameZstate_low_fileZstate_low_outputZfile_copy_fileZqualified_nameZ copy_resultZcopy_result_output�cwdZtfp�root�dirsr �name�fullZsingler �retZtar_pathr r r �update_master_cache s� � � � � � � � � �� �: � "�� � � rB Fc C s t | |�}td | ||d�}|S )z� Define common functions to activite this wrapping module and tar copy. After file copies are finished, run the usual local saltcheck function z saltcheck.run_state_tests_ssh)r9 � check_all)rB r )r8 r9 rC rA r r r �run_state_tests~ s �rD c C s( t d � �| �}d�|�}t|| �}|S )z_ Lookup top files for minion, pass results to wrapped run_state_tests for copy and run zstate.show_top�,)r �getr rD )r9 Z top_statesZ state_stringrA r r r �run_highstate_tests� s rG )r )r F)�__doc__�loggingr r/ r* r � contextlibr Zsalt.fileclientr Zsalt.utils.filesZsalt.utils.jsonZsalt.utils.url� getLogger�__name__r! rB rD rG r r r r �<module> s j
| ver. 1.4 |
Github
|
.
| PHP 8.2.30 | Generation time: 0 |
proxy
|
phpinfo
|
Settings