textInput/fileUpload

1 files changed, 9 insertions, 10 deletions

diff --git a/app/relay/runner.js b/app/relay/runner.js
index 906ddbf..ecdfcde 100644
--- a/app/relay/runner.js
+++ b/app/relay/runner.js
@@ -151,18 +151,17 @@ export function run_task(task, preempt, watch){
 	}
   
   task.uuid = task.uuid || uuidv1()
-  task.processor = interpreter.gpu ? 'gpu' : 'cpu'
+  const processor = task.processor = interpreter.gpu ? 'gpu' : 'cpu'
   remote.emit('task_res', { type: 'task_begin', task })
   
-  if (watch) {
-    console.log("watching stdout..")
-    subprocess.stdout.on('data', data => {
-      remote.emit('task_res', { type: 'stdout', data: data.toString('utf8') })
-    })
-    subprocess.stderr.on('data', data => {
-      remote.emit('task_res', { type: 'stderr', data: data.toString('utf8') })
-    })
-  }
+  watch && console.log("watching stdout..")
+
+  subprocess.stdout.on('data', data => {
+    watch && remote.emit('task_res', { type: 'stdout', processor, data: data.toString('utf8') })
+  })
+  subprocess.stderr.on('data', data => {
+    watch && remote.emit('task_res', { type: 'stderr', processor, data: data.toString('utf8') })
+  })
 
   let finished = false