File manager - Edit - /opt/saltstack/salt/lib/python3.10/site-packages/salt/runners/__pycache__/jobs.cpython-310.pyc
Back
o ;j�G � @ s< d Z ddlZddlZddlZddlZddlZddlZddlZddl Zddl Zddl Zddl Zddl mZ z ddlmZ dZW n eyI dZY nw e�e�Zdd� Zd dd �Z d!d d �Zd"d d �Z d#dd�Z d$dd�Z d%dd�Z d%dd�Z d&dd�Z dd� Z dd� Z!d d � Z"d d d �Z#dS )'zB A convenience system to manage jobs, both active and already run � N)�SaltClientErrorTFc C s t jj�t�S )z� Return the actively executing runners for the master CLI Example: .. code-block:: bash salt-run jobs.master )�salt�utils�masterZget_running_jobs�__opts__� r r �E/opt/saltstack/salt/lib/python3.10/site-packages/salt/runners/jobs.pyr s r c C s� i }t j�td ��4}z |jddtd d�}W n ty6 } zt|� |W Y d}~W d � S d}~ww W d � n1 sAw Y | rWt�dd� t |� � ��id � |� � D ]P\}}| rlt�dd |� �id � t |t �srq[|D ]6}|d |vr�t|d |�||d < ||d �||�d d�igg d �� qt||d d �||d i� qtq[t j�t�}|D ].} ttd td f�} |j| � d� | �}|r�|D ]}||| d vr�|| d �|� q�q�|S )z� Return a report on all actively running jobs from a job id centric perspective CLI Example: .. code-block:: bash salt-run jobs.active Z conf_file�*zsaltutil.running�timeout)r N�messagez!Attempting to contact minions: {}�progresszReceived reply from minion �jid�pid)�Running�Returnedr � ext_job_cache�master_job_cache�.get_jidr )r �clientZget_local_clientr �cmdr �print� __jid_event__� fire_event�format�list�keys�items� isinstance�_format_jid_instance�update�get�append�minion� MasterMinion� _get_returner� returners) �display_progress�retr Zactive_Z client_errorr" �data�job�mminionr �returnerr r r �active* s^ ��� � ���� � � ��r, c s. i }t j�t�}ttd |td f�}z t| ||d�}W n ty& Y dS w |�dg �} |�di �� � ra� D ])} |rCt� d| id� d � | v rU|rT� | �d �|| < q7|r`� | �d �|| < q7|rs� fd d �| D �D ]} d || < qlz � t t � �� �d �} W n t t fy� d} Y nw | r�| |d�S |S )a� Return the printout from a previously executed job jid The jid to look up. ext_source The external job cache to use. Default: `None`. returned : True If ``True``, include the minions that did return from the command. .. versionadded:: 2015.8.0 missing : False If ``True``, include the minions that did *not* return from the command. display_progress : False If ``True``, fire progress events. .. versionadded:: 2015.5.0 CLI Example: .. code-block:: bash salt-run jobs.lookup_jid 20130916125524463507 salt-run jobs.lookup_jid 20130916125524463507 --out=highstate r r )� ext_sourcer& zCRequested returner could not be loaded. No JIDs could be retrieved.�Minions�Resultr r �returnc 3 s � | ] }|� vr|V qd S �Nr )�.0�x��returnsr r � <genexpr>� s � z lookup_jid.<locals>.<genexpr>zMinion did not return�outN�� outputterr( )r r" r# r r$ �list_job� TypeErrorr r r �next�iter� StopIteration�AttributeError) r r- Zreturned�missingr& r' r* r+ r( Ztargeted_minionsr" Z minion_idr9 r r4 r � lookup_jidd sD ! � � �� � rA c C s� d| i}t j�t�}ttd |td f�}|r"t�dd|� �id� |j|� d� | �}|�t | |�� |j|� d� | �|d < d � td �}t� d �r^||jv r^|j| | �}|r^||d < |S ) a� List a specific job given by its jid ext_source If provided, specifies which external job cache to use. display_progress : False If ``True``, fire progress events. .. versionadded:: 2015.8.8 CLI Example: .. code-block:: bash salt-run jobs.list_job 20130916125524463507 salt-run jobs.list_job 20130916125524463507 --out=pprint r r r r zQuerying returner: r � .get_loadr r/ �{}.get_endtime�job_cache_store_endtime�EndTime) r r" r# r r$ r r r% r r r r ) r r- r& r' r* r+ r) �fstr�endtimer r r r: � s$ ��r: c C s t td | td f�}|rt�dd|� d�id� tj�t�} | j|� d� � } i } | D ]�} d} |r`d } d | | v r`t|t �r[|D ]}|| | d v rY| | d | || krYd} qAnt � d � |r�| r�d } d | | v r�| | d }t|t �rz|g}|D ]}tj j�|�D ] }t�||�r�d} q�q||r�| r�d } d | | v r�tj j�|�D ]}t�| | d |�r�d} q�|r�| r�d } tr�t�|�}t�| | d �}||kr�d} nt �d� |r�| r�d } tr�t�|�}t�| | d �}||kr�d} nt �d� | r�| | | | < q,|�r|| d�S | S )a� List all detectable jobs and associated functions ext_source If provided, specifies which external job cache to use. **FILTER OPTIONS** .. note:: If more than one of the below options are used, only jobs which match *all* of the filters will be returned. search_metadata Specify a dictionary to match to the job's metadata. If any of the key-value pairs in this dictionary match, the job will be returned. Example: .. code-block:: bash salt-run jobs.list_jobs search_metadata='{"foo": "bar", "baz": "qux"}' search_function Can be passed as a string or a list. Returns jobs which match the specified function. Globbing is allowed. Example: .. code-block:: bash salt-run jobs.list_jobs search_function='test.*' salt-run jobs.list_jobs search_function='["test.*", "pkg.install"]' .. versionchanged:: 2015.8.8 Multiple targets can now also be passed as a comma-separated list. For example: .. code-block:: bash salt-run jobs.list_jobs search_function='test.*,pkg.install' search_target Can be passed as a string or a list. Returns jobs which match the specified minion name. Globbing is allowed. Example: .. code-block:: bash salt-run jobs.list_jobs search_target='*.mydomain.tld' salt-run jobs.list_jobs search_target='["db*", "myminion"]' .. versionchanged:: 2015.8.8 Multiple targets can now also be passed as a comma-separated list. For example: .. code-block:: bash salt-run jobs.list_jobs search_target='db*,myminion' start_time Accepts any timestamp supported by the dateutil_ Python module (if this module is not installed, this argument will be ignored). Returns jobs which started after this timestamp. end_time Accepts any timestamp supported by the dateutil_ Python module (if this module is not installed, this argument will be ignored). Returns jobs which started before this timestamp. .. _dateutil: https://pypi.python.org/pypi/python-dateutil CLI Example: .. code-block:: bash salt-run jobs.list_jobs salt-run jobs.list_jobs search_function='test.*' search_target='localhost' search_metadata='{"bar": "foo"}' salt-run jobs.list_jobs start_time='2015, Mar 16 19:00' end_time='2015, Mar 18 22:00' r r r �Querying returner � for jobs.r z .get_jidsTF�MetadatazKThe search_metadata parameter must be specified as a dictionary. Ignoring.�Target�Function� StartTimezA'dateutil' library not available, skipping start_time comparison.z?'dateutil' library not available, skipping end_time comparison.r8 )r$ r r r r r" r# r% r �dict�log�info�strr �argsZ split_input�fnmatch�DATEUTIL_SUPPORT�dateutil_parser�parse�error)r- r9 �search_metadata�search_function� search_targetZ start_timeZend_timer& r+ r* r' Zmret�itemZ_match�key�targets�targetZparsed_start_timeZ _start_timeZparsed_end_timer r r � list_jobs� s� V�� ��� �� � �� �� � r_ c C s� t td |td f�}|rt�dd|� d�id� tj�t�}|� d�}||jvr1td|� d ���|j| | |�}|r@||d �S |S ) a List all detectable jobs and associated functions ext_source The external job cache to use. Default: `None`. CLI Example: .. code-block:: bash salt-run jobs.list_jobs_filter 50 salt-run jobs.list_jobs_filter 100 filter_find_job=False r r r rH rI r z.get_jids_filter�'z(' returner function not implemented yet.r8 ) r$ r r r r r" r# r% �NotImplementedError) �countZfilter_find_jobr- r9 r& r+ r* �funr' r r r �list_jobs_filter~ s �� rd c C s� i }t td |td f�}tj�t�}z|j|� d� | �}t| |�|| < W n ty: d�|�|| d< | Y S w |j|� d� | �|| d< d�td �}t� d�ri||jv ri|j| | �}|ri||| d < |S ) z� Print a specific job's detail given by its jid, including the return data. CLI Example: .. code-block:: bash salt-run jobs.print_job 20130916125524463507 r r rB z_Requested returner {} is not available. Jobs cannot be retrieved. Check master log for details.r/ r rC rD rE ) r$ r r r" r# r% r r; r r )r r- r' r+ r* r) rF rG r r r � print_job� s* � �� re c C s� t � }t| |d�}|�dg �}|�di �}|D ] }||v r0d|| v r0|| d r+dnd||< qd||< q|D ]}d|| v rI|| d rId||< q7|S )a Check if a job has been executed and exit successfully jid The jid to look up. ext_source The external job cache to use. Default: `None`. CLI Example: .. code-block:: bash salt-run jobs.exit_success 20160520145827701627 )r- r. r/ r0 TF)rN r: r )r r- r' r( Zminions�resultr" r r r � exit_success� s �rg c C sN |rt |t�st�d� dS t| |||||d�}|r%t|�d }t|| �S dS )aA .. versionadded:: 2015.8.0 List all detectable jobs and associated functions CLI Example: .. code-block:: bash salt-run jobs.last_run salt-run jobs.last_run target=nodename salt-run jobs.last_run function='cmd.run' salt-run jobs.last_run metadata="{'foo': 'bar'}" z8The metadata parameter must be specified as a dictionaryF)r- r9 rX rY rZ r& ���)r rN rO rP r_ �sortedre )r- r9 �metadata�functionr^ r& Z _all_jobsZlast_jobr r r �last_run� s � rl c C s" | D ] }|r|dur| S qdS )zF Helper to iterate over returner_types and pick the first one Nr )Zreturner_typesr+ r r r r$ s ��r$ c C s� | sddi}|S | � dd�t| � dg ��| � dd�| � dd �| � d d �d �}d | v r3| � d i �|d< n:d| v rHd | d v rH| d � d i �|d< n%| � dg �pOg D ] }t|t�rl|� d�du rld |v rl|� d i �|d< nqPd| v rw| d |d< |S )z) Helper to format a job instance �Errorz/Cannot contact returner or no job with this jidrc zunknown-function�argZtgtzunknown-targetZtgt_typer �user�root)rL Z ArgumentsrK z Target-typeZUserrj rJ �kwargsZ __kwarg__Tr. )r r r rN )r) r' rn r r r �_format_job_instance s0 � �� rr c C s$ t |�}|�dtjj�| �i� |S )z' Helper to format jid instance rM )rr r r r r Z jid_to_time)r r) r' r r r r G s r c c s� � t �| �D ]t}t j�| |�}t �|�D ]e}t j�||d�}tjj�|d��}tj� |�}W d � n1 s7w Y t j� |�sCqtjj�|d��}tj� |�}W d � n1 s\w Y |d }|rrt � dd|� �id� ||||fV qqdS )z2 Walk through the job dir and return jobs z.load.p�rbNr r z Found JID r ) �os�listdir�path�joinr r �filesZfopen�payload�load�isfiler r ) Zjob_dirr& �topZt_path�finalZ load_pathZrfhr) r r r r � _walk_throughP s& � � ���r~ )F)NTFF)NF)NNNNNNNF)TNNFr1 )NNNNNF)$�__doc__rS �loggingrt Z salt.clientr Z salt.minionZ salt.payloadZsalt.returnersZsalt.utils.argsZsalt.utils.filesZsalt.utils.jidZsalt.utils.masterZsalt.exceptionsr Zdateutil.parser�parserrU rT � ImportError� getLogger�__name__rO r r, rA r: r_ rd re rg rl r$ rr r r~ r r r r �<module> sd � ; � L+ � & � % %# �+ )
| ver. 1.4 |
Github
|
.
| PHP 8.2.30 | Generation time: 0 |
proxy
|
phpinfo
|
Settings