o

�N�g�@sfdZd
dl
Z
d
dlZd
dlZd
dlZd
dlZd
dlZe
�e	�
Z
ddd�
Zddd�
Zdd�Z
d	d
�ZdS)z.
Functions for interacting with the job cache
�Nc
s�tj
j�tj
j�|�
�
}t�f
d
d�dD�
�
rdStj
j�|�d�s%dS|dur2tjj	|ddd�}|d}�d	d
krȈ�
d��
dg���d<d
�d<�d�d<d�|d�
}z|j|��
dd�d�
�d	<Wn&t
y


d|�d�}t�|�

t
|�
�
ty�


tjd|dd�
Yn
w|�d�}z|j|�d	��
Wnjt
y�


d|�d�}t�|�

t
|�
�
ty�


tjd|dd�
YnEwtj
j��d	�
�
r|�d�}	z
|j|	d�d	d�
Wn't
y�


d|�d�}t�|�

t
|�
�
t�
y


tjd|dd�
Yn
w|�
r2t�d�d�d	�
|��tj
j��d	d�dgd��
|���

|d �
r=|�
d!�
�
r?dS��
d	�
dk�
rTt�d"�d	�d�
dS|�d�}
|�d#�}|�d$�}|�d%�}
d&�v
�
r���
d'i��
r���
d'i�}d&|v�
r���d&|d&i
�

d(|v�
r���d(|d(i
�

z|j|
}|j|}|j|}Wnt
�
y�
}
zd|�d)|��}t�|�

t
|�
�
d}~w
wd}|d*k�
r�|j|��
d	d+��
�
r�d}|�rz|j|
�d	��
Wn*t
�y
}
zt�d,|�
WYd}~nd}~w
t�y


tjd|dd�
Yn
wz	|j|��

Wnt�y0


tjd|dd�
Yn
w|�
d-�
�rI|
|jv�rK|j|
�d	|�
dSdSdS).zE
    Store job information using the configured master_job_cache
    c
3s�|]}
|
�v
V
qdS)
N�)�.0�key�
�loadr�B/opt/saltstack/salt/lib/python3.10/site-packages/salt/utils/job.py�	<genexpr>s�zstore_job.<locals>.<genexpr>)�return�jid�idFrN�ZstatesZrend�master_job_cacher
Zreq�argZfun_args�globZtgt_typeZtgtz{}.prep_jid�nocache)
r�
Returner 'z$' does not support function prep_jidz1The specified '%s' returner threw a stack trace:
T)
�exc_infoz
.save_loadz%' does not support function save_loadz/The specified '%s' returner threw a stack tracez	.prep_jid)
Z
passed_jidzGot return from %s for job %s�retZjob�	job_cacheZ
ext_job_cachez3Ignoring job return with jid for caching %s from %sz	.get_loadz	.returnerz.update_endtimeZfunr	�userz' does not support function Zlocal_cache�zLoad does not contain 'jid': %sZjob_cache_store_endtime)�salt�utilsr
Zjid_to_timeZgen_jid�anyZverifyZvalid_id�minion�MasterMinion�get�format�	returners�KeyError�log�error�	Exception�criticalZis_jid�infoZ
fire_event�eventZtagifyZ
fire_ret_load�debug�update)�optsrr%�mminion�endtimerZ	prep_fstrZemsgZ
saveload_fstrZ
jidstore_fstrZsavefstrZgetfstrZfstrZupdateetfstrZret_Z
savefstr_funcZgetfstr_funcZ	fstr_funcr!Z	save_load�
errr�	store_jobs�











�









��













��













��

�





�
























��"




�





��




��
�r,cCsf|d
ur
tj
j|ddd�}|d}|�d�}z
|j||
||d�
Wd
Sty2


td|�d��
�
w)	zk
    Store additional minions matched on lower-level masters using the configured
    master_job_cache
    NFrr
z
.save_minions)
�	syndic_idrz(' does not support function save_minions)rrrrr)r(r
Zminionsr)r-rZminions_fstrrrr�
store_minions�s






�r.c
Cs<d
}
t|t
�r|�dd
�d
kr|dSt|t�r|sdS|
S)z0
    Determine a retcode for a given return
    r
�retcode�
)�
isinstance�dictr�bool)rr/rrr�get_retcode�s


r4c
CsD|�d
d�}
|�dd�}|
dkr |dkr t
jj�dd�
|d}
|
S)a#

    Temporary function until 'keep_jobs' is fully deprecated,
    this will prefer 'keep_jobs_seconds', and only use
    'keep_jobs' as the configuration value if 'keep_jobs_seconds'
    is unmodified, and 'keep_jobs' is modified (in which case it
    will emit a deprecation warning).
    �keep_jobs_secondsi�Q
�	keep_jobs�ZArgonzQThe 'keep_jobs' option has been deprecated and replaced with 'keep_jobs_seconds'.i)rrrZversionsZ
warn_until)r(r5r6rrr�get_keep_jobs_seconds�s




�
r8)NN)�__doc__�loggingZsalt.minionrZsalt.utils.eventZsalt.utils.jidZsalt.utils.verifyZsalt.utils.versions�	getLogger�__name__r r,r.r4r8rrrr�<module>
s