fixes due to bad rebase

This commit is contained in:
Iuri Matias 2018-08-22 18:16:03 -04:00 committed by Pascal Precht
parent f02de020de
commit f873a26caf
No known key found for this signature in database
GPG Key ID: 0EE28D8D6FD85D7D
2 changed files with 8 additions and 1 deletions

View File

@ -91,7 +91,7 @@ class Engine {
} }
processManagerService(_options) { processManagerService(_options) {
const ProcessManager = require('./processes/process_manager.js'); const ProcessManager = require('./processes/processManager.js');
this.processManager = new ProcessManager({ this.processManager = new ProcessManager({
events: this.events, events: this.events,
logger: this.logger, logger: this.logger,
@ -99,6 +99,10 @@ class Engine {
}); });
} }
graphService(_options) {
this.registerModule('graph');
}
pipelineService(_options) { pipelineService(_options) {
const self = this; const self = this;
this.registerModule('pipeline', { this.registerModule('pipeline', {

View File

@ -42,6 +42,9 @@ class ProcessLauncher {
_subscribeToMessages() { _subscribeToMessages() {
const self = this; const self = this;
this.process.on('message', (msg) => { this.process.on('message', (msg) => {
if (msg.error) {
self.logger.error(msg.error);
}
if (msg.result === constants.process.log) { if (msg.result === constants.process.log) {
return self._handleLog(msg); return self._handleLog(msg);
} }