##// END OF EJS Templates
Merge pull request #2769 from dhirschfeld/clean-shutdown2...
Min RK -
r9028:821187b4 merge
parent child Browse files
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