Small improvement to loggedsubprocess

pipelet/environment.py

@@ -218,8 +218,8 @@ class Environment(EnvironmentBase):
         ef = self.get_data_fn(proc+'.err')
         o = file(of,'w')
         e = file(ef,'w')
-        o.write('#'+' '.join([str(a) for a in args])+'\n')
-        o.flush()
+        e.write('#'+' '.join([str(a) for a in args])+'\n')
+        e.flush()
         p=subprocess.Popen(args, stdout=o, stderr=e, shell=shell)
         p.communicate()[0]
         if except_on_failure: