running basic tasks, monitoring stdout!

3 files changed, 39 insertions, 9 deletions

diff --git a/app/client/socket/socket.task.js b/app/client/socket/socket.task.js
index d65ed13..938c533 100644
--- a/app/client/socket/socket.task.js
+++ b/app/client/socket/socket.task.js
@@ -6,18 +6,47 @@ import { socket } from './socket.connection'
 socket.on('task_res', (data) => {
   console.log('system response', data)
   switch (data.type) {
-    // case 'rpc_connected':
-    //   return dispatch({ type: types.system.rpc_connected, runner: data.runner })
+    case 'start':
+      // return dispatch({ type: types.system.rpc_connected, runner: data.runner })
+      break
+    case 'task_begin':
+      break
+    case 'stop':
+      break
+    case 'task_finish':
+      break
+    case 'kill':
+      break
+    case 'stdout':
+      console.log(data.data)
+      break
+    case 'stderr':
+      console.log(data.data)
+      break
+    case 'add':
+      break
+    case 'remove':
+      break
+    case 'start_queue':
+      break
+    case 'stop_queue':
+      break
+    case 'list':
+      break
+    case 'set_priority':
+      break
+    case 'error':
+      return console.log('task error', data)
     default:
       return console.log('no such task command', data.type)
   }
 })
 
-export function start_task(task, preempt) {
+export function start_task(task, opt={}) {
   socket.emit('task', {
     type: 'start',
     task,
-    preempt,
+    ...opt,
   })
 }
 
@@ -25,5 +54,6 @@ export function stop_task(task) {
   socket.emit('task', {
     type: 'stop',
     task,
+    ...opt,
   })
 }
diff --git a/app/client/system/system.component.js b/app/client/system/system.component.js
index 5d75964..f8cf139 100644
--- a/app/client/system/system.component.js
+++ b/app/client/system/system.component.js
@@ -10,21 +10,21 @@ import * as taskActions from '../task/task.actions'
 
 const cpu_test_task = {
   activity: 'cpu',
-  library: 'test',
+  module: 'test',
   dataset: 'test',
   epochs: 1,
   opt: {}
 }
 const gpu_test_task = {
   activity: 'gpu',
-  library: 'test',
+  module: 'test',
   dataset: 'test',
   epochs: 1,
   opt: {}
 }
 const live_test_task = {
   activity: 'live',
-  library: 'test',
+  module: 'test',
   dataset: 'test',
   epochs: 1,
   opt: {}
diff --git a/app/client/task/task.actions.js b/app/client/task/task.actions.js
index ea3dfff..6e39e71 100644
--- a/app/client/task/task.actions.js
+++ b/app/client/task/task.actions.js
@@ -2,11 +2,11 @@ import socket from '../socket'
 import types from '../types'
 
 export const start_task = (task, opt={}) => {
-  socket.task.start_task(task)
+  socket.task.start_task(task, opt)
   return { type: types.task.starting_task, task, ...opt }
 }
 
 export const stop_task = (task, opt={}) => {
-  socket.task.stop_task(task)
+  socket.task.stop_task(task, opt)
   return { type: types.task.stopping_task, task, ...opt }
 }