. d Z ddlmZ ddlZddlmZ ddlmZmZm Z m
Z
ddl m Z G d dej
Zdd
Zdej fd Z G d d
e ZdS )z
raven.contrib.celery
~~~~~~~~~~~~~~~~~~~~
:copyright: (c) 2010-2012 by the Sentry Team, see AUTHORS for more details.
:license: BSD, see LICENSE for more details.
)absolute_importN)SoftTimeLimitExceeded)after_setup_logger task_failure task_prerun task_postrun)
SentryHandlerc e Zd Zd ZdS ) CeleryFilterc t |di }t |t s |j dk S | d|j dk S )Ndata
_log_errorinternal)getattr
isinstancedictfuncNameget)selfrecord
extra_datas o/builddir/build/BUILD/cloudlinux-venv-1.0.10/venv/lib/python3.11/site-packages/raven/contrib/celery/__init__.pyfilterzCeleryFilter.filter sM VVR00
*d++ 3?l2 2~~j&/\*IJJJ N)__name__
__module__ __qualname__r r r r r s( K K K K Kr r Fc L t | | d S )N)ignore_expected)SentryCeleryHandlerinstallclientr s r register_signalr% s' @@@HHJJJJJr c t t | | fd}t j |d d S )Nc |j D ]/}t |t r| dS 0| d S )NF)handlersr r addFilter
addHandler)
senderloggerloglevellogfileformatcolorizekwhfilter_handlers
r process_logger_eventz4register_logger_signal..process_logger_event( sb
A!]++
G$$$ uu
'"""""r Fweak)r r setLevelr) r connect)r$ r, r- r5 r3 r4 s @@r register_logger_signalr: ! s nnGF##G X g
#
#
#
#
#
# 3%@@@@@@r c 4 e Zd Zd dZd Zd Zd Zd Zd ZdS )
r! Fc " || _ || _ d S Nr# )r r$ r s r __init__z SentryCeleryHandler.__init__8 s . r c t j | j d t j | j d t j | j d d S )NFr6 )r r9 handle_task_prerunr handle_task_postrunr process_failure_signalr s r r" zSentryCeleryHandler.install< sS D 3%@@@@ T 5EBBBB T 8uEEEEEEr c t j | j t j | j t j | j d S r= )r
disconnectr@ r rA r rB rC s r uninstallz SentryCeleryHandler.uninstallA sD t 6777 8999 ;<<<<]>]^KK K $$" $ %
r c | j j | j j |j d S r= )r$ contextactivate transactionpushrJ r r+ rK rL r1 s r r@ z&SentryCeleryHandler.handle_task_prerunZ s: $$&&& $$TY/////r c | j j |j | j j d S r= )r$ rX poprJ rV clearrZ s r rA z'SentryCeleryHandler.handle_task_postrun^ s: ##DI... !!#####r NF) r r r r> r" rF rB r@ rA r r r r! r! 7 sv / / / /F F F
= = =
(0 0 0$ $ $ $ $r r! r^ )__doc__
__future__r loggingcelery.exceptionsr celery.signalsr r r r raven.handlers.loggingr Filterr r% ERRORr: objectr! r r r rh s/ ' & & & & & 3 3 3 3 3 3 1 0 0 0 0 0K K K K K7> K K KK K K K +/ A A A A,)$ )$ )$ )$ )$& )$ )$ )$ )$ )$r