File tree Expand file tree Collapse file tree 1 file changed +10
-5
lines changed Expand file tree Collapse file tree 1 file changed +10
-5
lines changed Original file line number Diff line number Diff line change @@ -197,13 +197,18 @@ def _get_result(self, taskid):
197197 def _submit_job (self , node , updatehash = False ):
198198 raise NotImplementedError
199199
200- def _report_crash (self , node , result = None ):
201- tb = None
200+ def _report_crash (self , node , result = None , traceback = None ):
201+ # Overwrite traceback if comes with result
202+ # to keep compatibility
202203 if result is not None :
203204 node ._result = result ['result' ]
204- tb = result ['traceback' ]
205- node ._traceback = tb
206- return report_crash (node , traceback = tb )
205+ if 'traceback' in result :
206+ traceback = result ['traceback' ]
207+
208+ if traceback is not None :
209+ node ._traceback = traceback
210+
211+ return report_crash (node , traceback = traceback )
207212
208213 def _clear_task (self , taskid ):
209214 raise NotImplementedError
You can’t perform that action at this time.
0 commit comments