PATH:
opt
/
hc_python
/
lib
/
python3.12
/
site-packages
/
sentry_sdk
/
integrations
/
celery
/
__pycache__
� o0iI � �V � d dl Z d dlmZ d dlmZ d dlZd dlmZ d dlmZ d dl m Z mZmZ d dl mZmZmZ d dlmZmZmZ d d lmZ d d lmZ d dlmZmZ d dlmZ d d lmZm Z m!Z!m"Z" d dl#m$Z$ e$rEd dl#m%Z% d dl#m&Z& d dl#m'Z' d dl#m(Z( d dl#m)Z) d dl#m*Z* d dl+m,Z,m-Z-m.Z.m/Z/ d dlm0Z0 e)de&de%f �� Z1 d dl2m3Z4 d dl5m6Z6 d dl7m8Z8 d dl9m:Z:m;Z;m<Z<m=Z= d dl>m?Z? e<e:e;fZA G d � d!e� ZBd"� ZCd#� ZDd1d$�ZEd%� ZF G d&� d'� ZGd(� ZHd)� ZId*� ZJd+� ZKd,� ZLd-� ZMd.� ZNd/� ZOd0� ZPy# e@$ r ed� �w xY w)2� N)�Mapping��wraps)�isolation_scope)�continue_trace)�OP� SPANSTATUS�SPANDATA)�_check_minimum_version�Integration�DidNotEnable)�_patch_beat_apply_entry�_patch_redbeat_apply_async�_setup_celery_beat_signals)�_now_seconds_since_epoch)� ignore_logger)�BAGGAGE_HEADER_NAME�TransactionSource)�Baggage)�capture_internal_exceptions�ensure_integration_enabled�event_from_exception�reraise)� TYPE_CHECKING)�Any)�Callable)�List)�Optional)�TypeVar)�Union)�EventProcessor�Event�Hint�ExcInfo)�Span�F.)�bound)�VERSION)�Task)�task_has_custom)�Ignore�Reject�Retry�SoftTimeLimitExceeded)�ProducerzCelery not installedc �8 � e Zd ZdZde� �Z dd�Zed� � Zy)�CeleryIntegration�celeryzauto.queue.Nc �l � || _ || _ || _ t � t � t |� y �N)�propagate_traces�monitor_beat_tasks�exclude_beat_tasksr r r )�selfr5 r6 r7 s �V/opt/hc_python/lib/python3.12/site-packages/sentry_sdk/integrations/celery/__init__.py�__init__zCeleryIntegration.__init__@ s1 � � !1���"4���"4����!�"�$�"�#5�6� c �� � t t t � t � t � t � t � t � t d� t d� t d� y )Nzcelery.worker.jobzcelery.app.tracezcelery.redirected) r r1 �CELERY_VERSION�_patch_build_tracer�_patch_task_apply_async�_patch_celery_send_task�_patch_worker_exit�_patch_producer_publishr � r; r9 � setup_oncezCeleryIntegration.setup_onceO sL � � �0�.�A����!��!����!� �)�*��(�)� �)�*r; )TFN)�__name__� __module__�__qualname__� identifier�originr: �staticmethodrD rC r; r9 r1 r1 <