Source code for ClearMap.ParallelProcessing.ParallelTraceback
# -*- coding: utf-8 -*-
"""
ParalllelTraceback
==================
Decorator to traceback errors in parallel processes.
"""
__author__ = 'Christoph Kirst <christoph.kirst.ck@gmail.com>'
__license__ = 'GPLv3 - GNU General Pulic License v3 (see LICENSE)'
__copyright__ = 'Copyright © 2020 by Christoph Kirst'
__webpage__ = 'http://idisco.info'
__download__ = 'http://www.github.com/ChristophKirst/ClearMap2'
[docs]def parallel_traceback(func):
"""Wrapper to obtain a full traceback when exceuting a function in parallel.
Arguments
---------
func : function
The function to call.
Returns
-------
wrapper : function
The function wrapped with an appropiate traceback functionality.
"""
import traceback, functools
@functools.wraps(func)
def wrapper(*args, **kwargs):
try:
return func(*args, **kwargs)
except Exception as e:
msg = "{}\n\nOriginal {}".format(e, traceback.format_exc())
raise type(e)(msg)
return wrapper
Source
