Skip to content

Commit ae7637b

Browse files
committed
Simplify should_dispatch_immediately
1 parent 0ab59fc commit ae7637b

File tree

2 files changed

+3
-7
lines changed

2 files changed

+3
-7
lines changed

ipykernel/ipkernel.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -556,7 +556,7 @@ def do_clear(self):
556556
self.shell.reset(False)
557557
return dict(status='ok')
558558

559-
def should_dispatch_immediately(self, msg, *args):
559+
def should_dispatch_immediately(self, msg):
560560
try:
561561
msg_type = msg['header']['msg_type']
562562
if msg_type in self.comm_msg_types:

ipykernel/kernelbase.py

Lines changed: 2 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -399,9 +399,7 @@ def dispatch_queue(self):
399399
def _message_counter_default(self):
400400
return itertools.count()
401401

402-
def should_dispatch_immediately(
403-
self, msg, idents, dispatch
404-
):
402+
def should_dispatch_immediately(self, msg):
405403
"""
406404
This provides a hook for dispatching incoming messages
407405
from the frontend immediately, and out of order.
@@ -423,9 +421,7 @@ def schedule_dispatch(self, msg, dispatch):
423421

424422
new_args = (msg, idents)
425423

426-
if self.should_dispatch_immediately(
427-
msg, idents, dispatch
428-
):
424+
if self.should_dispatch_immediately(msg):
429425
return self.io_loop.add_callback(dispatch, *new_args)
430426

431427
idx = next(self._message_counter)

0 commit comments

Comments
 (0)