diff --git a/ipykernel/kernelbase.py b/ipykernel/kernelbase.py index 91a26df18..2bcf22a87 100644 --- a/ipykernel/kernelbase.py +++ b/ipykernel/kernelbase.py @@ -411,10 +411,6 @@ def dispatch_queue(self): """ while True: - # ensure control stream is flushed before processing shell messages - if self.control_stream: - self.control_stream.flush() - # receive the next message and handle it try: yield self.process_one() except Exception: