Ë
    S>{ié  ã                   óF  — d dl mZ d dlZd dlmZ d dlmZ d dlmZ d dl	m
Z
mZ d dlmZ d dlmZ d d	lmZmZmZmZ 	 d d
lmZ d dlmZ d dlmZ d dlmZ d dlmZ d dl!m"Z" e"rd dl#m$Z$m%Z%m&Z& d dl!m'Z' d dlm(Z( d dlm)Z)  G d„ de«      Z*d„ Z+d„ Z,y# e $ r	  e
d«      ‚w xY w)é    )Úabsolute_importN)ÚOP)Úcontinue_trace)ÚHub)ÚDidNotEnableÚIntegration)Úignore_logger)ÚTRANSACTION_SOURCE_TASK)Úcapture_internal_exceptionsÚevent_from_exceptionÚformat_timestampÚparse_version)ÚQueue)ÚJobTimeoutException)ÚVERSION)ÚWorker)Ú	JobStatuszRQ not installed)ÚTYPE_CHECKING)ÚAnyÚCallableÚDict)ÚEventProcessor)ÚExcInfo)ÚJobc                   ó    — e Zd ZdZed„ «       Zy)ÚRqIntegrationÚrqc                  ó^  ‡‡‡— t        t        «      } | €t        dj                  t        «      «      ‚| dk  rt        d«      ‚t        j
                  Šˆfd„}|t        _        t        j                  Šˆfd„}|t        _        t        j                  Šˆfd„}|t        _        t        d«       y )NzUnparsable RQ version: {})r   é   zRQ 0.6 or newer is required.c                 óÖ  •— t         j                  }|j                  t        «      }|€ ‰
| |g|¢­i |¤ŽS |j                  }|€J ‚|j                  «       5 }|j                  «        |j                  t        t        j                  |«      «      «       t        |j                  j                  d«      xs i t        j                  dt         ¬«      }t#        «       5  |j$                  |_        d d d «       |j)                  |d|i¬«      5   ‰
| |g|¢­i |¤Ž}	d d d «       d d d «       | j*                  r|j-                  «        	S # 1 sw Y   ŒZxY w# 1 sw Y   Œ;xY w# 1 sw Y   Œ?xY w)NÚ_sentry_trace_headerszunknown RQ task)ÚopÚnameÚsourceÚrq_job)Úcustom_sampling_context)r   ÚcurrentÚget_integrationr   ÚclientÚ
push_scopeÚclear_breadcrumbsÚadd_event_processorÚ_make_event_processorÚweakrefÚrefr   ÚmetaÚgetr   ÚQUEUE_TASK_RQr
   r   Ú	func_namer#   Ústart_transactionÚis_horseÚflush)ÚselfÚjobÚargsÚkwargsÚhubÚintegrationr)   ÚscopeÚtransactionÚrvÚold_perform_jobs             €úX/var/www/skyplay_api_hub/venv/lib/python3.12/site-packages/sentry_sdk/integrations/rq.pyÚsentry_patched_perform_jobz<RqIntegration.setup_once.<locals>.sentry_patched_perform_job7   s\  ø€ ä—+‘+ˆCØ×-Ñ-¬mÓ<ˆKàÐ"Ù& t¨SÐB°4ÒB¸6ÑBÐBà—Z‘ZˆFØÐ%Ð%Ð%à—‘Ó!ð E UØ×'Ñ'Ô)Ø×)Ñ)Ô*?ÄÇÁÈCÓ@PÓ*QÔRä,Ø—H‘H—L‘LÐ!8Ó9Ò?¸RÜ×'Ñ'Ø*Ü2ô	�ô 1Ó2ñ 5Ø'*§}¡}�KÔ$÷5ð ×*Ñ*Ø¸(ÀC¸ð +ó ñ Eñ )¨¨sÐD°TÒD¸VÑD�B÷E÷Eð& �}Š}ð —‘”àˆI÷5ð 5ú÷Eð Eú÷Eð Eús=   ÁBEÃEÃ.EÄEÄEÅE	ÅEÅE	ÅEÅE(c                 ó†   •— |j                   t        j                  k(  s|j                  rt	        |«        ‰| |g|¢­i |¤ŽS )N)Ú_statusr   ÚFAILEDÚ	is_failedÚ_capture_exception)r7   r8   Úexc_infor:   Úold_handle_exceptions       €rA   Úsentry_patched_handle_exceptionzARqIntegration.setup_once.<locals>.sentry_patched_handle_exceptiona   s<   ø€ ð �{‰{œi×.Ñ.Ò.°#·-²-Ü" 8Ô,á'¨¨cÐG°HÒGÀÑGÐGó    c                 óÚ   •— t         j                  }|j                  t        «      �<|j                  j
                  �&t        |j                  «       «      |j                  d<    ‰| |fi |¤ŽS )Nr!   )	r   r'   r(   r   r=   ÚspanÚdictÚiter_trace_propagation_headersr0   )r7   r8   r:   r;   Úold_enqueue_jobs       €rA   Úsentry_patched_enqueue_jobz<RqIntegration.setup_once.<locals>.sentry_patched_enqueue_jobn   s_   ø€ ä—+‘+ˆCØ×"Ñ"¤=Ó1Ð=Ø—9‘9—>‘>Ð-Ü8<Ø×:Ñ:Ó<ó9�C—H‘HÐ4Ñ5ñ # 4¨Ñ7°Ñ7Ð7rK   z	rq.worker)
r   Ú
RQ_VERSIONr   Úformatr   Úperform_jobÚhandle_exceptionr   Úenqueue_jobr	   )ÚversionrB   rJ   rQ   rP   rI   r@   s       @@@rA   Ú
setup_oncezRqIntegration.setup_once)   s™   ú€ ô  ¤
Ó+ˆàˆ?ÜÐ:×AÑAÄ*ÓMÓNÐNà�VÒÜÐ=Ó>Ð>ä ×,Ñ,ˆô$	ðL 8ŒÔä%×6Ñ6Ðô	Hð #BŒÔä×+Ñ+ˆô		8ð 7ŒÔä�kÕ"rK   N)Ú__name__Ú
__module__Ú__qualname__Ú
identifierÚstaticmethodrX   © rK   rA   r   r   &   s   „ Ø€JàñQ#ó ñQ#rK   r   c                 ó   ‡ — ˆ fd„}|S )Nc                 ó.  •—  ‰«       }|�°t        «       5  | j                  di «      }|j                  |j                  |j                  |j
                  |j                  dœ|d<   |j                  rt        |j                  «      |d   d<   |j                  rt        |j                  «      |d   d<   d d d «       d|v r=t        «       5  t        |d   d   t        «      rdd	|j                  g| d
<   d d d «       | S | S # 1 sw Y   ŒLxY w# 1 sw Y   | S xY w)NÚextra)Újob_idÚfuncr9   r:   Údescriptionzrq-jobÚenqueued_atÚ
started_atrH   r   r   r   Úfingerprint)r   Ú
setdefaultÚidr3   r9   r:   rd   re   r   rf   Ú
issubclassr   )ÚeventÚhintr8   ra   Úweak_jobs       €rA   Úevent_processorz._make_event_processor.<locals>.event_processor€   s  ø€ á‹jˆØˆ?Ü,Ó.ñ UØ×(Ñ(¨°"Ó5�à!Ÿf™fØŸM™MØŸH™HØ!Ÿj™jØ#&§?¡?ñ#��h‘ð —?’?Ü5EÀcÇoÁoÓ5V�E˜(‘O MÑ2Ø—>’>Ü4DÀSÇ^Á^Ó4T�E˜(‘O LÑ1÷Uð ˜ÑÜ,Ó.ñ XÜ˜d :Ñ.¨qÑ1Ô3FÔGØ,0Ð2GÈÏÉÐ+W�E˜-Ñ(÷Xð ˆˆuˆ÷)Uð Uú÷ Xð ˆús   •BC>Ã	)D
Ã>DÄ
Dr^   )rm   rn   s   ` rA   r-   r-   ~   s   ø€ ôð4 ÐrK   c                 óÊ   — t         j                  }|j                  t        «      €y |j                  }t        | |j                  dddœ¬«      \  }}|j                  ||¬«       y )Nr   F)ÚtypeÚhandled)Úclient_optionsÚ	mechanism)rl   )r   r'   r(   r   r)   r   ÚoptionsÚcapture_event)rH   r:   r;   r)   rk   rl   s         rA   rG   rG   �   s_   € ä
�+‰+€CØ
×Ñœ=Ó)Ð1Øð �Z‰Z€Fä&ØØ—~‘~Ø¨EÑ2ô�K€Eˆ4ð ×Ñ�e $ÐÕ'rK   )-Ú
__future__r   r.   Úsentry_sdk.constsr   Úsentry_sdk.apir   Úsentry_sdk.hubr   Úsentry_sdk.integrationsr   r   Úsentry_sdk.integrations.loggingr	   Úsentry_sdk.tracingr
   Úsentry_sdk.utilsr   r   r   r   Úrq.queuer   Úrq.timeoutsr   Ú
rq.versionr   rR   Ú	rq.workerr   Úrq.jobr   ÚImportErrorÚsentry_sdk._typesr   Útypingr   r   r   r   r   r   r   r-   rG   r^   rK   rA   ú<module>r†      s‰   ðÝ &ã Ý  å )Ý ß =Ý 9Ý 6÷ó ð+ÝÝ/Ý0Ý Ý õ ,áß*Ñ*å0Ý(åôU#�Kô U#òpó>(øðK ò +Ù
Ð)Ó
*Ð*ð+ús   ¾B ÂB 