##// END OF EJS Templates
IPython.parallel logging cleanup...
MinRK -
Show More
@@ -162,6 +162,10 b' class BaseParallelApplication(BaseIPythonApplication):'
162 162 self._log_formatter = logging.Formatter("[%(name)s] %(message)s")
163 163 self._log_handler.setFormatter(self._log_formatter)
164 164 self.log.addHandler(self._log_handler)
165 # do not propagate log messages to root logger
166 # ipcluster app will sometimes print duplicate messages during shutdown
167 # if this is 1 (default):
168 self.log.propagate = False
165 169
166 170 def write_pid_file(self, overwrite=False):
167 171 """Create a .pid file in the pid_dir with my pid.
@@ -40,6 +40,7 b' import zmq'
40 40 from zmq.log import handlers
41 41
42 42 # IPython imports
43 from IPython.config.application import Application
43 44 from IPython.utils.pickleutil import can, uncan, canSequence, uncanSequence
44 45 from IPython.utils.newserialized import serialize, unserialize
45 46 from IPython.zmq.log import EnginePUBHandler
@@ -391,7 +392,8 b' def select_random_ports(n):'
391 392 def signal_children(children):
392 393 """Relay interupt/term signals to children, for more solid process cleanup."""
393 394 def terminate_children(sig, frame):
394 logging.critical("Got signal %i, terminating children..."%sig)
395 log = Application.instance().log
396 log.critical("Got signal %i, terminating children..."%sig)
395 397 for child in children:
396 398 child.terminate()
397 399
General Comments 0
You need to be logged in to leave comments. Login now