monitoring of processes with epoch/progress events

2 files changed, 8 insertions, 8 deletions

diff --git a/app/relay/queue.js b/app/relay/queue.js
index 6e67b80..9f9e821 100644
--- a/app/relay/queue.js
+++ b/app/relay/queue.js
@@ -2,16 +2,16 @@ let queue = []
 let active = true
 let status = 'waiting'
 
-const is_active = () => active
-const get_status = () => status
-const activate = () => {
+export const is_active = () => active
+export const get_status = () => status
+export const activate = () => {
   active = true
   status = 'active'
 }
-const deactivate = reason => {
+export const deactivate = reason => {
   active = false
   status = reason
 }
-const add_task = task => queue.push(task)
-const remove_task = task => queue = queue.filter(t => t.id !== task.id)
-const get_next_task = () => queue.shift()
+export const add_task = task => queue.push(task)
+export const remove_task = task => queue = queue.filter(t => t.id !== task.id)
+export const get_next_task = () => queue.shift()
diff --git a/app/relay/runner.js b/app/relay/runner.js
index c04419d..4b5522d 100644
--- a/app/relay/runner.js
+++ b/app/relay/runner.js
@@ -8,7 +8,7 @@ import uuidv1 from 'uuid/v1'
 import * as fs from 'fs'
 import * as path from 'path'
 
-import * as queue from 'queue'
+import * as queue from './queue'
 
 const idle_state = { status: 'IDLE', task: {} }