o
    i                     @   s   d dl mZ d dlZd dlmZ d dlmZ d dlmZ z
d dl	m
Z
mZ W n ey1   dZ
Y nw d dlmZ er@d dlmZ dd
dZdS )    )wrapsN)OP)
SPANSTATUS)qualname_from_function)TaskTaskResultStatus)TYPE_CHECKING)Anyreturnc                     s2   t d u rd S t j t d fdd} | t _d S )	Nselfr	   argskwargsr
   c                    s   ddl m} t |}|d u r | g|R i |S t| jp"d}tjtj	||j
d  | g|R i |W  d    S 1 sCw   Y  d S )Nr   )DjangoIntegrationz<unknown Django task>)opnameorigin)sentry_sdk.integrations.djangor   
sentry_sdk
get_clientget_integrationr   func
start_spanr   QUEUE_SUBMIT_DJANGOr   )r   r   r   r   integrationr   old_task_enqueue a/home/ubuntu/veenaModal/venv/lib/python3.10/site-packages/sentry_sdk/integrations/django/tasks.py_sentry_enqueue   s   
$z$patch_tasks.<locals>._sentry_enqueue)r   r	   r   r	   r   r	   r
   r	   )r   enqueuer   )r   r   r   r   patch_tasks   s   
r    )r
   N)	functoolsr   r   sentry_sdk.constsr   sentry_sdk.tracingr   sentry_sdk.utilsr   django.tasks.baser   r   ImportErrortypingr   r	   r    r   r   r   r   <module>   s    