5IiN d dl Z d dlZd dlmZmZ d dlmZ d dlZd dlm Z d dl
m Z d dl m
Z
d dlmZ e
r*d dlmZ d d lmZ d d
lmZ d d lmZ d d lmZ d d
lmZ d dlmZ ddZedd ZdZdZd Z G d de Z dS ) N)ThreadLock)contextmanager)Envelope)Session)
TYPE_CHECKING)format_timestamp)Any)Callable)Dict) Generator)List)Optional)Unionc | t j j } | j j }|+| j r | j j ni }| dd }|S )z""&888!!(+++#:: ) ) ) ) / 5 5 7 7 J JME68>""&888!!(+++#:: ! !"9&%"H"H I I I I x~ " " h ' ' ' ' ' # "s 155c j t j k r j d S j 5 j t j k r j d d d d S fd}t | }d|_ | | _ t j _ d d d n # 1 swxY w Y d S )Nc j r=t j j j r j ;d S d S N)r> timesleepr7 rJ r? s r r: z/SessionFlusher._ensure_running.._threadr sW m %Jt 2333} %
m % % % % %r )targetT)r= osgetpidr: r; r daemonstart)r? r: threads ` r _ensure_runningz SessionFlusher._ensure_runningj s" 29;; . .4<3K4
/ /#ry{{22t|7O / / / / / / / /
%
%
%
%
% 7+++F FM LLNNN!DL#%9;;D / / / / / / / / / / / / / / / ts %B; AB;;B?B?c | j 5 | d }t t | }|j }| j |i }| |i }d|vrt |j |d< |j dk r |
dd dz |d< nl|j dk r |
dd dz |d< nD|j dk r |
dd dz |d< n |
d d dz |d < d d d d S # 1 swxY w Y d S )
NF)with_user_infostartedr( r r' erroredr& ) r< get_json_attrstuplesortedrC truncated_startedr9
setdefaultr statusr errors)r? rH r+ primary_key
secondary_keyrI states r add_aggregate_sessionz$SessionFlusher.add_aggregate_session s
! = =**%*@@E u{{}} 5 566K # 5M,77 RHHF%%mR88E%%#3G4M#N#Ni ~**#(99Y#:#:Q#>i :--$)IIj!$<$i "'))Ha"8"81"<h% = = = = = = = = = = = = = = = = = =s D,EEEc |j dk r| | n,| j | | d S )Nrequest)r# rg r8 appendto_jsonrW )r? rH s r rE zSessionFlusher.add_session sb 9 , , & &w / / / / ! ( ( ):): ; ; ; r c d| _ d S )NF)r> rP s r killzSessionFlusher.kill s
r c . | d S rM )rm rP s r __del__zSessionFlusher.__del__ s r N)r4 )
__name__
__module__ __qualname__r@ rJ rW rg rE rm ro r r r3 r3 > s ( ( (6 , = = => r r3 rM )Nr! ) rR rN threadingr r
contextlibr r sentry_sdk.enveloper sentry_sdk.sessionr sentry_sdk._typesr sentry_sdk.utilsr typingr
r r r
r r r r r TERMINAL_SESSION_STATESrD r1 objectr3 rs r r r} s " " " " " " " " % % % % % % ( ( ( ( ( ( & & & & & & + + + + + + - - - - - - < Q Q Q
q q q q qV q q q q qr