@@ -461,49 +461,6 @@ class AgentKernelRegistryKey:
461461 kernel_id : KernelId
462462
463463
464- class KernelRegistry (MutableMapping [AgentKernelRegistryKey , AbstractKernel ]):
465- _registry : MutableMapping [AgentKernelRegistryKey , AbstractKernel ]
466- _global_registry : MutableMapping [KernelId , AbstractKernel ]
467-
468- def __init__ (self ) -> None :
469- super ().__init__ ()
470-
471- self ._registry = {}
472- self ._global_registry = {}
473-
474- def agent_mapping (self , agent_id : AgentId ) -> "KernelRegistryAgentMapping" :
475- return KernelRegistryAgentMapping (self , agent_id )
476-
477- def global_view (self ) -> "KernelRegistryGlobalView" :
478- return KernelRegistryGlobalView (self )
479-
480- @overload
481- def __getitem__ (self , key : KernelId ) -> AbstractKernel : ...
482-
483- @overload
484- def __getitem__ (self , key : AgentKernelRegistryKey ) -> AbstractKernel : ...
485-
486- def __getitem__ (self , key : KernelId | AgentKernelRegistryKey ) -> AbstractKernel :
487- if isinstance (key , AgentKernelRegistryKey ):
488- return self ._registry [key ]
489- else :
490- return self ._global_registry [key ]
491-
492- def __setitem__ (self , key : AgentKernelRegistryKey , value : AbstractKernel ) -> None :
493- self ._registry [key ] = value
494- self ._global_registry [key .kernel_id ] = value
495-
496- def __delitem__ (self , key : AgentKernelRegistryKey ) -> None :
497- del self ._registry [key ]
498- del self ._global_registry [key .kernel_id ]
499-
500- def __iter__ (self ) -> Iterator [AgentKernelRegistryKey ]:
501- return iter (self ._registry )
502-
503- def __len__ (self ) -> int :
504- return len (self ._registry )
505-
506-
507464class KernelRegistryAgentMapping (MutableMapping [KernelId , AbstractKernel ]):
508465 _registry : KernelRegistry
509466 _agent_id : AgentId
@@ -551,6 +508,49 @@ def __len__(self) -> int:
551508 return len (self ._registry )
552509
553510
511+ class KernelRegistry (MutableMapping [AgentKernelRegistryKey , AbstractKernel ]):
512+ _registry : MutableMapping [AgentKernelRegistryKey , AbstractKernel ]
513+ _global_registry : MutableMapping [KernelId , AbstractKernel ]
514+
515+ def __init__ (self ) -> None :
516+ super ().__init__ ()
517+
518+ self ._registry = {}
519+ self ._global_registry = {}
520+
521+ def agent_mapping (self , agent_id : AgentId ) -> KernelRegistryAgentMapping :
522+ return KernelRegistryAgentMapping (self , agent_id )
523+
524+ def global_view (self ) -> KernelRegistryGlobalView :
525+ return KernelRegistryGlobalView (self )
526+
527+ @overload
528+ def __getitem__ (self , key : KernelId ) -> AbstractKernel : ...
529+
530+ @overload
531+ def __getitem__ (self , key : AgentKernelRegistryKey ) -> AbstractKernel : ...
532+
533+ def __getitem__ (self , key : KernelId | AgentKernelRegistryKey ) -> AbstractKernel :
534+ if isinstance (key , AgentKernelRegistryKey ):
535+ return self ._registry [key ]
536+ else :
537+ return self ._global_registry [key ]
538+
539+ def __setitem__ (self , key : AgentKernelRegistryKey , value : AbstractKernel ) -> None :
540+ self ._registry [key ] = value
541+ self ._global_registry [key .kernel_id ] = value
542+
543+ def __delitem__ (self , key : AgentKernelRegistryKey ) -> None :
544+ del self ._registry [key ]
545+ del self ._global_registry [key .kernel_id ]
546+
547+ def __iter__ (self ) -> Iterator [AgentKernelRegistryKey ]:
548+ return iter (self ._registry )
549+
550+ def __len__ (self ) -> int :
551+ return len (self ._registry )
552+
553+
554554_zctx = None
555555
556556
0 commit comments