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