@@ -110,6 +110,7 @@ def relink_initialworkdir(
110
110
def neverquote (string : str , pos : int = 0 , endpos : int = 0 ) -> Optional [Match [str ]]:
111
111
return None
112
112
113
+
113
114
CollectOutputsType = Union [Callable [[str , int ], CWLObjectType ], functools .partial ]
114
115
115
116
@@ -230,10 +231,15 @@ def is_streamable(file: str) -> bool:
230
231
self .base_path_logs = self .outdir
231
232
else :
232
233
self .base_path_logs = runtimeContext .log_dir
233
- # Generate random ids
234
+ # Generate random ids
234
235
import uuid
235
- self .stdout = self .stdout if not self .stdout else self .stdout + uuid .uuid4 ().hex
236
- self .stderr = self .stderr if not self .stderr else self .stderr + uuid .uuid4 ().hex
236
+
237
+ self .stdout = (
238
+ self .stdout if not self .stdout else self .stdout + uuid .uuid4 ().hex
239
+ )
240
+ self .stderr = (
241
+ self .stderr if not self .stderr else self .stderr + uuid .uuid4 ().hex
242
+ )
237
243
238
244
def _execute (
239
245
self ,
@@ -285,8 +291,12 @@ def _execute(
285
291
]
286
292
),
287
293
" < %s" % self .stdin if self .stdin else "" ,
288
- " > %s" % os .path .join (self .base_path_logs , self .stdout ) if self .stdout else "" ,
289
- " 2> %s" % os .path .join (self .base_path_logs , self .stderr ) if self .stderr else "" ,
294
+ " > %s" % os .path .join (self .base_path_logs , self .stdout )
295
+ if self .stdout
296
+ else "" ,
297
+ " 2> %s" % os .path .join (self .base_path_logs , self .stderr )
298
+ if self .stderr
299
+ else "" ,
290
300
)
291
301
if self .joborder is not None and runtimeContext .research_obj is not None :
292
302
job_order = self .joborder
0 commit comments