golden hour
/opt/saltstack/salt/lib/python3.10/site-packages/salt/runners/__pycache__
⬆️ Go Up
Upload
File/Folder
Size
Actions
__init__.cpython-310.pyc
197 B
Del
OK
asam.cpython-310.pyc
7.9 KB
Del
OK
auth.cpython-310.pyc
1.89 KB
Del
OK
bgp.cpython-310.pyc
12.55 KB
Del
OK
cache.cpython-310.pyc
10.98 KB
Del
OK
cloud.cpython-310.pyc
4.16 KB
Del
OK
config.cpython-310.pyc
1.08 KB
Del
OK
ddns.cpython-310.pyc
6.7 KB
Del
OK
digicertapi.cpython-310.pyc
16.23 KB
Del
OK
doc.cpython-310.pyc
1.76 KB
Del
OK
drac.cpython-310.pyc
4.15 KB
Del
OK
error.cpython-310.pyc
771 B
Del
OK
event.cpython-310.pyc
2.32 KB
Del
OK
f5.cpython-310.pyc
8.29 KB
Del
OK
fileserver.cpython-310.pyc
17.12 KB
Del
OK
git_pillar.cpython-310.pyc
3.54 KB
Del
OK
http.cpython-310.pyc
2.55 KB
Del
OK
jobs.cpython-310.pyc
13.26 KB
Del
OK
launchd.cpython-310.pyc
1.49 KB
Del
OK
lxc.cpython-310.pyc
13.3 KB
Del
OK
manage.cpython-310.pyc
21.71 KB
Del
OK
mattermost.cpython-310.pyc
4.21 KB
Del
OK
mine.cpython-310.pyc
1.79 KB
Del
OK
nacl.cpython-310.pyc
8.46 KB
Del
OK
net.cpython-310.pyc
27.7 KB
Del
OK
network.cpython-310.pyc
2.59 KB
Del
OK
pagerduty.cpython-310.pyc
3.96 KB
Del
OK
pillar.cpython-310.pyc
4.25 KB
Del
OK
pkg.cpython-310.pyc
1.37 KB
Del
OK
queue.cpython-310.pyc
8.14 KB
Del
OK
reactor.cpython-310.pyc
4.32 KB
Del
OK
salt.cpython-310.pyc
4.58 KB
Del
OK
saltutil.cpython-310.pyc
15.88 KB
Del
OK
sdb.cpython-310.pyc
2.54 KB
Del
OK
smartos_vmadm.cpython-310.pyc
7.99 KB
Del
OK
spacewalk.cpython-310.pyc
7.54 KB
Del
OK
ssh.cpython-310.pyc
1000 B
Del
OK
state.cpython-310.pyc
8.22 KB
Del
OK
survey.cpython-310.pyc
5.07 KB
Del
OK
test.cpython-310.pyc
2.65 KB
Del
OK
thin.cpython-310.pyc
1.81 KB
Del
OK
vault.cpython-310.pyc
10.01 KB
Del
OK
venafiapi.cpython-310.pyc
5.57 KB
Del
OK
virt.cpython-310.pyc
13.15 KB
Del
OK
vistara.cpython-310.pyc
4.39 KB
Del
OK
winrepo.cpython-310.pyc
5.14 KB
Del
OK
Edit: jobs.cpython-310.pyc
o �xe�E � @ 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�} |jd� | � | �}|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: {}�progressz Received 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� |jd�|� | �}|� t | |�� |jd�|� | �|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�|�id� tj�t�} | jd�|� � } i } | D ]�} d} |r_d} d | | v r_t |t �rZ|D ]}|| | d v rX| | d | || krXd} q@nt � d � |r�| r�d} d | | v r�| | d }t |t �ry|g}|D ]}tjj�|�D ] }t�||�r�d} q�q{|r�| r�d} d | | v r�tjj�|�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% 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�|�id� tj�t�}d�|�}||jvr/t 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 r z{}.get_jids_filterz+'{}' returner function not implemented yet.r8 ) r$ r r r r r r" r# r% �NotImplementedError) �countZfilter_find_jobr- r9 r& r+ r* �funr' r r r �list_jobs_filter~ s" �� � rb c C s� i }t td |td f�}tj�t�}z|jd�|� | �}t| |�|| < W n ty: d�|�|| d< | Y S w |jd�|� | �|| 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* � �� rc 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)rM r: r )r r- r' r( Zminions�resultr" r r r � exit_success� s �re 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 rW rX rY r& ���)r rM rN rO r^ �sortedrc )r- r9 �metadata�functionr] r& Z _all_jobsZlast_jobr r r �last_run� s � rj 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< nd| v rGd | d v rG| d � d i �|d< d| v rQ| d |d< |S )z) Helper to format a job instance �Errorz/Cannot contact returner or no job with this jidra zunknown-function�argZtgtzunknown-targetZtgt_typer �user�root)rK Z ArgumentsrJ z Target-typeZUserrh rI �kwargsr. )r r )r) r' r r r �_format_job_instance s" � rp c C s$ t |�}|�dtjj�| �i� |S )z' Helper to format jid instance rL )rp r r r r Z jid_to_time)r r) r' r r r r = 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 r ) Zjob_dirr& �topZt_path�finalZ load_pathZrfhr) r r r r � _walk_throughF s* � � ����r| )F)NTFF)NF)NNNNNNNF)TNNFr1 )NNNNNF)$�__doc__rR Zloggingrr Z salt.clientr Z salt.minionZ salt.payloadZsalt.returnersZsalt.utils.argsZsalt.utils.filesZsalt.utils.jidZsalt.utils.masterZsalt.exceptionsr Zdateutil.parser�parserrT rS � ImportErrorZ getLogger�__name__rN r r, rA r: r^ rb rc re rj r$ rp r r| r r r r �<module> sd � ; � L+ � & � ' %# �+
Save