diff options
| author | Jules Laplace <julescarbon@gmail.com> | 2018-06-04 23:57:23 +0200 |
|---|---|---|
| committer | Jules Laplace <julescarbon@gmail.com> | 2018-06-04 23:57:23 +0200 |
| commit | a960d57ad80a65d5cf028f2595b38ca07bb46b83 (patch) | |
| tree | 58bc92a8c30511a1e4caa79f7ce5a3528d7ac35b /app/relay/runner.js | |
| parent | 1ccc4c798d95133cde1d4558318f0640a772526a (diff) | |
updating task status on serverrrrrr
Diffstat (limited to 'app/relay/runner.js')
| -rw-r--r-- | app/relay/runner.js | 8 |
1 files changed, 8 insertions, 0 deletions
diff --git a/app/relay/runner.js b/app/relay/runner.js index 4b5522d..734e3ea 100644 --- a/app/relay/runner.js +++ b/app/relay/runner.js @@ -189,11 +189,14 @@ export function run_task(task, preempt=false, watch=false){ const module = modules[task.module] if (! module) return { type: 'error', error: "No such module: " + task.module } const activity = module.activities[task.activity] +console.log(task) + if (! activity) return { type: 'error', error: 'No such activity in module: ' + task.module + ' ' + task.activity } return run_task_with_activity(task, module, activity, preempt, watch) } export function run_task_with_activity(task, module, activity, preempt=false, watch=false) { const { interpreter, params } = build_params(module, activity, task) +console.log(activity) if (! interpreter) return { type: 'error', error: "No such interpreter: " + activity.interpreter } if (interpreter.gpu && state.current_gpu_task.status !== 'IDLE') { @@ -298,8 +301,13 @@ export function run_task_with_activity(task, module, activity, preempt=false, wa return task } +export function start_queue(){ + run_next_task() +} + export function run_next_task(){ if (queue.is_active()) { + console.log(queue.list_tasks()) const task = queue.get_next_task() return run_task(task) } |
