We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 2b37852 commit a174581Copy full SHA for a174581
1 file changed
sentry_sdk/_span_batcher.py
@@ -51,7 +51,7 @@ def __init__(
51
self._active: "threading.local" = threading.local()
52
53
self._last_full_flush: float = time.monotonic() # drives time-based flushes
54
- self._flush_event: threading.Event = threading.Event()
+ self._flush_event = threading.Event()
55
self._pending_flush: set[str] = set() # buckets to be flushed
56
57
self._flusher: "Optional[threading.Thread]" = None
@@ -76,7 +76,9 @@ def _reset_thread_state(self) -> None:
76
self._lock = threading.Lock()
77
self._active = threading.local()
78
79
+ self._last_full_flush: float = time.monotonic()
80
self._flush_event = threading.Event()
81
+ self._pending_flush: set[str] = set()
82
83
self._flusher = None
84
self._flusher_pid = None
0 commit comments