+j+ddlZddlZddlmZmZddlmZddlmZddl m Z ddl Z ddl m Z mZmZddlmZmZmZejd ZGd d ZeZdS) N)CallableMapping)contextmanager)cached_property)Any)FunctionConstraintsValidationResultvalidate_function_call)BackendNotFoundErrorBackendNotImplementedErrorNoCapableBackendErrorzcomfy_kitchen.dispatchc eZdZdZedeeefdzfdZdede ee ffdZ ded ede dzfd Z ded efd Z defd ZdefdZdeefdZdedefdZde fdZded edeeefdefdZ dd edeeefdzdefdZ dd ededzdeeefdzdefdZedefdZdS)BackendRegistryci|_i|_i|_gd|_t |_i|_tj|_ tj |_ dS)N)cudatritoneager) _backends _capabilities _constraints _priorityset _disabled _unavailable threadingLock_locklocal _thread_local)selfs Y/home/wildlama/comfy/ComfyUI/.venv/lib/python3.11/site-packages/comfy_kitchen/registry.py__init__zBackendRegistry.__init__s^444^%% &_..returnNctjr[ tjtj}|j|jfS#t$rYdSwxYwdSN)torchr is_availableget_device_propertiescurrent_devicemajorminor Exception)r!propss r"_compute_capabilityz#BackendRegistry._compute_capabilitysv : " " $ $   889R9R9T9TUU U[11   tt tsAA)) A76A7name capabilitiesc.|j5||j|<t||j|<|D]\}}||j||f<|j|dddddS#1swxYwYdS)a!Register a backend with its capabilities and constraints. Args: name: Backend name (e.g., "cuda", "eager", "triton") module: The backend module containing implementations capabilities: Dict mapping function names to FunctionConstraints N) rrrkeysritemsrrpop)r!r1moduler2 func_name constraintss r"registerzBackendRegistry.register)sZ . .#)DN4 '*<+<+<+>+>'?'?D t $*6*<*<*>*> C C& ;7B!4"344   ! !$ - - -  . . . . . . . . . . . . . . . . . .sA5B  BB backend_namer8c:|j||fS)z5Get constraints for a specific backend/function pair.)rget)r!r;r8s r"get_constraintszBackendRegistry.get_constraints=s  $$lI%>???r$reasoncZ|j5||j|<ddddS#1swxYwYdS)zMark a backend as unavailable with a reason. Args: name: Backend name reason: Why the backend is unavailable (e.g., "ImportError: ...") N)rr)r!r1r?s r"mark_unavailablez BackendRegistry.mark_unavailableCs}Z - -&,D d # - - - - - - - - - - - - - - - - - -s $$cz|j5|j|ddddS#1swxYwYdS)zhManually disable a backend. Args: backend_name: Name of backend to disable N)rraddr!r;s r"disablezBackendRegistry.disableMs Z - - N  | , , , - - - - - - - - - - - - - - - - - - 044cz|j5|j|ddddS#1swxYwYdS)ztRe-enable a previously disabled backend. Args: backend_name: Name of backend to enable N)rrdiscardrDs r"enablezBackendRegistry.enableVs Z 1 1 N " "< 0 0 0 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1rF priority_listcn|j5t||_ddddS#1swxYwYdS)zSet backend selection priority order. Args: priority_list: List of backend names in priority order N)rlistr)r!rJs r" set_priorityzBackendRegistry.set_priority_s Z 1 1!-00DN 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1s *..c&||jvo||jvS)zCheck if backend is available and not disabled. Args: backend_name: Name of backend to check Returns: True if backend is registered and not disabled )rrrDs r"r)zBackendRegistry.is_availablehst~-T,dn2TTr$c i}t|jt|jzt|jz}|D]X}||jv||jv|j|t|j|gd||<Y|S)aReturn dict of all backends with their status. Returns: Dict mapping backend names to status info: { "backend_name": { "available": bool, "disabled": bool, "unavailable_reason": str or None, "capabilities": list[str] } } ) availabledisabledunavailable_reasonr2) rrrr4rrr=sortedr)r!resultall_backend_namesr1s r" list_backendszBackendRegistry.list_backendsss   #dn&9&9&;&;"<"< $LL!H(T]^^^#O(.(;%V%Vv?T%V%V"" DhPYZZZ!N L$$\22  2 6 6|SUU K KKK 77 iQWXX~060C-^-^vG\-^-^H\* LL5|Y O O O   #Ix888r$backendc(|r||jvr)t||j|d||jvrt|d||j|t vrt|||r?||||}|j s!t|||j d|j it|j||S|||}t|j||S)a=Get the best implementation for a function. Args: func_name: Name of the function to get backend: Explicit backend to use, or None for auto-select kwargs: Kwargs for constraint validation (empty/None skips validation) Returns: The function implementation Raises: BackendNotFoundError: If explicit backend is not available BackendNotImplementedError: If explicit backend doesn't implement function NoCapableBackendError: If no backend can handle the call not registeredrQrc)rr rr=rrrr r`rfrrirjrern)r!r8rorWrTselected_backends r"get_implementationz"BackendRegistry.get_implementations&*  ?dn,,*7D4E4I4I'Sc4d4deee$.((*7J??? 2 6 6w F FFF0)DDD y77FSS~y/ GH[EvEv_e_tEvEv;wxxx4>'2I>> >33IvFFt~&67CCCr$c#K||sO||jvr|j|}t||||jvrt|dt|dt |jdd}||j_ dV|t|jddS||j_dS#|t|jdn ||j_wxYw)zContext manager to temporarily use a specific backend. Args: backend_name: Name of backend to use in this context Example: with registry.use_backend("eager"): result = some_function() rQrqrbN)r)rr rrer rbdelattr)r!r;r?previouss r" use_backendzBackendRegistry.use_backends  .. Kt000*<8*<@@@//*<DDD*<9IJJJ4-/A4HH.:+ ? EEE*,>?????6>"333*,>????6>"3>>>>s B55&Cr')NN)__name__ __module__ __qualname__r#rtupleintr0strdictr r:r>rArErIrLrMrdr)rVrrr r`rnrrsrrwr$r"rrs///U38_t%;_..3 334 ....(@@,/@ t #@@@@ -S-#-----C----1311111$s)1111 U U U U U Ut:" " " S! "  " " " " N,0595959S!D(59 59595959t#+/ #D#D#Dt#DS!D( #D  #D#D#D#DJ????^???r$r)loggingrcollections.abcrr contextlibr functoolsrtypingrr(r9r r r exceptionsr r r getLoggerrgrregistryrr$r"rs--------%%%%%%%%%%%% VVVVVVVVVV  3 4 4\?\?\?\?\?\?\?\?~ ?  r$