diff options
| -rw-r--r-- | app/relay/runner.js | 2 | ||||
| -rw-r--r-- | app/server/bridge.js | 2 |
2 files changed, 3 insertions, 1 deletions
diff --git a/app/relay/runner.js b/app/relay/runner.js index d7623c1..f091cf6 100644 --- a/app/relay/runner.js +++ b/app/relay/runner.js @@ -405,6 +405,8 @@ export function run_task_with_activity(task, module, activity, preempt=false, wa if (activity.after in modules[task.module].activities) { const after_activity = modules[task.module].activities[activity.after] return run_task_with_activity(task, module, after_activity, preempt, watch) + } else { + console.warn('no such after activity:', task.module, activity.after) } } return run_next_task() diff --git a/app/server/bridge.js b/app/server/bridge.js index 0796c85..bd48597 100644 --- a/app/server/bridge.js +++ b/app/server/bridge.js @@ -50,7 +50,6 @@ function bind_relay(socket) { // messages related to queuing and tasks socket.on('task_res', data => { - console.log(data) if (data.task && data.task.id) { delete data.task.created_at delete data.task.updated_at @@ -58,6 +57,7 @@ function bind_relay(socket) { .then(task => { task.processor = data.task.processor data.task = task + console.log(">>>>>>>>>>>>>>>>>>>>>>>>>. updated task") client.emit('task_res', data) }) if (data.action === 'resolve_dataset' && data.task.opt.file_id) { |