Show More
@@ -348,7 +348,11 b' class IPClusterEngines(BaseParallelApplication):' | |||
|
348 | 348 | # Some EngineSetLaunchers ignore `n` and use their own engine count, such as SSH: |
|
349 | 349 | n = getattr(self.engine_launcher, 'engine_count', self.n) |
|
350 | 350 | self.log.info("Starting %s Engines with %s", n, self.engine_launcher_class) |
|
351 | self.engine_launcher.start(self.n) | |
|
351 | try: | |
|
352 | self.engine_launcher.start(self.n) | |
|
353 | except: | |
|
354 | self.log.exception("Engine start failed") | |
|
355 | raise | |
|
352 | 356 | self.engine_launcher.on_stop(self.engines_stopped_early) |
|
353 | 357 | if self.early_shutdown: |
|
354 | 358 | ioloop.DelayedCallback(self.engines_started_ok, self.early_shutdown*1000, self.loop).start() |
@@ -517,7 +521,11 b' class IPClusterStart(IPClusterEngines):' | |||
|
517 | 521 | def start_controller(self): |
|
518 | 522 | self.log.info("Starting Controller with %s", self.controller_launcher_class) |
|
519 | 523 | self.controller_launcher.on_stop(self.stop_launchers) |
|
520 | self.controller_launcher.start() | |
|
524 | try: | |
|
525 | self.controller_launcher.start() | |
|
526 | except: | |
|
527 | self.log.exception("Controller start failed") | |
|
528 | raise | |
|
521 | 529 | |
|
522 | 530 | def stop_controller(self): |
|
523 | 531 | # self.log.info("In stop_controller") |
General Comments 0
You need to be logged in to leave comments.
Login now