Show More
@@ -1155,14 +1155,17 b' class Client(HasTraits):' | |||
|
1155 | 1155 | NOT IMPLEMENTED |
|
1156 | 1156 | whether to restart engines after shutting them down. |
|
1157 | 1157 | """ |
|
1158 | ||
|
1158 | from IPython.parallel.error import NoEnginesRegistered | |
|
1159 | 1159 | if restart: |
|
1160 | 1160 | raise NotImplementedError("Engine restart is not yet implemented") |
|
1161 | 1161 | |
|
1162 | 1162 | block = self.block if block is None else block |
|
1163 | 1163 | if hub: |
|
1164 | 1164 | targets = 'all' |
|
1165 | try: | |
|
1165 | 1166 | targets = self._build_targets(targets)[0] |
|
1167 | except NoEnginesRegistered: | |
|
1168 | targets = [] | |
|
1166 | 1169 | for t in targets: |
|
1167 | 1170 | self.session.send(self._control_socket, 'shutdown_request', |
|
1168 | 1171 | content={'restart':restart},ident=t) |
@@ -1550,7 +1553,7 b' class Client(HasTraits):' | |||
|
1550 | 1553 | elif header['msg_type'] == 'execute_reply': |
|
1551 | 1554 | res = ExecuteReply(msg_id, rcontent, md) |
|
1552 | 1555 | else: |
|
1553 | raise KeyError("unhandled msg type: %r" % header[msg_type]) | |
|
1556 | raise KeyError("unhandled msg type: %r" % header['msg_type']) | |
|
1554 | 1557 | else: |
|
1555 | 1558 | res = self._unwrap_exception(rcontent) |
|
1556 | 1559 | failures.append(res) |
General Comments 0
You need to be logged in to leave comments.
Login now