1 files changed, 4 insertions, 0 deletions
diff --git a/app/relay/runner.js b/app/relay/runner.js
index 7203956..c72b8cc 100644
--- a/app/relay/runner.js
+++ b/app/relay/runner.js
@@ -187,6 +187,10 @@ export function run_task_with_activity(task, module, activity, preempt=false, wa
   subprocess.stderr.on('data', buf => {
     const data = buf.toString('utf8')
     watch && remote.emit('task_res', { type: 'stderr', processor, data })
+    if (activity.listen) {
+      const res = activity.listen(task, data, count++)
+      if (res) remote.emit('task_res', res)
+    }
   })
 
   let finished = false