@@ -519,19 +519,14 @@ def collect_output_ports(self, ports, builder, outdir, compute_checksum=True, jo
519
519
_logger .debug (u"Raw output from %s: %s" , custom_output , json .dumps (ret , indent = 4 ))
520
520
else :
521
521
for i , port in enumerate (ports ):
522
- with SourceLine (ports , i , WorkflowException , debug ):
523
- fragment = shortname (port ["id" ])
524
- try :
525
- ret [fragment ] = self .collect_output (port , builder , outdir , fs_access ,
526
- compute_checksum = compute_checksum )
527
- except Exception as e :
528
- _logger .debug (
529
- u"Error collecting output for parameter '%s'"
530
- % shortname (port ["id" ]), exc_info = True )
531
- raise WorkflowException (
522
+ def makeWorkflowException (msg ):
523
+ return WorkflowException (
532
524
u"Error collecting output for parameter '%s':\n %s"
533
- % (shortname (port ["id" ]), indent (u (str (e )))))
534
-
525
+ % (shortname (port ["id" ]), msg ))
526
+ with SourceLine (ports , i , makeWorkflowException , debug ):
527
+ fragment = shortname (port ["id" ])
528
+ ret [fragment ] = self .collect_output (port , builder , outdir , fs_access ,
529
+ compute_checksum = compute_checksum )
535
530
if ret :
536
531
revmap = partial (revmap_file , builder , outdir )
537
532
adjustDirObjs (ret , trim_listing )
0 commit comments