File manager - Edit - /opt/saltstack/salt/lib/python3.10/site-packages/salt/__pycache__/runner.cpython-310.pyc
Back
o ;j�6 � @ s� d Z ddlZddlZddlZddlZddlZddlZddlZddl Zddl Zddl m Z ddl mZ ddlmZ e�e�ZG dd� de je j�ZG dd � d e�ZdS ) z# Execute salt convenience routines � N)�mixins)�display_output)� verify_func s| e Zd ZdZdZdZddd�Zdd� Zd d � Zd d � Z e d d� �Z dd� Z dd� Z ddd�Z d� fdd� Z� ZS ) � RunnerClienta7 The interface used by the :command:`salt-run` CLI tool on the Salt Master It executes :ref:`runner modules <all-salt.runners>` which run on the Salt Master. Importing and using ``RunnerClient`` must be done on the same machine as the Salt Master and it must be done using the same user that the Salt Master is running as. Salt's :conf_master:`external_auth` can be used to authenticate calls. The eauth user must be authorized to execute runner modules: (``@runner``). Only the :py:meth:`master_call` below supports eauth. �runner�runNc C sl t jj| ||d� t jj| ||d� || _|pi | _d | _tjj � � | _ tjjj d| jd | jdd�| _d S )N��context�masterZsock_dirF)�opts�listen) r �SyncClientMixin�__init__�AsyncClientMixinr r �event�salt�utils�user�get_specific_userZ salt_user� get_event��selfr r � r �?/opt/saltstack/salt/lib/python3.10/site-packages/salt/runner.pyr ) s �zRunnerClient.__init__c C s� | j d ur | j �� d | _ t| d�r%| jd ur%t| jd�r"| j�� i | _t| d�r?| jd urAt| jd�r:| j�� i | _d S d S d S )N� _functions�destroyr )r r �hasattrr r �r r r r r 4 s �zRunnerClient.destroyc C s | S �Nr r r r r � __enter__A s zRunnerClient.__enter__c G s | � � d S r )r )r �argsr r r �__exit__D s zRunnerClient.__exit__c C sz t | d�s:t | d�stj�| j�| _ztjj| j| j| jd�| _W | jS ty9 tjj| j| jd�| _Y | jS w | jS )Nr r )r r r ) r r �loaderr r r r r �AttributeErrorr r r r � functionsG s � ��zRunnerClient.functionsc s� � � d�}t| j|� � fdd�dD �}tjjj� � dg �dd�\}}|�� � di �� |�� � g }|�|� |� t dd d i|��� tj j | j| |d d �\}}t d|||d �d �|��S )a� Format the low data for RunnerClient()'s master_call() function This also normalizes the following low data formats to a single, common low data structure. Old-style low: ``{'fun': 'jobs.lookup_jid', 'jid': '1234'}`` New-style: ``{'fun': 'jobs.lookup_jid', 'kwarg': {'jid': '1234'}}`` CLI-style: ``{'fun': 'jobs.lookup_jid', 'arg': ['jid="1234"']}`` �func s i | ] }|� v r|� � |��qS r )�pop)�.0�i��lowr r � <dictcomp>f s � z.RunnerClient._reformat_low.<locals>.<dictcomp>)�username�password�eauth�token�clientr �key�argF)Z condition�kwargZ __kwarg__T)Zignore_invalid)r3 r2 )r% r3 Nr ) r& r r$ r r r � parse_input�update�extend�append�dict�minion�load_args_and_kwargs) r r* r% Z eauth_credsZ_argZ_kwargZmungedr2 r3 r r) r � _reformat_lowX s � �zRunnerClient._reformat_lowc C s | � |�}tj�| |�S )a� Execute a runner function asynchronously; eauth is respected This function requires that :conf_master:`external_auth` is configured and the user is authorized to execute runner functions: (``@runner``). .. code-block:: python runner.cmd_async({ 'fun': 'jobs.list_jobs', 'username': 'saltdev', 'password': 'saltdev', 'eauth': 'pam', }) )r; r r � cmd_async)r r* �reformatted_lowr r r r< � s zRunnerClient.cmd_asyncFc C s | � |�}tj�| |||�S )a� Execute a runner function synchronously; eauth is respected This function requires that :conf_master:`external_auth` is configured and the user is authorized to execute runner functions: (``@runner``). .. code-block:: python runner.cmd_sync({ 'fun': 'jobs.list_jobs', 'username': 'saltdev', 'password': 'saltdev', 'eauth': 'pam', }) )r; r r �cmd_sync)r r* �timeout� full_returnr= r r r r> � s �zRunnerClient.cmd_syncTc s t � �||||||�S )a� Execute a function .. code-block:: python >>> opts = salt.config.master_config('/etc/salt/master') >>> runner = salt.runner.RunnerClient(opts) >>> runner.cmd('jobs.list_jobs', []) { '20131219215650131543': { 'Arguments': [300], 'Function': 'test.sleep', 'StartTime': '2013, Dec 19 21:56:50.131543', 'Target': '*', 'Target-type': 'glob', 'User': 'saltdev' }, '20131219215921857715': { 'Arguments': [300], 'Function': 'test.sleep', 'StartTime': '2013, Dec 19 21:59:21.857715', 'Target': '*', 'Target-type': 'glob', 'User': 'saltdev' }, } )�super�cmd)r r% r2 Zpub_datar3 Z print_eventr@ �� __class__r r rB � s %zRunnerClient.cmdr )NF)NNNTF)�__name__� __module__� __qualname__�__doc__r0 Z tag_prefixr r r r! �propertyr$ r; r< r> rB � __classcell__r r rC r r s& 2 �r c sD e Zd ZdZd � fdd� Z� fdd�Z� fdd�Zd d d �Z� ZS )�Runnerz+ Execute the salt runner interface Nc s8 t � j||d� tjj|| j|d�| _tj�|�| _d S )Nr )rA r r r" � returnersr$ � outputtersr rC r r r � s zRunner.__init__c sn t | d�r| jd urt | jd�r| j�� i | _t | d�r0| jd ur0t | jd�r-| j�� i | _t� �� d S )NrL r rM )r rL r rM rA r rC r r r � s zRunner.destroyc sL | j �dd�}t� �|�}t|�D ]}t|� d�d| j � t|| � qdS )z. Print out the documentation! r% N�:�text)r �getrA �get_docs�sortedr �print)r r2 Zdocsr% rC r r � print_docs� s �zRunner.print_docsFc C s� ddl }i }| j�dd�r| �� dS d| jd i}�za| j| j�d�d�}|d | _|jjj| jd | j�d g �d �}t | j |d � |j � | j |d |�\}}||d< ||d < | j�d �r�d | jv r�z-|jj �tj�| jd d�d��} |jj�| �� �|d< W d � n1 s�w Y W n ty� | jd |d < Y nw d |vr�d|vr�| jd r�ddl}|j�| j�} | �| jd �} | jd r�| r�| �| jd | �} | r�| �d d�|d < | s�t� d� |W S |� | � | jd |d < n|jj � � } |d dv �r |d |d d< | j�dd��r7| j�d ��r | � |�}n | j!| jd || |d�}t�"d|d � |d W S | j�d ��re| �#|�}t$|t%��r[t&|�dd hk�r[|d }|d }nd}t'||| j� n| j(| | j| jd || |d |d d|d � }W nw |j)j*�y� } zh|jj+j,d | jd �� }|j-d|� d | jd || jd!�d"| j� d#�d$� W d � n 1 �s�w Y d|v �r�| �.d%�/|d ��}nd}|�s�|� }| j�d&d��s�t'|d'| j� W Y d}~|S W Y d}~|S d}~ww t�0d(|� |S ))z- Execute the runner sequence r N�docFr% �jid)rV r2 �no_parse)rW r3 r. r/ Zcachedirz .root_key�rr1 Zmktoken� zAuthentication failed)zstate.orchestratez state.orchz state.slsZorchestration_jid�async)r Zpubz�Running in asynchronous mode. Results of this execution may be collected by attaching to the master event bus or by examining the master job cache, if configured. This execution is running under tag %s�tag�data� outputter) �instancer r% r* r r[ rV Z daemonizer@ r )r � )�success�return�retcoder% �fun_argsrV z salt/run/z/ret)r[ z{}*�quiet�nestedzRunner return: %s)1� salt.minionr rP rT Z_gen_async_pubrV r r r4 r r$ r9 r: �filesZfopen�os�path�joinZ stringutilsZ to_unicode�readline�OSErrorZ salt.authZauthZResolverZcliZ token_cli�log�errorr5 r r r< Z asynchronous�warningr> � isinstancer8 �setr Z_proc_function� exceptionsZ SaltExceptionr r Z fire_eventrQ �format�debug)r r@ r �retr* Z async_pubrc r �kwargsZfp_Zresolver�res�tokr r] �excZevtr r r r � s� �� � � �� � � �� �� � � � ��� z Runner.runr )F) rE rF rG rH r r rT r rJ r r rC r rK � s rK )rH �loggingrh Zsalt.exceptionsr Z salt.loaderrf Zsalt.utils.argsZsalt.utils.eventZsalt.utils.filesZsalt.utils.userZ salt.clientr Z salt.outputr Zsalt.utils.lazyr � getLoggerrE rm r r r rK r r r r �<module> s" F
| ver. 1.4 |
Github
|
.
| PHP 8.2.30 | Generation time: 0 |
proxy
|
phpinfo
|
Settings