Show More
@@ -268,11 +268,6 b' class Kernel(Configurable):' | |||||
268 | # it to sit in memory until the next execute_request comes in. |
|
268 | # it to sit in memory until the next execute_request comes in. | |
269 | shell.payload_manager.clear_payload() |
|
269 | shell.payload_manager.clear_payload() | |
270 |
|
270 | |||
271 | # Send the reply. |
|
|||
272 | reply_msg = self.session.send(self.reply_socket, u'execute_reply', |
|
|||
273 | reply_content, parent, ident=ident) |
|
|||
274 | logger.debug(str(reply_msg)) |
|
|||
275 |
|
||||
276 | # Flush output before sending the reply. |
|
271 | # Flush output before sending the reply. | |
277 | sys.stdout.flush() |
|
272 | sys.stdout.flush() | |
278 | sys.stderr.flush() |
|
273 | sys.stderr.flush() | |
@@ -282,6 +277,11 b' class Kernel(Configurable):' | |||||
282 | if self._execute_sleep: |
|
277 | if self._execute_sleep: | |
283 | time.sleep(self._execute_sleep) |
|
278 | time.sleep(self._execute_sleep) | |
284 |
|
279 | |||
|
280 | # Send the reply. | |||
|
281 | reply_msg = self.session.send(self.reply_socket, u'execute_reply', | |||
|
282 | reply_content, parent, ident=ident) | |||
|
283 | logger.debug(str(reply_msg)) | |||
|
284 | ||||
285 | if reply_msg['content']['status'] == u'error': |
|
285 | if reply_msg['content']['status'] == u'error': | |
286 | self._abort_queue() |
|
286 | self._abort_queue() | |
287 |
|
287 |
General Comments 0
You need to be logged in to leave comments.
Login now