Skip to content

Commit 1e0ac27

Browse files
committed
Updated formatting in plugins/base.py related to clean_queue
1 parent ae71ef4 commit 1e0ac27

File tree

1 file changed

+4
-6
lines changed

1 file changed

+4
-6
lines changed

nipype/pipeline/plugins/base.py

Lines changed: 4 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -154,9 +154,7 @@ def run(self, graph, config, updatehash=False):
154154
result = self._get_result(taskid)
155155
except Exception:
156156
notrun.append(
157-
self._clean_queue(
158-
jobid,
159-
graph))
157+
self._clean_queue(jobid, graph))
160158
else:
161159
if result:
162160
if result['traceback']:
@@ -218,9 +216,9 @@ def _clean_queue(self, jobid, graph, result=None):
218216

219217
if self._status_callback:
220218
self._status_callback(self.procs[jobid], 'exception')
221-
if result is None:
222-
result={'result': None,
223-
'traceback': '\n'.join(format_exception(*sys.exc_info()))}
219+
if result is None:
220+
result = {'result': None,
221+
'traceback': '\n'.join(format_exception(*sys.exc_info()))}
224222

225223
if str2bool(self._config['execution']['stop_on_first_crash']):
226224
raise RuntimeError("".join(result['traceback']))

0 commit comments

Comments
 (0)