File tree Expand file tree Collapse file tree 1 file changed +5
-5
lines changed Expand file tree Collapse file tree 1 file changed +5
-5
lines changed Original file line number Diff line number Diff line change @@ -278,16 +278,16 @@ def output_callback(out, processStatus):
278
278
279
279
fetch_iter_lock = threading .Lock ()
280
280
threads = set ()
281
- exception = None
281
+ exceptions = []
282
282
283
283
def run_job (job ):
284
284
def runner ():
285
285
try :
286
286
job .run (** kwargs )
287
287
except WorkflowException as e :
288
- exception = e
288
+ exceptions . append ( e )
289
289
except Exception as e :
290
- exception = WorkflowException (Text (e ))
290
+ exceptions . append ( WorkflowException (Text (e ) ))
291
291
292
292
threads .remove (thread )
293
293
@@ -303,8 +303,8 @@ def wait_for_next_completion():
303
303
fetch_iter_lock .acquire ()
304
304
fetch_iter_lock .acquire ()
305
305
fetch_iter_lock .release ()
306
- if exception is not None :
307
- raise exception
306
+ if exceptions :
307
+ raise exceptions [ 0 ]
308
308
309
309
jobiter = t .job (job_order_object , output_callback , ** kwargs )
310
310
You can’t perform that action at this time.
0 commit comments