@@ -314,7 +314,10 @@ def _execute(
314
314
raise WorkflowException (f"{ self .stdin } missing from pathmapper" )
315
315
else :
316
316
stdin_path = rmap [1 ]
317
- def stderr_stdout_log_path (base_path_logs , stderr_or_stdout ) -> Optional [str ]:
317
+
318
+ def stderr_stdout_log_path (
319
+ base_path_logs , stderr_or_stdout
320
+ ) -> Optional [str ]:
318
321
if stderr_or_stdout is not None :
319
322
abserr = os .path .join (base_path_logs , stderr_or_stdout )
320
323
dnerr = os .path .dirname (abserr )
@@ -393,13 +396,16 @@ def stderr_stdout_log_path(base_path_logs, stderr_or_stdout) -> Optional[str]:
393
396
# Move logs from log location to final output
394
397
if self .outdir != self .base_path_logs :
395
398
if stdout_path :
396
- new_stdout_path = stdout_path .replace (self .base_path_logs , self .outdir )
399
+ new_stdout_path = stdout_path .replace (
400
+ self .base_path_logs , self .outdir
401
+ )
397
402
shutil .copy2 (stdout_path , new_stdout_path )
398
403
if stderr_path :
399
- new_stderr_path = stderr_path .replace (self .base_path_logs , self .outdir )
404
+ new_stderr_path = stderr_path .replace (
405
+ self .base_path_logs , self .outdir
406
+ )
400
407
shutil .copy2 (stderr_path , new_stderr_path )
401
408
402
-
403
409
outputs = self .collect_outputs (self .outdir , rcode )
404
410
outputs = bytes2str_in_dicts (outputs ) # type: ignore
405
411
except OSError as e :
0 commit comments