Show More
@@ -59,7 +59,7 b' def flush_channels(kc=None):' | |||
|
59 | 59 | except Empty: |
|
60 | 60 | break |
|
61 | 61 | else: |
|
62 |
|
|
|
62 | validate_message(msg) | |
|
63 | 63 | |
|
64 | 64 | |
|
65 | 65 | def execute(code='', kc=None, **kwargs): |
@@ -68,14 +68,14 b" def execute(code='', kc=None, **kwargs):" | |||
|
68 | 68 | kc = KC |
|
69 | 69 | msg_id = kc.execute(code=code, **kwargs) |
|
70 | 70 | reply = kc.get_shell_msg(timeout=TIMEOUT) |
|
71 |
|
|
|
71 | validate_message(reply, 'execute_reply', msg_id) | |
|
72 | 72 | busy = kc.get_iopub_msg(timeout=TIMEOUT) |
|
73 |
|
|
|
73 | validate_message(busy, 'status', msg_id) | |
|
74 | 74 | nt.assert_equal(busy['content']['execution_state'], 'busy') |
|
75 | 75 | |
|
76 | 76 | if not kwargs.get('silent'): |
|
77 | 77 | pyin = kc.get_iopub_msg(timeout=TIMEOUT) |
|
78 |
|
|
|
78 | validate_message(pyin, 'pyin', msg_id) | |
|
79 | 79 | nt.assert_equal(pyin['content']['code'], code) |
|
80 | 80 | |
|
81 | 81 | return msg_id, reply['content'] |
General Comments 0
You need to be logged in to leave comments.
Login now