U ��\� �@s^ddlZddlmZmZddlmZmZddlmZmZddl m Z e�ZGdd�de�ZdS)�N)�Thread�Lock)�sleep�time)�queue�check_thread_support)�loggerc@sbeZdZdd�Zedd��Zdd�Zdd�Zd d �Zdd�Z ddd�Z dd�Zdd�Zdd�Z d S)�BackgroundWorkercCs*t�t�d�|_t�|_d|_d|_dS)N��)rr�Queue�_queuer�_lock�_thread�_thread_for_pid��self�r�B/opt/alt/python38/lib/python3.8/site-packages/sentry_sdk/worker.py�__init__s zBackgroundWorker.__init__cCs&|jt��krdS|jsdS|j��S)NF)r�os�getpidr�is_aliverrrrrs zBackgroundWorker.is_alivecCs|js|��dS�N)r�startrrrr�_ensure_thread$szBackgroundWorker._ensure_threadcCsdt�|}|j}|j��z8|jrL|t�}|dkrt|jdd�|_|j�d�|j��t��|_ W5QRXdS)Nzraven-sentry.BackgroundWorker)�target�nameT) r rr�_targetr� setDaemonrrrrrrrrr8s� zBackgroundWorker.startc Cs>t�d�|j�$|jr0|j�t�d|_d|_W5QRXdS)Nz"background worker got kill request)r�debugr rr� put_nowait�_TERMINATORrrrrr�killCs zBackgroundWorker.killNc CsDt�d�|j� |jr,|dkr,|�||�W5QRXt�d�dS)Nz#background worker got flush requestgzbackground worker flushed)rr%r r�_wait_flush)rr�callbackrrr�flushLs zBackgroundWorker.flushcCsNtd|�}|�|�sJ|j��}t�d|�|dk r<|||�|�||�dS)Ng��?z%d event(s) pending on flush)�minr rZqsizerr%)rrr*Zinitial_timeout�pendingrrrr)Ts zBackgroundWorker._wait_flushcCs|��|j�|�dSr)rrr&�rr*rrr�submit^szBackgroundWorker.submitcCsf|j��}z@|tkrW�4qbz |�Wn"tk rFtjddd�YnXW5|j��Xtd�qdS)NzFailed processing jobT)�exc_infor)r�getZ task_doner'� Exceptionr�errorrr.rrrr#cs zBackgroundWorker._target)N)�__name__� __module__�__qualname__r�propertyrrr rr(r+r)r/r#rrrrr s r )r� threadingrrrrZsentry_sdk._compatrrZsentry_sdk.utilsrrZAny�Optional�Callable�objectr'r rrrr�s