summaryrefslogtreecommitdiff
path: root/app/relay
diff options
context:
space:
mode:
Diffstat (limited to 'app/relay')
-rw-r--r--app/relay/modules/test.js12
-rw-r--r--app/relay/runner.js6
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()
}