s
Z 3 3=
3 ( / <.M '+ # ""$$$')y{{$ 3 3 3 3 3 3 3 3 3 3 3 3 3 3 3 3 3 3s A%A::A>A>c " t j d | j 5 | j rS | j t n$# t $ r t j d Y nw xY wd| _ d| _ ddd dS # 1 swxY w Y dS )z
Kill worker thread. Returns immediately. Not useful for
waiting on shutdown for events, use `flush` for that.
z"background worker got kill requestz)background worker queue full, kill failedN) r debugr r r
put_nowait _TERMINATORr r r! s r killzBackgroundWorker.killI s 9:::
Z , ,|
,NK**;7777 N N NL!LMMMMMN $ '+$ , , , , , , , , , , , , , , , , , ,s4 B AB A&#B%A&&BB BNc t j d | j 5 | j r |dk r| || d d d n # 1 swxY w Y t j d d S )Nz#background worker got flush requestg zbackground worker flushed)r r7 r r _wait_flush)r r& callbacks r flushzBackgroundWorker.flushZ s :;;;
Z 4 4}
43 (333 4 4 4 4 4 4 4 4 4 4 4 4 4 4 4 011111s $A AAc 4 | j S r )r fullr! s r r@ zBackgroundWorker.fullb s { !!!r c h t d| }| | s| j dz }t j d| | ||| | ||z
s5| j dz }t j d| d S d S d S )Ng? z %d event(s) pending on flushz"flush timed out, dropped %s events)minr/ r qsizer r7 error)r r& r= initial_timeoutpendings r r< z BackgroundWorker._wait_flushf s c7++%%o66 Lk''))A-G L7 A A A#'***))'O*CDD
L +++--1 A7KKKKK L L
L
Lr c | | j | dS # t $ r Y dS w xY w)NTF)r$ r r8 r r r= s r submitzBackgroundWorker.submits sV K " "8 , , ,4 55 s 2
A A c v | j } |t u r | j d S | n&# t $ r t j dd Y nw xY w| j n # | j w xY wt d )NTzFailed processing job)exc_infor )r getr9 task_done Exceptionr rE r rI s r r4 zBackgroundWorker._target| s {((H
({** %%''''' I HJJJJ I I IL!84HHHHHHI %%'''' %%'''' !HHH s/ B
A
B
A0-B
/A00B
B(r )__name__
__module__ __qualname__r r propertyr r$ r/ r# r: r> r@ r< rJ r4 r r r r s "4 $ $ $ $ ' ' X'
+ + +$ 3 3 3, , ,"2 2 2 2" " " L L L
r r )r r r r sentry_sdk._compatr sentry_sdk._queuer r sentry_sdk.utilsr sentry_sdk.constsr sentry_sdk._typesr
typingr r r
objectr9 r rT r r r\ s 3 3 3 3 3 3 . . . . . . . . # # # # # # 0 0 0 0 0 0 + + + + + + fhh t t t t tv t t t t tr