queue

1 files changed, 7 insertions, 8 deletions

diff --git a/app/relay/remote.js b/app/relay/remote.js
index 8f72f03..512745f 100644
--- a/app/relay/remote.js
+++ b/app/relay/remote.js
@@ -29,9 +29,7 @@ remote.on('cmd', (data) => {
       })
       break
     default:
-      rpc.invoke('send_command', data.cmd, data.payload || null, (err, res, more) => {
-        console.log('command:', data.cmd, res)
-        remote.emit('res', {
+      rpc.invoke('send_command', data.cmd, data.payload || null, (err, res, more) => { console.log('command:', data.cmd, res) remote.emit('res', {
           cmd: data.cmd,
           res: res,
         })
@@ -65,12 +63,13 @@ remote.on('task', (data) => {
       queue.remove_task(data.task)
       break
     case 'start_queue':
-      queue = runner.get_queue(data.task)
-      console.log(queue)
-      if (! queue.is_active()) {
-        queue.activate()
-        runner.start_queue()
+      if (q.cpu && ! q.cpu.is_active()) {
+        q.activate()
+      }
+      if (q.gpu && ! q.gpu.is_active()) {
+        q.activate()
       }
+      runner.start_queue()
       break
     case 'stop_queue':
       queue = q.get_processor(data.task)