@@ -70,21 +70,22 @@ def __init__(
7070
7171 def publish_msg (
7272 self ,
73- msg_type : str ,
74- data : MaybeDict = None ,
75- metadata : MaybeDict = None ,
76- buffers : BuffersType = None ,
77- ** keys : t .Any ,
73+ msg_type : str , # noqa: ARG002
74+ data : MaybeDict = None , # noqa: ARG002
75+ metadata : MaybeDict = None , # noqa: ARG002
76+ buffers : BuffersType = None , # noqa: ARG002
77+ ** keys : t .Any , # noqa: ARG002
7878 ) -> None :
79- raise NotImplementedError ("publish_msg Comm method is not implemented" )
79+ msg = "publish_msg Comm method is not implemented"
80+ raise NotImplementedError (msg )
8081
8182 def __del__ (self ) -> None :
8283 """trigger close on gc"""
8384 self .close (deleting = True )
8485
8586 # publishing messages
8687
87- def open ( # noqa: A003
88+ def open (
8889 self , data : MaybeDict = None , metadata : MaybeDict = None , buffers : BuffersType = None
8990 ) -> None :
9091 """Open the frontend-side version of this comm"""
@@ -93,7 +94,8 @@ def open( # noqa: A003
9394 data = self ._open_data
9495 comm_manager = comm .get_comm_manager ()
9596 if comm_manager is None :
96- raise RuntimeError ("Comms cannot be opened without a comm_manager." )
97+ msg = "Comms cannot be opened without a comm_manager." # type:ignore[unreachable]
98+ raise RuntimeError (msg )
9799
98100 comm_manager .register_comm (self )
99101 try :
@@ -211,7 +213,7 @@ def register_target(self, target_name: str, f: CommTargetCallback | str) -> None
211213
212214 self .targets [target_name ] = t .cast (CommTargetCallback , f )
213215
214- def unregister_target (self , target_name : str , f : CommTargetCallback ) -> CommTargetCallback :
216+ def unregister_target (self , target_name : str , f : CommTargetCallback ) -> CommTargetCallback : # noqa: ARG002
215217 """Unregister a callable registered with register_target"""
216218 return self .targets .pop (target_name )
217219
@@ -245,7 +247,7 @@ def get_comm(self, comm_id: str) -> BaseComm | None:
245247
246248 # Message handlers
247249
248- def comm_open (self , stream : ZMQStream , ident : str , msg : MessageType ) -> None :
250+ def comm_open (self , stream : ZMQStream , ident : str , msg : MessageType ) -> None : # noqa: ARG002
249251 """Handler for comm_open messages"""
250252 from comm import create_comm
251253
@@ -278,7 +280,7 @@ def comm_open(self, stream: ZMQStream, ident: str, msg: MessageType) -> None:
278280 exc_info = True ,
279281 )
280282
281- def comm_msg (self , stream : ZMQStream , ident : str , msg : MessageType ) -> None :
283+ def comm_msg (self , stream : ZMQStream , ident : str , msg : MessageType ) -> None : # noqa: ARG002
282284 """Handler for comm_msg messages"""
283285 content = msg ["content" ]
284286 comm_id = content ["comm_id" ]
@@ -291,7 +293,7 @@ def comm_msg(self, stream: ZMQStream, ident: str, msg: MessageType) -> None:
291293 except Exception :
292294 logger .error ("Exception in comm_msg for %s" , comm_id , exc_info = True )
293295
294- def comm_close (self , stream : ZMQStream , ident : str , msg : MessageType ) -> None :
296+ def comm_close (self , stream : ZMQStream , ident : str , msg : MessageType ) -> None : # noqa: ARG002
295297 """Handler for comm_close messages"""
296298 content = msg ["content" ]
297299 comm_id = content ["comm_id" ]
0 commit comments