§ <ˆj ãó —ddlZddlZddlmZmZddlmZddlZddlm Z ddl m Z ddl m Z ddlmZe r*ddlmZdd lmZdd lmZdd lmZdd lmZdd lmZddlmZdd„Zedd„¦«ZdZdZd„ZGd„de¦«ZdS)éN)ÚThreadÚLock)Úcontextmanager)ÚEnvelope)ÚSession)Ú TYPE_CHECKING)Úformat_timestamp)ÚAny)ÚCallable)ÚDict)Ú Generator)ÚList)ÚOptional)ÚUnioncóž—|€tjj}|jj}|€+|jr |jjni}| dd¦«}|S)zÑ"Ô"Õ&8Ò8Ð8Ø×!Ò! (Ñ+Ô+Ð+Ý#™:œ:�à × Ò  Ñ )Ô )Ð )Ð )à/×5Ò5Ñ7Ô7ð Jð J‰MˆE�6Ý�8”>Ñ"Ô"Õ&8Ò8Ð8Ø×!Ò! (Ñ+Ô+Ð+Ý#™:œ:�à × !Ò !Õ"9¸&À%Ñ"HÔ"HÑ IÔ IÐ IÐ Iå ˆxŒ~Ñ Ô  Ò "Ð "Ø × Ò ˜hÑ 'Ô 'Ð 'Ð 'Ð 'ð #Ð "s –1±5¸5có�‡—‰jtj¦«kr ‰j�dS‰j5‰jtj¦«kr‰j� ddd¦«dSˆfd„}t |¬¦«}d|_| ¦«|‰_tj¦«‰_ddd¦«n #1swxYwYdS)Ncó�•—‰jr=tj‰j¦«‰jr‰ ¦«‰j°;dSdS©N)r>ÚtimeÚsleepr7rJ©r?s€rr:z/SessionFlusher._ensure_running.._threadrsWø€à”mð%Ý”J˜tÔ2Ñ3Ô3Ð3Ø”}ð%ØŸ š ™ œ ˜ ð”mð%ð%ð%ð%ð%r )ÚtargetT)r=ÚosÚgetpidr:r;rÚdaemonÚstart)r?r:Úthreads` rÚ_ensure_runningzSessionFlusher._ensure_runningjs"ø€à Ô ¥2¤9¡;¤;Ò .Ð .°4´<Ð3KØ�4Ø Ô ð /ð /ØÔ#¥r¤y¡{¤{Ò2Ð2°t´|Ð7OØð /ð /ð /ñ /ô /ð /ð /ð /ð %ð %ð %ð %ð %õ 7Ð+Ñ+Ô+ˆFØ ˆFŒMØ �LŠL‰NŒNˆNØ!ˆDŒLÝ#%¤9¡;¤;ˆDÔ ð /ð /ð /ñ /ô /ð /ð /ð /ð /ð /ð /øøøð /ð /ð /ð /ð ˆts®%B;Á AB;Â;B?ÃB?cóœ—|j5| d¬¦«}tt| ¦«¦«¦«}|j}|j |i¦«}| |i¦«}d|vrt|j¦«|d<|j dkr|  dd¦«dz|d<nl|j dkr|  dd¦«dz|d<nD|j dkr|  dd¦«dz|d<n|  d d¦«dz|d <ddd¦«dS#1swxYwYdS) NF)Úwith_user_infoÚstartedr(rér'Úerroredr&) r<Úget_json_attrsÚtupleÚsortedrCÚtruncated_startedr9Ú setdefaultr ÚstatusrÚerrors)r?rHr+Ú primary_keyÚ secondary_keyrIÚstates rÚadd_aggregate_sessionz$SessionFlusher.add_aggregate_session€sž€ðÔ !ð =ð =Ø×*Ò*¸%Ð*Ñ@Ô@ˆEÝ¥ u§{¢{¡}¤}Ñ 5Ô 5Ñ6Ô6ˆKØ#Ô5ˆMØÔ,×7Ò7¸ ÀRÑHÔHˆFØ×%Ò% m°RÑ8Ô8ˆEà Ð%Ð%Ý#3°GÔ4MÑ#NÔ#N��iÑ ðŒ~ Ò*Ð*Ø#(§9¢9¨Y¸Ñ#:Ô#:¸QÑ#>��iÑ Ð Ø” :Ò-Ð-Ø$)§I¢I¨j¸!Ñ$<Ô$<¸qÑ$@��jÑ!Ð!Ø” !Ò#Ð#Ø#(§9¢9¨Y¸Ñ#:Ô#:¸QÑ#>��iÑ Ð à"'§)¢)¨H°aÑ"8Ô"8¸1Ñ"<��h‘ð% =ð =ð =ñ =ô =ð =ð =ð =ð =ð =ð =ð =øøøð =ð =ð =ð =ð =ð =sˆD,EÅEÅEcóÈ—|jdkr| |¦«n,|j | ¦«¦«| ¦«dS)NÚrequest)r#rgr8ÚappendÚto_jsonrW)r?rHs rrEzSessionFlusher.add_sessionŸsb€ð Ô  9Ò ,Ð ,Ø × &Ò & wÑ /Ô /Ð /Ð /à Ô !× (Ò (¨¯ªÑ):Ô):Ñ ;Ô ;Ð ;Ø ×ÒÑÔÐÐÐr có—d|_dS)NF)r>rPs rÚkillzSessionFlusher.kill©s €àˆŒ ˆ ˆ r có.—| ¦«dSrM)rmrPs rÚ__del__zSessionFlusher.__del__­s€à � Š ‰ Œ ˆ ˆ ˆ r N)r4) Ú__name__Ú __module__Ú __qualname__r@rJrWrgrErmro©r rr3r3>s‡€€€€€ðððððð (ð(ð(ð6ððð,=ð=ð=ð>ððððððððððr r3rM)Nr!)rRrNÚ threadingrrÚ contextlibrrÚsentry_sdk.enveloperÚsentry_sdk.sessionrÚsentry_sdk._typesrÚsentry_sdk.utilsr Útypingr r r r rrrrrÚTERMINAL_SESSION_STATESrDr1Úobjectr3rsr rúr}s­ðØ € € € Ø € € € Ø"Ð"Ð"Ð"Ð"Ð"Ð"Ð"Ø%Ð%Ð%Ð%Ð%Ð%àÐÐÐØ(Ð(Ð(Ð(Ð(Ð(Ø&Ð&Ð&Ð&Ð&Ð&Ø+Ð+Ð+Ð+Ð+Ð+Ø-Ð-Ð-Ð-Ð-Ð-àðØÐÐÐÐÐØÐÐÐÐÐØÐÐÐÐÐØ Ð Ð Ð Ð Ð ØÐÐÐÐÐØÐÐÐÐÐØÐÐÐÐÐð ð ð ð ðð ð ð ñ„ð ð<ÐØÐðQðQðQð qðqðqðqðq�Vñqôqðqðqðqr