aDriv4 website!

Linux premium231.web-hosting.com 4.18.0-553.45.1.lve.el8.x86_64 #1 SMP Wed Mar 26 12:08:09 UTC 2025 x86_64
LiteSpeed
66.29.146.61

worker.py

import os
import threading

from time import sleep, time
from sentry_sdk._compat import check_thread_support
from sentry_sdk._queue import Queue, FullError
from sentry_sdk.utils import logger
from sentry_sdk.consts import DEFAULT_QUEUE_SIZE

from sentry_sdk._types import TYPE_CHECKING

if TYPE_CHECKING:
    from typing import Any
    from typing import Optional
    from typing import Callable

_TERMINATOR = object()

class BackgroundWorker(object):
    def __init__(self, queue_size=DEFAULT_QUEUE_SIZE):
        # type: (int) -> None
        check_thread_support()
        self._queue = Queue(queue_size)  # type: Queue
        self._lock = threading.Lock()
        self._thread = None  # type: Optional[threading.Thread]
        self._thread_for_pid = None  # type: Optional[int]

@property
    def is_alive(self):
        # type: () -> bool
        if self._thread_for_pid != os.getpid():
            return False
        if not self._thread:
            return False
        return self._thread.is_alive()

def _ensure_thread(self):
        # type: () -> None
        if not self.is_alive:
            self.start()

def _timed_queue_join(self, timeout):
        # type: (float) -> bool
        deadline = time() + timeout
        queue = self._queue

queue.all_tasks_done.acquire()

try:
            while queue.unfinished_tasks:
                delay = deadline - time()
                if delay <= 0:
                    return False
                queue.all_tasks_done.wait(timeout=delay)

return True
        finally:
            queue.all_tasks_done.release()

def start(self):
        # type: () -> None
        with self._lock:
            if not self.is_alive:
                self._thread = threading.Thread(
                    target=self._target, name="raven-sentry.BackgroundWorker"
                )
                self._thread.daemon = True
                self._thread.start()
                self._thread_for_pid = os.getpid()

def kill(self):
        # type: () -> None
        """
        Kill worker thread. Returns immediately. Not useful for
        waiting on shutdown for events, use `flush` for that.
        """
        logger.debug("background worker got kill request")
        with self._lock:
            if self._thread:
                try:
                    self._queue.put_nowait(_TERMINATOR)
                except FullError:
                    logger.debug("background worker queue full, kill failed")

self._thread = None
                self._thread_for_pid = None

def flush(self, timeout, callback=None):
        # type: (float, Optional[Any]) -> None
        logger.debug("background worker got flush request")
        with self._lock:
            if self.is_alive and timeout > 0.0:
                self._wait_flush(timeout, callback)
        logger.debug("background worker flushed")

def full(self):
        # type: () -> bool
        return self._queue.full()

def _wait_flush(self, timeout, callback):
        # type: (float, Optional[Any]) -> None
        initial_timeout = min(0.1, timeout)
        if not self._timed_queue_join(initial_timeout):
            pending = self._queue.qsize() + 1
            logger.debug("%d event(s) pending on flush", pending)
            if callback is not None:
                callback(pending, timeout)

if not self._timed_queue_join(timeout - initial_timeout):
                pending = self._queue.qsize() + 1
                logger.error("flush timed out, dropped %s events", pending)

def submit(self, callback):
        # type: (Callable[[], None]) -> bool
        self._ensure_thread()
        try:
            self._queue.put_nowait(callback)
            return True
        except FullError:
            return False

def _target(self):
        # type: () -> None
        while True:
            callback = self._queue.get()
            try:
                if callback is _TERMINATOR:
                    break
                try:
                    callback()
                except Exception:
                    logger.error("Failed processing job", exc_info=True)
            finally:
                self._queue.task_done()
            sleep(0)

Name	Type	Size	Owner/Group	Permission	Last Modified	Actions
.	dir	-	root/root	0755	2026-02-05 09:38:42
..	dir	-	root/root	0755	2026-02-05 09:39:01
__pycache__	dir	-	root/root	0755	2026-02-05 09:48:00
crons	dir	-	root/root	0755	2026-02-05 09:38:42
integrations	dir	-	root/root	0755	2026-02-05 09:38:42
__init__.py	text/x-script.python	1.03 KB	root/root	0644	2026-01-20 01:01:48
_compat.py	text/x-script.python	2.73 KB	root/root	0644	2026-01-20 01:01:48
_functools.py	text/plain	4.84 KB	root/root	0644	2026-01-20 01:01:48
_lru_cache.py	text/plain	5.26 KB	root/root	0644	2026-01-20 01:01:48
_queue.py	text/plain	11 KB	root/root	0644	2026-01-20 01:01:48
_types.py	text/x-script.python	2.19 KB	root/root	0644	2026-01-20 01:01:48
_werkzeug.py	text/plain	3.7 KB	root/root	0644	2026-01-20 01:01:48
api.py	text/x-script.python	6.05 KB	root/root	0644	2026-01-20 01:01:48
attachments.py	text/x-script.python	1.77 KB	root/root	0644	2026-01-20 01:01:48
client.py	text/x-script.python	22.35 KB	root/root	0644	2026-01-20 01:01:48
consts.py	text/x-script.python	8.49 KB	root/root	0644	2026-01-20 01:01:48
debug.py	text/x-script.python	1.11 KB	root/root	0644	2026-01-20 01:01:48
envelope.py	text/x-script.python	9.37 KB	root/root	0644	2026-01-20 01:01:48
hub.py	text/x-script.python	26.42 KB	root/root	0644	2026-01-20 01:01:48
monitor.py	text/x-script.python	2.97 KB	root/root	0644	2026-01-20 01:01:48
profiler.py	text/plain	33.18 KB	root/root	0644	2026-01-20 01:01:48
py.typed	application/x-empty	0 B	root/root	0644	2026-01-20 01:01:48
scope.py	text/x-script.python	24.26 KB	root/root	0644	2026-01-20 01:01:48
scrubber.py	text/x-script.python	3.8 KB	root/root	0644	2026-01-20 01:01:48
serializer.py	text/x-script.python	12.97 KB	root/root	0644	2026-01-20 01:01:48
session.py	text/x-script.python	5.43 KB	root/root	0644	2026-01-20 01:01:48
sessions.py	text/x-script.python	5.76 KB	root/root	0644	2026-01-20 01:01:48
tracing.py	text/x-script.python	29.04 KB	root/root	0644	2026-01-20 01:01:48
tracing_utils.py	text/x-script.python	12 KB	root/root	0644	2026-01-20 01:01:48
tracing_utils_py2.py	text/x-script.python	1.21 KB	root/root	0644	2026-01-20 01:01:48
tracing_utils_py3.py	text/x-script.python	2.1 KB	root/root	0644	2026-01-20 01:01:48
transport.py	text/x-script.python	18.13 KB	root/root	0644	2026-01-20 01:01:48
utils.py	text/x-script.python	45.58 KB	root/root	0644	2026-01-20 01:01:48
worker.py	text/x-script.python	4.15 KB	root/root	0644	2026-01-20 01:01:48

For more Private tool come to me!

https://t.me/aDriv4vz