import logging def setup(): logging._acquireLock() try: OldLoggerClass = logging.getLoggerClass() class ProcessAwareLogger(OldLoggerClass): _process_aware = True def makeRecord(self, *args, **kwds): record = OldLoggerClass.makeRecord(self, *args, **kwds) record.processName = multiprocessing.util.current_process()._name return record logging.setLoggerClass(ProcessAwareLogger) finally: logging._releaseLock() setup() import multiprocessing.util multiprocessing.util.log_to_stderr(level=logging.DEBUG) multiprocessing.util.debug("Terminating")