Show More
@@ -517,12 +517,12 b' class Kernel(Configurable):' | |||||
517 | #--------------------------------------------------------------------------- |
|
517 | #--------------------------------------------------------------------------- | |
518 |
|
518 | |||
519 | def abort_request(self, stream, ident, parent): |
|
519 | def abort_request(self, stream, ident, parent): | |
520 |
"""abort a specifi |
|
520 | """abort a specific msg by id""" | |
521 | msg_ids = parent['content'].get('msg_ids', None) |
|
521 | msg_ids = parent['content'].get('msg_ids', None) | |
522 | if isinstance(msg_ids, string_types): |
|
522 | if isinstance(msg_ids, string_types): | |
523 | msg_ids = [msg_ids] |
|
523 | msg_ids = [msg_ids] | |
524 | if not msg_ids: |
|
524 | if not msg_ids: | |
525 | self.abort_queues() |
|
525 | self._abort_queues() | |
526 | for mid in msg_ids: |
|
526 | for mid in msg_ids: | |
527 | self.aborted.add(str(mid)) |
|
527 | self.aborted.add(str(mid)) | |
528 |
|
528 | |||
@@ -674,4 +674,3 b' class Kernel(Configurable):' | |||||
674 | self.session.send(self.iopub_socket, self._shutdown_message, ident=self._topic('shutdown')) |
|
674 | self.session.send(self.iopub_socket, self._shutdown_message, ident=self._topic('shutdown')) | |
675 | self.log.debug("%s", self._shutdown_message) |
|
675 | self.log.debug("%s", self._shutdown_message) | |
676 | [ s.flush(zmq.POLLOUT) for s in self.shell_streams ] |
|
676 | [ s.flush(zmq.POLLOUT) for s in self.shell_streams ] | |
677 |
|
General Comments 0
You need to be logged in to leave comments.
Login now