Make sure that your multiprocessing pool workers report their full traceback when crashing!

error_wrapper_pool.py

import sys
import traceback
from functools import wraps


def error_wrapper_pool(method):
    """ Make sure that your multiprocessing pool workers report
        their full traceback when crashing!
    """
    @wraps(method)
    def wrapper(*args, **kwargs):
        try:
            method(*args, **kwargs)
        except:
            trace = traceback.format_exception(*sys.exc_info())
            raise RuntimeError(''.join(trace))
    return wrapper