j HUdZddlZddlZddlZddlmZmZmZmZejZ iZ ee ee effe d<gZeee gdfe d<ejGddZde d ed e d eed e d df dZdee gdfd dfdZd ee ee efffdZded eefdZy)z3In-memory entrypoint registry for the local runner.N)AnyCallableDictListREGISTRY _listenersc&eZdZUeed<dZeed<y)ParamnamestrtypeN)__name__ __module__ __qualname__r __annotations__r m/Users/manta/Documents/Projects/TheRoad-I1/backend/.venv/lib/python3.12/site-packages/opik/runner/registry.pyr r s ID#rr r funcprojectparams docstringreturnct5|||||dt|<tt}dddD] }|| y#1swYxYw)N)rr rrr)_lockrlistr)r rrrr listenerslisteners rregisterrsM "  $   s >Arcdt5tj|dddy#1swYyxYwN)rrappend)rs r on_registerr#(s (# s&/cXt5ttcdddS#1swYyxYwr!)rdictrrrrget_allr&-s H~ s )fnc`tj|}g}|jjD]y\}}|jtj j urd}n/|j}t|dr |jn t|}|jt||{|S)Nr r)r r ) inspect signature parametersitems annotation Parameteremptyhasattrrr r"r )r'sigr param_nameparam type_nameanns rextract_paramsr62s   B CF ^^113 E   w0066 6I""C(/Z(@ c#hI e)<= 4 Mr)__doc__ dataclassesr) threadingtypingrrrrLockrrr rr dataclassr rr#r&r6rrrr=s9,, &($sDcN" #(*, D3%+& ',     K     *$(C5$;/$D$ c4S>)* x DK r