`iRPddlZddlZddlZddlmZddlmZmZddlm Z ddl m Z m Z m Z  ddlZddlmZn#e$r edwxYwddlmZmZer+dd lmZmZmZdd lmZdd lmZed ed efZdddefdZddZd dZ d!dZ!GddeZ"d"dZ#dS)#N)OP) Integration DidNotEnable) nullcontext)event_from_exceptionloggerreraise)Taskzasyncio not available)cast TYPE_CHECKING)AnyCallableTypeVar) Coroutine)ExcInfoT.)boundcoror returncJt|ddpt|ddpdS)N __qualname____name__zcoroutine without __name__)getattr)rs s/home/jaya/work/projects/VOICE-AGENT/VIET/agent-env/lib/python3.11/site-packages/sentry_sdk/integrations/asyncio.pyget_namers2nd++ ( 4T * * ( 'wrappedCoroutine[Any, Any, Any]Callable[[T], T]cFtjtj|ddS)N)rr)rassignedupdated) functoolspartialupdate_wrapper)rs r_wrap_coroutiner'#s+   -    rc d tj}|tddrdS dfd }d |_||dS#t $rtjd YdSwxYw)N_is_sentry_task_factoryFloopasyncio.AbstractEventLooprrkwargsr rasyncio.Future[Any]cFtdfd }d}r||fi|}|&t|fd|i|}|jr|jd= td|t dn#t $rYnwxYw|S) Nrr cKd}tjt}|r|jnd}tj5|r8tjtjttj n t5 d{V}n5#t$r}|dd}~wt$rttYnwxYwdddn #1swxYwYdddn #1swxYwY|S)NF)opnameorigin) sentry_sdk get_clientget_integrationAsyncioIntegration task_spansisolation_scope start_spanrFUNCTIONrr2rStopAsyncIteration Exceptionr _capture_exception)result integrationr7ers r_task_with_sentry_span_creationzTpatch_asyncio.._sentry_task_factory.._task_with_sentry_span_creation<s(355EE& 8CM[33 /11;;& + -!{!)$#5#< )]];;;+/ZZZZZZFF1..."#-(;;;#%7%9%9::::;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;" sgA C;C$B#"C$# C-B00"CC$CC$ C;$C( (C;+C( ,C;;C?C?r*zasyncio.Task[Any]z (Sentry-wrapped))rr )r'r _source_tracebackr set_namerAttributeError)r*rr,rAtaskorig_task_factorys ` r_sentry_task_factoryz+patch_asyncio.._sentry_task_factory7s! T " "     # " 6D! ((99;;?E|;;==SSDSFSS)3.r2 ($//88~~888"    Ks3B BBTzThere is no running asyncio loop so there is nothing Sentry can patch. Please make sure you call sentry_sdk.init() within a running asyncio loop for the AsyncioIntegration to work. See https://docs.sentry.io/platforms/python/integrations/asyncio/)r*r+rrr,r rr-) asyncioget_running_loopget_task_factoryrr)set_task_factory RuntimeErrorrwarning)r*rHrGs @r patch_asynciorO-sR ')) 1133 $&? G G  F> -> ,> > # > > > > > > @8<4 233333     P       s8A+*A++B  B rctj}tj}|t }|3t ||jddd\}}tj|||S)NrIF)typehandled)client_options mechanism)hint) sysexc_infor3r4r5r6roptions capture_event)rWclientr?eventrUs rr=r=s}|~~H  " $ $F(();<(U;;   t  T2222 OrcFeZdZdZdeZd deddfdZed dZdS) r6rIzauto.function.Tr7rNc||_dSN)r7)selfr7s r__init__zAsyncioIntegration.__init__s $rc"tdSr^)rOr!rr setup_oncezAsyncioIntegration.setup_oncesr)TrN) r __module__r identifierr2boolr` staticmethodrbr!rrr6r6smJ *j * *F%%4%4%%%%\rr6argsr,ctj}|sdStjdt |i|}|d|jvr ||jd<dSdS)a Enable AsyncioIntegration with the provided options. This is useful in scenarios where Sentry needs to be initialized before an event loop is set up, but you still want to instrument asyncio once there is an event loop. In that case, you can sentry_sdk.init() early on without the AsyncioIntegration and then, once the event loop has been set up, execute: ```python from sentry_sdk.integrations.asyncio import enable_asyncio_integration async def async_entrypoint(): enable_asyncio_integration() ``` Any arguments provided will be passed to AsyncioIntegration() as is. If AsyncioIntegration has already patched the current event loop, this function won't have any effect. If AsyncioIntegration was provided in sentry_sdk.init(disabled_integrations=[...]), this function will ignore that and the integration will be enabled. NzSetting up integration asynciorI)r3r4 is_activerdebugr6rb integrations)rhr,rZr?s renable_asyncio_integrationrms4 " $ $F      L1222$d5f55K+++)4I&&&,+r)rrrrrc)rr)rhr r,r rN)$rVr$r3sentry_sdk.constsrsentry_sdk.integrationsrr$sentry_sdk.integrations._wsgi_commonrsentry_sdk.utilsrrr rI asyncio.tasksr ImportErrortypingr r r rrcollections.abcrsentry_sdk._typesrrstrrr'rOr=r6rmr!rrrxs  ========<<<<<<BBBBBBBBBB0NNN"""""""000 ,. / //0'&&&&&&&/----------))))))))))))8CH-...A5ST T T T n"        *5*5*5*5*5*5s 7A