📁 File Manager Pro
v10.0.2 | PHP: 8.1.34
Server: LiteSpeed
2026-06-27 20:25:29
📂
/
/
opt
/
hc_python
/
lib
/
python3.12
/
site-packages
/
sentry_sdk
/
integrations
/
__pycache__
✏️
Editing: dramatiq.cpython-312.pyc
� Yr*j � � � d dl Z d dlmZ d dlZd dlmZmZmZ d dlm Z m Z d dlmZm Z d dlmZ d dlmZ d dlmZmZmZ d d lmZ d d lmZmZmZ ed� Z d dlmZ d d lm Z d dl!m"Z" d dl#m$Z$m%Z% d dlm'Z' e'rd dlm(Z(m)Z)m*Z*m+Z+m,Z, d dl-m.Z.m/Z/ G d� de � Z0dd�Z1 G d� de$� Z2 dd�Z3 G d� d� Z4y# e&$ r ed� �w xY w)� N)�TypeVar)�continue_trace�get_baggage�get_traceparent)�OP� SPANSTATUS)�DidNotEnable�Integration)�request_body_within_bounds)� SegmentSource)�BAGGAGE_HEADER_NAME�SENTRY_TRACE_HEADER_NAME�TransactionSource)�has_span_streaming_enabled)�AnnotatedValue�capture_internal_exceptions�event_from_exception�R)�Broker)�Retry)�Message)� Middleware�default_middlewarezDramatiq is not installed)� TYPE_CHECKING)�Any�Callable�Dict�Optional�Union)�Event�Hintc �0 � e Zd ZdZdZde� �Zedd�� Zy)�DramatiqIntegrationa? Dramatiq integration for Sentry Please make sure that you call `sentry_sdk.init` *before* initializing your broker, as it monkey patches `Broker.__init__`. This integration was originally developed and maintained by https://github.com/jacobsvante and later donated to the Sentry project. �dramatiqzauto.queue.Nc � � t � y �N)�_patch_dramatiq_broker� � �O/opt/hc_python/lib/python3.12/site-packages/sentry_sdk/integrations/dramatiq.py� setup_oncezDramatiqIntegration.setup_once7 s � �� r) ��returnN)�__name__� __module__�__qualname__�__doc__� identifier�origin�staticmethodr+ r( r) r* r# r# ( s, � � � �J��:�,� '�F��!� �!r) r# c �X �� t j � d�fd�} | t _ y )Nc � �� t j � j t � } |j d� }|�t d� t D � � }nt |� }|�:|D �cg c] }t |t � r�|�� }}|j dt � � ||d<