1 files changed, 47 insertions, 14 deletions

diff --git a/public/bundle.js b/public/bundle.js
index 82a6d13..4c5842d 100644
--- a/public/bundle.js
+++ b/public/bundle.js
@@ -3085,6 +3085,9 @@ function run_system_command(cmd) {
 Object.defineProperty(exports, "__esModule", {
   value: true
 });
+
+var _extends = Object.assign || function (target) { for (var i = 1; i < arguments.length; i++) { var source = arguments[i]; for (var key in source) { if (Object.prototype.hasOwnProperty.call(source, key)) { target[key] = source[key]; } } } return target; };
+
 exports.start_task = start_task;
 exports.stop_task = stop_task;
 
@@ -3101,26 +3104,56 @@ function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { de
 _socket.socket.on('task_res', function (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);
   }
 });
 
-function start_task(task, preempt) {
-  _socket.socket.emit('task', {
+function start_task(task) {
+  var opt = arguments.length > 1 && arguments[1] !== undefined ? arguments[1] : {};
+
+  _socket.socket.emit('task', _extends({
     type: 'start',
-    task: task,
-    preempt: preempt
-  });
+    task: task
+  }, opt));
 }
 
 function stop_task(task) {
-  _socket.socket.emit('task', {
+  _socket.socket.emit('task', _extends({
     type: 'stop',
     task: task
-  });
+  }, opt));
 }
 
 /***/ }),
@@ -3274,21 +3307,21 @@ function _inherits(subClass, superClass) { if (typeof superClass !== "function"
 
 var cpu_test_task = {
   activity: 'cpu',
-  library: 'test',
+  module: 'test',
   dataset: 'test',
   epochs: 1,
   opt: {}
 };
 var gpu_test_task = {
   activity: 'gpu',
-  library: 'test',
+  module: 'test',
   dataset: 'test',
   epochs: 1,
   opt: {}
 };
 var live_test_task = {
   activity: 'live',
-  library: 'test',
+  module: 'test',
   dataset: 'test',
   epochs: 1,
   opt: {}
@@ -3732,14 +3765,14 @@ function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { de
 var start_task = exports.start_task = function start_task(task) {
   var opt = arguments.length > 1 && arguments[1] !== undefined ? arguments[1] : {};
 
-  _socket2.default.task.start_task(task);
+  _socket2.default.task.start_task(task, opt);
   return _extends({ type: _types2.default.task.starting_task, task: task }, opt);
 };
 
 var stop_task = exports.stop_task = function stop_task(task) {
   var opt = arguments.length > 1 && arguments[1] !== undefined ? arguments[1] : {};
 
-  _socket2.default.task.stop_task(task);
+  _socket2.default.task.stop_task(task, opt);
   return _extends({ type: _types2.default.task.stopping_task, task: task }, opt);
 };