관리-도구
편집 파일: __init__.pyc
� ��Yc @@ s� d Z d d l m Z d d l Z d d l m Z d d l m Z m Z m Z m Z d d l m Z d e j f d � � YZ e d � Z d e j d � Z d e f d � � YZ d S( s� raven.contrib.celery ~~~~~~~~~~~~~~~~~~~~ :copyright: (c) 2010-2012 by the Sentry Team, see AUTHORS for more details. :license: BSD, see LICENSE for more details. i ( t absolute_importN( t SoftTimeLimitExceeded( t after_setup_loggert task_failuret task_prerunt task_postrun( t SentryHandlert CeleryFilterc B@ s e Z d � Z RS( c C@ sG t | d i � } t | t � s. | j d k S| j d | j d k � S( Nt datat _log_errort internal( t getattrt isinstancet dictt funcNamet get( t selft recordt extra_data( ( sN /opt/alt/python27/lib/python2.7/site-packages/raven/contrib/celery/__init__.pyt filter s ( t __name__t __module__R ( ( ( sN /opt/alt/python27/lib/python2.7/site-packages/raven/contrib/celery/__init__.pyR s c C@ s t | d | �j � d S( Nt ignore_expected( t SentryCeleryHandlert install( t clientR ( ( sN /opt/alt/python27/lib/python2.7/site-packages/raven/contrib/celery/__init__.pyt register_signal s c @ sX t � � t | � � � j | � � j � � � � f d � } t j | d t �d S( Nc @ sH x4 | j D]) } t | � t k r | j � � t Sq W| j � � d S( N( t handlerst typeR t addFiltert Falset addHandler( t sendert loggert loglevelt logfilet formatt colorizet kwt h( t filter_t handler( sN /opt/alt/python27/lib/python2.7/site-packages/raven/contrib/celery/__init__.pyt process_logger_event( s t weak( R R t setLevelR R t connectR ( R R! R" R* ( ( R( R) sN /opt/alt/python27/lib/python2.7/site-packages/raven/contrib/celery/__init__.pyt register_logger_signal! s R c B@ sA e Z e d � Z d � Z d � Z d � Z d � Z d � Z RS( c C@ s | | _ | | _ d S( N( R R ( R R R ( ( sN /opt/alt/python27/lib/python2.7/site-packages/raven/contrib/celery/__init__.pyt __init__8 s c C@ sF t j | j d t �t j | j d t �t j | j d t �d S( NR+ ( R R- t handle_task_prerunR R t handle_task_postrunR t process_failure_signal( R ( ( sN /opt/alt/python27/lib/python2.7/site-packages/raven/contrib/celery/__init__.pyR < s c C@ s4 t j | j � t j | j � t j | j � d S( N( R t disconnectR0 R R1 R R2 ( R ( ( sN /opt/alt/python27/lib/python2.7/site-packages/raven/contrib/celery/__init__.pyt uninstallA s c K@ s� | j r1 t | d � r1 t | j | j � r1 d St | j t � ra d d t | d | � g } n d } | j j d i | d 6| d 6| d 6| d 6d | � d S( Nt throwst celeryR t namet extrat task_idt taskt argst kwargst fingerprint( R t hasattrR t exceptionR5 R R t NoneR t captureException( R R R9 R; R< t einfoR& R= ( ( sN /opt/alt/python27/lib/python2.7/site-packages/raven/contrib/celery/__init__.pyR2 F s - c K@ s* | j j j � | j j j | j � d S( N( R t contextt activatet transactiont pushR7 ( R R R9 R: R& ( ( sN /opt/alt/python27/lib/python2.7/site-packages/raven/contrib/celery/__init__.pyR0 Z s c K@ s* | j j j | j � | j j j � d S( N( R RE t popR7 RC t clear( R R R9 R: R& ( ( sN /opt/alt/python27/lib/python2.7/site-packages/raven/contrib/celery/__init__.pyR1 ^ s ( R R R R/ R R4 R2 R0 R1 ( ( ( sN /opt/alt/python27/lib/python2.7/site-packages/raven/contrib/celery/__init__.pyR 7 s ( t __doc__t __future__R t loggingt celery.exceptionsR t celery.signalsR R R R t raven.handlers.loggingR t FilterR R R R@ t ERRORR. t objectR ( ( ( sN /opt/alt/python27/lib/python2.7/site-packages/raven/contrib/celery/__init__.pyt <module> s "