diff --git a/lib/tasks/listen.js b/lib/tasks/listen.js index d5b16c79..3f6f5fa9 100644 --- a/lib/tasks/listen.js +++ b/lib/tasks/listen.js @@ -72,7 +72,7 @@ class TaskListen extends Task { } catch (err) { this.logger.info(err, `TaskListen:exec - error ${this.url}`); } - if (this.transcribeTask) this.transcribeTask.kill(); + if (this.transcribeTask) this.transcribeTask.kill(cs); this._removeListeners(ep); } diff --git a/lib/utils/background-task-manager.js b/lib/utils/background-task-manager.js index 3a427c10..7c55b80e 100644 --- a/lib/utils/background-task-manager.js +++ b/lib/utils/background-task-manager.js @@ -65,7 +65,7 @@ class BackgroundTaskManager extends Emitter { this.logger.info(`stopping background task: ${type}`); task.removeAllListeners(); task.span.end(); - task.kill(); + task.kill(this.cs); // Remove task from managed List this.tasks.delete(type); }