golden hour
/opt/cloudlinux/venv/lib/python3.11/site-packages/raven/contrib/celery/__pycache__
⬆️ Go Up
Upload
File/Folder
Size
Actions
__init__.cpython-311.opt-1.pyc
5.64 KB
Del
OK
__init__.cpython-311.pyc
5.64 KB
Del
OK
Edit: __init__.cpython-311.pyc
� `|oi � � � 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 )N�data� _log_error�internal)�getattr� isinstance�dict�funcName�get)�self�record� extra_datas �R/opt/cloudlinux/venv/lib/python3.11/site-packages/raven/contrib/celery/__init__.py�filterzCeleryFilter.filter sM � � �V�V�R�0�0� ��*�d�+�+� 3��?�l�2� 2��~�~�j�&�/�\�*I�J�J�J� N)�__name__� __module__� __qualname__r � r r r r s( � � � � � �K� K� K� K� Kr r Fc �L � t | |�� � � � � d S )N)�ignore_expected)�SentryCeleryHandler�install��clientr s r �register_signalr% s' � ����@�@�@�H�H�J�J�J�J�Jr c �� ��� t � � �t | � � ��� |� � �� �� � ��fd�}t j |d�� � d S )Nc � �� |j D ]/}t |t � � r|� �� � dS �0|� � � � d S )NF)�handlersr r � addFilter� addHandler) �sender�logger�loglevel�logfile�format�colorize�kw�h�filter_�handlers ��r �process_logger_eventz4register_logger_signal.<locals>.process_logger_event( sb �� � � � � �A��!�]�+�+� �� � �G�$�$�$� �u�u� � ���'�"�"�"�"�"r F��weak)r r �setLevelr) r �connect)r$ r, r- r5 r3 r4 s @@r �register_logger_signalr: ! s ��� ��n�n�G��F�#�#�G� ���X� � � � ���g� � � � #� #� #� #� #� #� � � 3�%�@�@�@�@�@�@r c �4 � e Zd Zd d�Zd� 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_signal�r s r r" zSentryCeleryHandler.install< sS � ���D� 3�%�@�@�@�@�� �T� 5�E�B�B�B�B�� �T� 8�u�E�E�E�E�E�Er 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� 6�7�7�7�� �� 8�9�9�9�� �� ;�<�<�<�<�<r c � � | j r,t |d� � r t |j |j � � rd S t |j t � � rddt |d|� � g}nd }| j � ||||d�|�� � d S )N�throws�celeryr �name)�task_id�task�args�kwargs)�extra� fingerprint) r �hasattrr � exceptionrH r r r$ �captureException)r r+ rK rM rN �einfor1 rP s r rB z*SentryCeleryHandler.process_failure_signalF s� � � � � �G�F�H�$=�$=� �*�U�_�^d�^k�Bl�Bl� � �F� �e�o�'<� =� =� �#�%<�g�f�f�V\�>]�>]�^�K�K� �K� � �$�$�"� � � � � � $� %� � � � � r c � � | j j � � � | j j � |j � � d S r= )r$ �context�activate� transaction�pushrJ �r r+ rK rL r1 s r r@ z&SentryCeleryHandler.handle_task_prerunZ s: � � � ��$�$�&�&�&� � � �$�$�T�Y�/�/�/�/�/r c � � | j j � |j � � | j j � � � d S r= )r$ rX �poprJ rV �clearrZ s r rA z'SentryCeleryHandler.handle_task_postrun^ s: � � � � �#�#�D�I�.�.�.� � ��!�!�#�#�#�#�#r N�F) 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 �logging�celery.exceptionsr �celery.signalsr r r r �raven.handlers.loggingr �Filterr r% �ERRORr: �objectr! r r r �<module>rh s/ ��� � '� &� &� &� &� &� ���� 3� 3� 3� 3� 3� 3�� � � � � � � � � � � � 1� 0� 0� 0� 0� 0�K� K� K� K� K�7�>� K� K� K�K� K� K� K� +/�� � A� A� A� A�,)$� )$� )$� )$� )$�&� )$� )$� )$� )$� )$r
Save