← Back
Editing: worker.cpython-312.pyc
� ]*j�+ � �� � d dl Z d dlZd dlZd dlmZmZ d dlmZmZ d dlm Z d dl mZmZ d dl mZ d dlmZmZ e r d dlmZmZmZ e� Z G d � d e� Z G d� de� Z G d � de� Zy)� N)�ABC�abstractmethod)�sleep�time)� TYPE_CHECKING)� FullError�Queue)�DEFAULT_QUEUE_SIZE)�logger�mark_sentry_task_internal)�Any�Callable�Optionalc � � e Zd ZdZeedefd�� � Zed d�� Z dde ddddfd �Z edefd �� Zedddefd�� Zy)�WorkerzBase class for all workers.�returnc � � y)z(Whether the worker is alive and running.N� ��selfs �@/opt/hc_python/lib/python3.12/site-packages/sentry_sdk/worker.py�is_alivezWorker.is_alive s � � � Nc � � y)z5Kill the worker. It will not process any more events.Nr r s r �killzWorker.kill � � � r �timeout�callbackz%Optional[Callable[[int, float], Any]]c � � y)z<Flush the worker, blocking until done or timeout is reached.Nr �r r r s r �flushzWorker.flush! s � � r c � � y)z#Whether the worker's queue is full.Nr r s r �fullzWorker.full'