diff --git a/lib/core/engine.js b/lib/core/engine.js index 35044e829..38d7a72cc 100644 --- a/lib/core/engine.js +++ b/lib/core/engine.js @@ -91,7 +91,7 @@ class Engine { } processManagerService(_options) { - const ProcessManager = require('./processes/process_manager.js'); + const ProcessManager = require('./processes/processManager.js'); this.processManager = new ProcessManager({ events: this.events, logger: this.logger, @@ -99,6 +99,10 @@ class Engine { }); } + graphService(_options) { + this.registerModule('graph'); + } + pipelineService(_options) { const self = this; this.registerModule('pipeline', { diff --git a/lib/core/processes/processLauncher.js b/lib/core/processes/processLauncher.js index 88ad8f4c3..7ee80fc5f 100644 --- a/lib/core/processes/processLauncher.js +++ b/lib/core/processes/processLauncher.js @@ -42,6 +42,9 @@ class ProcessLauncher { _subscribeToMessages() { const self = this; this.process.on('message', (msg) => { + if (msg.error) { + self.logger.error(msg.error); + } if (msg.result === constants.process.log) { return self._handleLog(msg); }