add a nice feature to logged_subprocess

pipelet/environment.py

@@ -323,7 +323,7 @@ class Environment(EnvironmentBase):
             +glob(path.join(self._worker.pipe.get_data_dir(segx),path.join('*/',y)))
 
     
-    def logged_subprocess(self, args, shell=False, except_on_failure=True, name=None):
+    def logged_subprocess(self, args, shell=False, except_on_failure=True, name=None, of=None):
         """ Execute a subprocess and log its output.
         
         Create files process_name.log and process_name.err
@@ -341,7 +341,8 @@ class Environment(EnvironmentBase):
         proc = args[0]
         if name is None:
             name = path.basename(proc)
-        of = self.get_data_fn(name+'.log')
+        if of is None:
+            of = self.get_data_fn(name+'.log')
         ef = self.get_data_fn(name+'.err')
         o = file(of,'w')
         e = file(ef,'w')