o Ơi@s>UddlZddlZddlZddlZddlZddlmZddlm Z m Z e e Z edddZeejdejejfed<ejdejdejfd Zd Zeed <e d d GdddejeZe d d GdddZddZe d d GdddZGdddZdejdefddZejdde dedej!fddZ"dS) N) ContextVar) dataclassfield _CALLBACKS)defaultObserverTObserverCallback.)boundFRETHROW_CALLBACK_EXCEPTIONT)frozenc@sheZdZUdZdZeed<edddZe ed<de d e j fd d Z dd dZd e je jfddZd S)rz Usage: >>> some_observer: Observer = ... >>> with some_observer.add(callback_func): >>> # do stuff, and when some_observer.observe() is called, >>> # it will execute callback_func() >>> ... namecCstSN)objectrrR/home/ubuntu/.local/lib/python3.10/site-packages/torch_tensorrt/dynamo/observer.py+szObserver.)default_factory unique_idcallbackreturncs(tjfdd}|S)Nc3s\zdVWz WdStyYdSwz Wwty-Ywwr)_get_callbacksremove ValueErrorrrselfrr_add3s  zObserver.add.._add)rappend contextlibcontextmanager)rrrrrradd-s z Observer.addNc OsL|D]}tdtd||i|Wdn1swYqdS)NzError calling observer callback)rethrow)r _log_errorr )rargskwargsrrrrobserveBs zObserver.observecCs6t}|duri}t|||vrg||<||S)z Gets the callbacks registered in current execution context. Any code that manipulates the returned list (add, remove, iterate) is concurrency safe. N)rgetset)rcallbacks_dictrrrrIs zObserver._get_callbacks)rN)__name__ __module__ __qualname____doc__r str__annotations__rrrrtContextManagerr r%ListCallablerrrrrrs   c@sNeZdZUdZejed<ejejed<ej e ejfed<dZ ejed<dS)ObserveContexta Passed to the registered callables that observes any function decorated by `observable`. See `observable` for detail. Attributes: callable: the observed callable object args: the args passed to the callable kwargs: the kwargs passed to the callable return_value: the return value returned by the callable, only available when observing the callable after its invocation (via `CallableObservers.post`) callabler#r$N return_value) r)r*r+r,r/r2r.r1AnyMappingr-r5rrrrr3Zs  r3cCsdtdtfdd}|S)a A decorator to turn a function into observable Example: >>> @observable() >>> def func_to_observe(x, y) -> int: >>> ... >>> >>> def log(ctx: ObserveContext): >>> print( >>> f"called {ctx.callable.__name__} with {ctx.args} {ctx.kwargs}" >>> ) >>> >>> # register: >>> with func_to_observe.observers.pre.add(log): >>> func_to_observe(1, 2) >>> # print out "called func_to_observe with (1,2) >>> # here it won't print observed_funcrcSst|d}t||S)N) orig_func)_make_observable functoolswraps)r8 wrapped_funcrrr decorators zobservable..decorator)r4ObservedCallable)r>rrr observableosr@c@s>eZdZUeejegdfed<eejegdfed<dS)CallableObserversNprepost)r)r*r+rr/r2r3r.rrrrrAs rAc@s2eZdZUdZeed<eed<dejfddZ dS)r?z, Interface for an observed callable observersr9rcOstr)NotImplementedError)rr#r$rrr__call__szObservedCallable.__call__N) r)r*r+r,rAr.r4r/r6rFrrrrr?s r?r9rcs8tttdtfdd}|_|_|S)z; A wrapper for a callable which is to be observed. )rBrCc s\jt||d}z|i|}|Wjt|||Sjt|||wr)rBr%r3rC)r#r$r5rDr9rrr8s  z'_make_observable..observed_func)rArr;r<r9rD)r9r8rrGrr:s r:msgr!c csXzdVWdSty+}z|}t|dt|r WYd}~dSd}~ww)Nz (This error is handled): ) Exception_LOGGERinfo traceback format_exc)rHr!e_errrr"s r")F)#rr;loggingrLtypingr/ contextvarsr dataclassesrr getLoggerr)rJrDictr1r2r.TypeVarr6rr boolGenericrr3r@rAr?r:rr-r0r"rrrrs0   $ >