In cvm, vm, py, c|py and debugmode, print more info when the execution of an apply node crash.

theano/compile/debugmode.py

@@ -1908,7 +1908,7 @@ class _Linker(gof.link.LocalLinker):
                         try:
                             thunk_c()
                         except Exception:
-                            raise_with_op(node)
+                            raise_with_op(node, thunk_c)
 
                         for r in node.outputs:
                             # check output values for type-correctness
@@ -1958,7 +1958,7 @@ class _Linker(gof.link.LocalLinker):
                                 try:
                                     thunk_c()
                                 except Exception:
-                                    raise_with_op(node)
+                                    raise_with_op(node, thunk_c)
                             _logger.debug(
                                     '%i - calling _check_preallocated_output '
                                     'with thunk_c', i)

theano/compile/function_module.py

@@ -583,6 +583,14 @@ class Function(object):
                 # this is a new vm-provided function
                 # the C VM needs this because the exception manipulation
                 # done by raise_with_op is not implemented in C.
+                if hasattr(self.fn, 'thunks'):
+                    # For the CVM
+                    gof.vm.raise_with_op(self.fn.nodes[self.fn.position_of_error],
+                                         self.fn.thunks[self.fn.position_of_error])
+                else:
+                    # For the c linker
+                    # We don't have access from python to all the temps values
+                    # So for now, we just don't print the extra shapes/strides info
                     gof.vm.raise_with_op(self.fn.nodes[self.fn.position_of_error])
             else:
                 # old-style linkers raise their own exceptions

theano/gof/link.py

 """WRITEME"""
 from copy import copy
+import StringIO
 import sys
 import traceback
 
@@ -55,7 +56,7 @@ sys.excepthook = thunk_hook
 
 
 # TODO: Make this work with linker defined schedule
-def raise_with_op(op, exc_info=None):
+def raise_with_op(op, thunk=None, exc_info=None):
     """
     Re-raise an exception while annotating the exception object with
     debug info.
@@ -94,6 +95,9 @@ def raise_with_op(op, exc_info=None):
         raise exc_type, exc_value, exc_trace
     try:
         trace = op.tag.trace
+    except AttributeError:
+        try:
+            trace = op.op.tag.trace
         except AttributeError:
             trace = ()
     exc_value.__thunk_trace__ = trace
@@ -108,10 +112,29 @@ def raise_with_op(op, exc_info=None):
     if raise_with_op.print_thunk_trace:
         log_thunk_trace(exc_value)
 
-    if hasattr(op, "outputs"):
-        exc_value = exc_type(exc_value, op, op.outputs)
+    if theano.config.exception_verbosity == 'high':
+        f = StringIO.StringIO()
+        theano.printing.debugprint(op, file=f, stop_on_name=True)
+        if thunk is not None:
+            shapes = [getattr(ipt[0], 'shape', 'No shapes')
+                      for ipt in thunk.inputs]
+            strides = [getattr(ipt[0], 'strides', 'No strides')
+                       for ipt in thunk.inputs]
+            detailed_err_msg = ("\nInputs shapes: %s \n" % shapes +
+                                "Inputs strides: %s \n" % strides +
+                                "Debugprint of the apply node: \n" +
+                                f.getvalue())
+        else:
+            detailed_err_msg = "\nDebugprint of the apply node: \n" + f.getvalue()
     else:
-        exc_value = exc_type(exc_value, op)
+        detailed_err_msg = ("\nUse the Theano flag"
+                            " 'exception_verbosity=high' for more"
+                            " information on the inputs of this apply"
+                            " node.")
+
+    exc_value = exc_type(str(exc_value) +
+                         "\nApply node that caused the error: " + str(op) +
+                         detailed_err_msg)
     raise exc_type, exc_value, exc_trace
 
 raise_with_op.print_thunk_trace = False
@@ -364,7 +387,7 @@ def streamline(fgraph, thunks, order, post_thunk_old_storage=None,
                     for old_s in old_storage:
                         old_s[0] = None
             except Exception:
-                raise_with_op(node)
+                raise_with_op(node, thunk)
         f = streamline_default_f
     elif nice_errors:
         thunk_node_list = zip(thunks, order)
@@ -376,7 +399,7 @@ def streamline(fgraph, thunks, order, post_thunk_old_storage=None,
                 for thunk, node in thunk_node_list:
                     thunk()
             except Exception:
-                raise_with_op(node)
+                raise_with_op(node, thunk)
         f = streamline_nice_errors_f
     else:
         # don't worry about raise_with_op, just go a little faster.
@@ -670,7 +693,7 @@ class WrapLinker(Linker):
                 try:
                     wrapper(i, node, *thunks)
                 except Exception:
-                    raise_with_op(node)
+                    raise_with_op(node, thunk)
         f.thunk_groups = thunk_groups
 
         return f, inputs0, outputs0

theano/gof/vm.py

@@ -165,7 +165,7 @@ class Loop(VM):
                     self.call_counts[i] += 1
                     self.call_times[i] += t1 - t0
             except:
-                raise_with_op(node)
+                raise_with_op(node, thunk)
         else:
             for cont in self.pre_call_clear:
                 cont[0] = None
@@ -173,7 +173,7 @@ class Loop(VM):
                 for thunk, node in zip(self.thunks, self.nodes):
                     thunk()
             except:
-                raise_with_op(node)
+                raise_with_op(node, thunk)
 
 
 class LoopGC(VM):
@@ -205,7 +205,7 @@ class LoopGC(VM):
                         old_s[0] = None
                     i += 1
             except:
-                raise_with_op(node)
+                raise_with_op(node, thunk)
         else:
             for cont in self.pre_call_clear:
                 cont[0] = None
@@ -216,7 +216,7 @@ class LoopGC(VM):
                     for old_s in old_storage:
                         old_s[0] = None
             except:
-                raise_with_op(node)
+                raise_with_op(node, thunk)
 
 
 class Stack(VM):
@@ -400,7 +400,8 @@ class Stack(VM):
                                     st = 'c'
                                 self.variable_strides[var] = st
                     except Exception:
-                        raise_with_op(current_apply)
+                        raise_with_op(current_apply,
+                                      self.thunks[self.node_idx[current_apply]])
                     for o in current_apply.outputs:
                         compute_map[o][0] = 1
                     if self.allow_gc:
@@ -458,7 +459,8 @@ class Stack(VM):
                     self.call_times[current_idx] += dt
 
                 except Exception:
-                    raise_with_op(current_apply)
+                    raise_with_op(current_apply,
+                                  self.thunks[self.node_idx[current_apply]])
 
                 if requires:
                     for r in requires:

theano/scan_module/scan_op.py

@@ -974,10 +974,18 @@ class Scan(PureOp):
                 fn()
             except Exception:
                 if hasattr(fn, 'position_of_error'):
-                    # this is a new vm-provided function
-                    # the C VM needs this because the exception manipulation
+                    # this is a new vm-provided function or c linker
+                    # they need this because the exception manipulation
                     # done by raise_with_op is not implemented in C.
-                    gof.vm.raise_with_op(fn.nodes[fn.position_of_error])
+                    if hasattr(self.fn, 'thunks'):
+                        # For the CVM
+                        gof.vm.raise_with_op(self.fn.nodes[self.fn.position_of_error],
+                                             self.fn.thunks[self.fn.position_of_error])
+                    else:
+                        # For the c linker
+                        # We don't have access from python to all the temps values
+                        # So for now, we just don't print the extra shapes/strides info
+                        gof.vm.raise_with_op(self.fn.nodes[self.fn.position_of_error])
                 else:
                     # old-style linkers raise their own exceptions
                     raise