rhTUdZddlZddlZddlZddlmZddlmZmZm Z ddl m Z eje ZGddZeeeeeefe eee egdfZe ed<Gd d ZGd d Zy) a[Metrics collection and management system for Dynamo. This module provides context managers for gathering and reporting metrics during compilation and runtime. It includes two main components: - MetricsContext: A context manager for collecting metrics during compilation, supporting nested contexts and various metric types (counters, sets, key-value pairs) - RuntimeMetricsContext: A specialized context for runtime metrics collection that doesn't require explicit context management The metrics system enables comprehensive monitoring and analysis of both compilation and execution performance. N)Iterator)AnyCallableOptional) TypeAliascZeZdZdZd defdZdededdfdZdefd Zde e eeffd Z y) TopNz_ Helper to record a list of metrics, keeping only the top N "most expensive" elements. at_mostc ||_g|_yN)r heap)selfr s p/var/www/html/ai-insurance-compliance-backend/venv/lib/python3.12/site-packages/torch/_dynamo/metrics_context.py__init__z TopN.__init__ s +- keyvalreturnNct|j|jkrtjntj }||j||fyr )lenr r heapqheappush heappushpop)rrrfns raddzTopN.add$s8"499~ dt|jdDS)Nc3*K|] \}}||f ywr ).0rrs r z TopN.__iter__..-sKxsCc KsT)reverse)sortedr rs r__iter__z TopN.__iter__,sK6$))T+JKKr)) __name__ __module__ __qualname____doc__intrrrrrtupler&r!rrr r sT.."s""" L(5c?3Lrr OnExitTypec eZdZdefdZddZdeeedeede ddfd Z de fd Z d e d eddfd Zdd e d e de ddfdZd e de d e ddfdZddee e fde ddfdZdee e fddfdZd e d e ddfdZd e de deddfdZy)MetricsContexton_exitc<||_i|_d|_d|_y)aQ Use this class as a contextmanager to create a context under which to accumulate a set of metrics, e.g., metrics gathered during a compilation. On exit of the contextmanager, call the provided 'on_exit' function and pass a dictionary of all metrics set during the lifetime of the contextmanager. rN)_on_exit_metrics_start_time_ns_levelrr1s rrzMetricsContext.__init__7s!  (* #$ rrc|jdk(r i|_tj|_|xjdz c_|S)z/ Initialize metrics recording. r)r6r4timetime_nsr5rs r __enter__zMetricsContext.__enter__Cs8 ;;! DM"&,,.D  q  rexc_type exc_value _tracebackNc4|xjdzc_|jdk\sJ|jdk(r? tj}|j|j||j ||yy#t $rtjdYywxYw)z> At exit, call the provided on_exit function. r9rz0Unexpected exception logging compilation metricsN) r6r:r;r3r5r4 Exceptionlog exception)rr=r>r? end_time_nss r__exit__zMetricsContext.__exit__Os q {{a ;;!  R"lln  ''dmmXy   R PQ Rs=A66BBc |jdkDS)z4 True if we've entered the context. r)r6rs r in_progresszMetricsContext.in_progresscs{{Qrmetricvaluec|jdk(rtd|d||jvrd|j|<|j|xx|z cc<y)7 Increment a metric by a given amount. rzCannot increment  outside of a MetricsContextNr6 RuntimeErrorr4rrHrIs r incrementzMetricsContext.incrementisT ;;! !26(:VWX X  &$%DMM& ! f&r overwritec|jdk(rtd|d||jvr|std|d||j|<y)z Set a metric to a given value. Raises if the metric has been assigned previously in the current context. r Cannot set rLzMetric 'z-' has already been set in the current contextNrM)rrHrIrQs rsetzMetricsContext.setss] ;;! VH4PQR R T]] "96("OP !& frrc|jdk(rtd|d||jvri|j|<||j||<y)a= Treats a give metric as a dictionary and set the k and value within it. Note that the metric must be a dictionary or not present. We allow this to be called multiple times (i.e. for features, it's not uncommon for them to be used multiple times within a single compilation). rrSrLNrM)rrHrrIs r set_key_valuezMetricsContext.set_key_valuesR ;;! VH4PQR R  &$&DMM& !%* fc"rvaluesc|jdk(r td|jj|jz}|r|std|d|jj |y)z Set multiple metrics directly. This method does NOT increment. Raises if any metric has been assigned previously in the current context and overwrite is not set to True. r1Cannot update metrics outside of a MetricsContextz Metric(s) z- have already been set in the current contextN)r6rNr4keysupdate)rrWrQexistings rr[zMetricsContext.updatesl ;;! RS S==%%'&++-7 IXJ&ST  V$rcz|jdk(r td|jdk(r|j|yy)zA Update, but only when at the outermost context. rrYr9N)r6rNr[)rrWs r update_outerzMetricsContext.update_outers9 ;;! RS S ;;!  KK  rc|jdk(rtd|d||jvrt|j|<|j|j |y)z8 Records a metric as a set() of values. rz Cannot add rLN)r6rNr4rTrrOs r add_to_setzMetricsContext.add_to_setsX ;;! VH4PQR R  &$'EDMM& ! f!!%(rrc|jdk(ry||jvrt|j|<|j|j||y)z; Records a metric as a TopN set of values. rN)r6r4r r)rrHrrs r add_top_nzMetricsContext.add_top_nsH ;;!    &$(FDMM& ! f!!#s+r)rr0)F)r(r)r*r.rr<rtype BaseExceptionrrEboolrGstrr,rPrTrVdictr[r^r`rbr!rrr0r06s2   R4 ./RM*R R  R(T ''C'D' &# &c &d &t & +C +c +# +$ + %T#s(^ % % % 4S> d ))S)T),,#,C,D,rr0c LeZdZdefdZ d dededeeee fddfdZ d d Z y) RuntimeMetricsContextr1c.||_i|_d|_y)z Similar to MetricsContext, but used to gather the runtime metrics that are decoupled from compilation, where there's not a natural place to insert a context manager. rN)r3r4r5r7s rrzRuntimeMetricsContext.__init__s   (* #$rNrHrIextrarc.|jstj|_||jvrd|j|<|j|xx|z cc<|r:|j D]&\}}||jvs|||j|<(yy)rKrN)r4r:r;r5items)rrHrIrkkvs rrPzRuntimeMetricsContext.increments }}"&,,.D   &$%DMM& ! f&   )1DMM)am'(DMM!$ ) rc|jrF tj}|j|j||jddi|_yy#t $rt jdY)wxYw#i|_wxYw)zW Call the on_exit function with the metrics gathered so far and reset. Nz,Unexpected exception logging runtime metrics)r4r:r;r3r5rArBrC)rrDs rfinishzRuntimeMetricsContext.finishst == #"lln  ''dmmT4 !#    N LM N!# s#=AA52A84A55A88 Br )rN) r(r)r*r.rrfr,rrgrrPrqr!rrririsL% %JN))"%).6tCH~.F) )$ #rri)r+rloggingr:collections.abcrtypingrrrtyping_extensionsr getLoggerr(rBr r,rgrfrcrdr.__annotations__r0rir!rrrxs   $**'g!LL*!#tCH~x](;UV  I B,B,J*#*#r