Fix calls to clean_queue to make sure that the info about exceptions is always there

Author: achetverikov

nipype/interfaces/ants/tests/test_auto_AntsJointFusion.py

@@ -57,8 +57,8 @@ def test_AntsJointFusion_inputs():
             hash_files=False,
         ),
         out_label_post_prob_name_format=dict(
-            requires=['out_label_fusion', 'out_intensity_fusion_name_format'],
-        ),
+            requires=['out_label_fusion',
+                      'out_intensity_fusion_name_format'], ),
         patch_metric=dict(argstr='-m %s', ),
         patch_radius=dict(
             argstr='-p %s',

nipype/interfaces/mixins/tests/test_auto_ReportCapableInterface.py

@@ -0,0 +1,17 @@
+# AUTO-GENERATED by tools/checkspecs.py - DO NOT EDIT
+from __future__ import unicode_literals
+from ..reporting import ReportCapableInterface
+
+
+def test_ReportCapableInterface_inputs():
+    input_map = dict(
+        ignore_exception=dict(
+            deprecated='1.0.0',
+            nohash=True,
+            usedefault=True,
+        ), )
+    inputs = ReportCapableInterface.input_spec()
+
+    for key, metadata in list(input_map.items()):
+        for metakey, value in list(metadata.items()):
+            assert getattr(inputs.traits()[key], metakey) == value

nipype/pipeline/plugins/base.py

@@ -292,7 +292,11 @@ def _send_procs_to_workers(self, updatehash=False, graph=None):
                         try:
                             num_subnodes = self.procs[jobid].num_subnodes()
                         except Exception:
-                            self._clean_queue(jobid, graph)
+                            self._clean_queue(jobid, graph,
+								result={
+									'result': None,
+									'traceback': '\n'.join(format_exception(*sys.exc_info()))
+								})
                             self.proc_pending[jobid] = False
                             continue
                         if num_subnodes > 1:
@@ -315,7 +319,11 @@ def _send_procs_to_workers(self, updatehash=False, graph=None):
                             try:
                                 self.procs[jobid].run()
                             except Exception:
-                                self._clean_queue(jobid, graph)
+                                self._clean_queue(jobid, graph,
+									result={
+										'result': None,
+										'traceback': '\n'.join(format_exception(*sys.exc_info()))
+									})
                             self._task_finished_cb(jobid)
                             self._remove_node_dirs()
                         else:
@@ -369,7 +377,12 @@ def _local_hash_check(self, jobid, graph):
                 logger.debug('Error skipping cached node %s (%s).\n\n%s',
                              self.procs[jobid], jobid,
                              '\n'.join(format_exception(*sys.exc_info())))
-                self._clean_queue(jobid, graph)
+                self._clean_queue(jobid, graph,
+					result={
+						'result': None,
+						'traceback': '\n'.join(format_exception(*sys.exc_info()))
+					})
+
                 self.proc_pending[jobid] = False
             return True
         return False