Skip to content
Merged
Show file tree
Hide file tree
Changes from 2 commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
1 change: 1 addition & 0 deletions CHANGES
Original file line number Diff line number Diff line change
@@ -1,6 +1,7 @@
Upcoming release (0.14.0)
================

* FIX: MultiProc mishandling crashes (https://github.com/nipy/nipype/pull/2301)
* FIX: Testing maintainance and improvements (https://github.com/nipy/nipype/pull/2252)
* ENH: Add elapsed_time and final metric_value to ants.Registration (https://github.com/nipy/nipype/pull/1985)
* ENH: Improve terminal_output feature (https://github.com/nipy/nipype/pull/2209)
Expand Down
15 changes: 10 additions & 5 deletions nipype/pipeline/plugins/base.py
Original file line number Diff line number Diff line change
Expand Up @@ -197,13 +197,18 @@ def _get_result(self, taskid):
def _submit_job(self, node, updatehash=False):
raise NotImplementedError

def _report_crash(self, node, result=None):
tb = None
def _report_crash(self, node, result=None, traceback=None):
Copy link
Member

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

is the change in signature because multiproc is not adding traceback to result? i.e., could this remain the same and 'traceback' added to result?

# Overwrite traceback if comes with result
# to keep compatibility
if result is not None:
node._result = result['result']
tb = result['traceback']
node._traceback = tb
return report_crash(node, traceback=tb)
if 'traceback' in result:
traceback = result['traceback']

if traceback is not None:
node._traceback = traceback

return report_crash(node, traceback=traceback)

def _clear_task(self, taskid):
raise NotImplementedError
Expand Down