summaryrefslogtreecommitdiff
path: root/app/relay/runner.js
diff options
context:
space:
mode:
Diffstat (limited to 'app/relay/runner.js')
-rw-r--r--app/relay/runner.js19
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