Added support for command stdout redirection to a file

Author: balis

converters/pegasus_dax.js

@@ -111,6 +111,11 @@ function createWorkflow(dax, functionName, cb) {
             "outs": []
         });
 
+        if (job.stdout) { // stdout should be redirected to a file
+            console.log(job.stdout);
+            wfOut.tasks[nextTaskId].config.executor.stdout = job.stdout[0]['$'].name;
+        }
+
         if (job['$'].runtime) { // synthetic workflow dax
             wfOut.tasks[nextTaskId].runtime = job['$'].runtime;
         }

functions/command.js

@@ -1,14 +1,22 @@
-var spawn = require('cross-spawn');
+var spawn = require('cross-spawn'),
+    fs = require('fs');
 
 function command(ins, outs, config, cb) {
     var exec = config.executor.executable,
         args = config.executor.args;
 
+    var stdoutStream;
+
     console.log("Executing:", exec, args);
 
 //    var proc = spawn(exec, [ args ]);
     var proc = spawn(exec,  args );
 
+    if (config.executor.stdout) {
+        stdoutStream = fs.createWriteStream(config.executor.stdout, {flags: 'w'});
+        proc.stdout.pipe(stdoutStream);
+    }
+
     proc.stdout.on('data', function(data) {
         console.log(exec, 'stdout:' + data);
     });