bi&dZddlZddlZddlZddlZddlmZejdZGddejjejjZ y)zBase class to manage commsN)Commzipykernel.commceZdZdZej dZejZejZ dZ dZ y) CommManagerzA comm manager.zipykernel.kernelbase.Kernelc tjjj|t j j j|fi|y)zInitialize the manager.N)comm base_commr__init__ traitletsconfigLoggingConfigurable)selfkwargss Q/home/cdr/jupyterlab/.venv/lib/python3.12/site-packages/ipykernel/comm/manager.pyr zCommManager.__init__s; ""++D1,,55dEfEc|d}|d}|d}|jj|d}t|d|d}|j||tj d|n |||y |jy#t $rtj d|d Y6wxYw#t $rtj d d YywxYw) zHandler for comm_open messagescontentcomm_id target_nameNF)rprimaryr show_warningz"No such comm target registered: %sz&Exception opening comm with target: %sT)exc_infozqCould not close comm during `comm_open` failure clean-up. The comm may not have been opened yet.)targetsgetr register_commloggererror Exceptionclose) rstreamidentmsgrrrfrs r comm_openzCommManager.comm_opensi.)$m, LL  [$ /#   4 9 LL={ K c$    DJJL  c E{]a b c   LLE   s$& B1B*!B'&B'* C  C N) __name__ __module__ __qualname____doc__r InstancekernelDictcommsrr r$rrrrs? Y   = >F INN EinnGF rr) r(loggingcomm.base_commrr traitlets.configr getLoggerrr rr r r-rrr2sP    + ,-$..,,i.>.>.R.R-r