removed pipe_exception_handler (did more harm than good most of the t…

…ime)

pipetools/debug.py

@@ -1,4 +1,3 @@
-from contextlib import contextmanager
 from itertools import imap, chain
 
 
@@ -22,21 +21,6 @@ def get_name(f):
     return f.__name__ if hasattr(f, '__name__') else repr(f)
 
 
-@contextmanager
-def pipe_exception_handler(name):
-    try:
-        yield
-    except Exception, ex:
-        message = '%s\n  in %s' % (ex, name())
-        try:
-            # some exceptions might be bit more complicated to construct
-            # in which case... we're screwed
-            pipe_exception = type(ex)(message)
-            raise pipe_exception
-        except:
-            raise
-
-
 def repr_args(*args, **kwargs):
     return ', '.join(chain(
         imap('{0!r}'.format, args),

pipetools/main.py

@@ -1,7 +1,6 @@
 from functools import partial, wraps
 
 from pipetools.debug import get_name, set_name, repr_args
-from pipetools.debug import pipe_exception_handler
 
 
 class Pipe(object):
@@ -29,8 +28,7 @@ def compose(first, second):
         name = lambda: '{0} | {1}'.format(get_name(first), get_name(second))
 
         def composite(*args, **kwargs):
-            with pipe_exception_handler(lambda: 'pipe | ' + name()):
-                return second(first(*args, **kwargs))
+            return second(first(*args, **kwargs))
         return set_name(name, composite)
 
     @classmethod
@@ -66,9 +64,8 @@ def compose(first, second):
         name = lambda: '{0} ?| {1}'.format(get_name(first), get_name(second))
 
         def composite(*args, **kwargs):
-            with pipe_exception_handler(lambda: 'maybe ?| ' + name()):
-                result = first(*args, **kwargs)
-                return None if result is None else second(result)
+            result = first(*args, **kwargs)
+            return None if result is None else second(result)
         return set_name(name, composite)
 
     def __call__(self, *args, **kwargs):