diff options
Diffstat (limited to 'app/relay')
| -rw-r--r-- | app/relay/modules/test.js | 12 | ||||
| -rw-r--r-- | app/relay/runner.js | 6 |
2 files changed, 17 insertions, 1 deletions
diff --git a/app/relay/modules/test.js b/app/relay/modules/test.js index 8876f7c..259e817 100644 --- a/app/relay/modules/test.js +++ b/app/relay/modules/test.js @@ -33,10 +33,22 @@ const live = { return null } } +const wait = { + type: 'perl', + script: 'test.pl', + params: '--wait', + after: 'buzz', +} +const buzz = { + type: 'perl', + script: 'test.pl', + params: '--buzz', +} export default { name, cwd, activities: { cpu, gpu, live, + wait, buzz, } } diff --git a/app/relay/runner.js b/app/relay/runner.js index 1c98977..2459996 100644 --- a/app/relay/runner.js +++ b/app/relay/runner.js @@ -318,8 +318,12 @@ export function run_task_with_activity(task, module, activity, preempt=false, wa set_connected(false) // remove task from queue // queue.remove_task(task) + console.log('success?', task.success, activity) if (task.success && activity.after) { - return run_task_with_activity(task, module, activity.after, preempt, watch) + 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) + } } return run_next_task() } |
