mendel-pipeline
Advanced tools
Comparing version 3.4.1 to 3.4.2
{ | ||
"name": "mendel-pipeline", | ||
"version": "3.4.1", | ||
"version": "3.4.2", | ||
"description": "The mendel package", | ||
@@ -5,0 +5,0 @@ "main": "src/main.js", |
@@ -79,3 +79,5 @@ /* Copyright 2015-2016, Yahoo Inc. | ||
console.error( | ||
colors.red(`Errored while parsing ${data.id}\n`), | ||
colors.red( | ||
`[Mendel] Errored while parsing ${data.id}\n` | ||
), | ||
data.error.stack | ||
@@ -93,3 +95,3 @@ ); | ||
if (isRetry) { | ||
console.log('[Mendel] Reconnected to daemon. Good to go!'); | ||
debug('Reconnected to daemon. Good to go!'); | ||
} | ||
@@ -108,4 +110,4 @@ }); | ||
if (!isRetry) { | ||
console.log([ | ||
'[Mendel] Daemon was disconnected.', | ||
debug([ | ||
'Daemon has disconnected.', | ||
'Will try to reconnect...', | ||
@@ -112,0 +114,0 @@ ].join(' ')); |
@@ -22,3 +22,3 @@ /* Copyright 2015, Yahoo Inc. | ||
server.once('error', (err) => { | ||
console.error('Unrecoverable Server Error', err); | ||
console.error('[Mendel] Unrecoverable Server Error', err); | ||
process.exit(1); | ||
@@ -25,0 +25,0 @@ }); |
@@ -63,3 +63,3 @@ const BaseNetwork = require('./base-network'); | ||
'==================================================', | ||
'Server cannot start when another server is active.', | ||
'[Mendel] Server cannot start when another server is active.', | ||
'If no server process is active, ', | ||
@@ -66,0 +66,0 @@ `please remove or kill "${chalk.bold(path)}" manually.`, |
@@ -55,3 +55,4 @@ /* Copyright 2015-2016, Yahoo Inc. | ||
} catch (e) { | ||
console.log(e.stack); | ||
console.error('[Mendel] builder communication error'); | ||
console.error(e.stack); | ||
} | ||
@@ -62,4 +63,4 @@ } | ||
this.server.on('error', (e) => { | ||
console.log('Mendel Server Errored'); | ||
console.log(e.stack); | ||
console.error('[Mendel] builder errored'); | ||
console.error(e.stack); | ||
process.exit(1); | ||
@@ -66,0 +67,0 @@ }); |
@@ -45,8 +45,9 @@ #!/usr/bin/env node | ||
process.on('exit', (code) => { | ||
console.log('exit', code); | ||
if (code > 0) daemon.onForceExit(); | ||
if (code > 0) { | ||
daemon.onForceExit(); | ||
} | ||
}); | ||
process.on('SIGINT', () => { | ||
console.log('SIGINT'); | ||
console.error('SIGINT'); | ||
daemon.onForceExit(); | ||
@@ -57,3 +58,3 @@ process.exit(1); | ||
process.on('uncaughtException', (error) => { | ||
console.log([ | ||
console.error([ | ||
`Force closing due to a critical error:\n`, | ||
@@ -60,0 +61,0 @@ chalk.red(error.stack), |
@@ -42,4 +42,4 @@ const EventEmitter = require('events').EventEmitter; | ||
console.error([ | ||
'Please, use --outlet only when you have another', | ||
'mendel process running on --watch mode.\n', | ||
'[Mendel] This action requires mendel', | ||
'builder running as a separate process.\n', | ||
].join(' ')); | ||
@@ -56,8 +56,6 @@ process.exit(1); | ||
if (this._verbose) | ||
console.log('[Mendel] Synced'); | ||
this.debug('synced'); | ||
}.bind(this)); | ||
this.client.on('unsync', function() { | ||
if (this._verbose) | ||
console.log('[Mendel] File change detected. Waiting to sync again...'); // eslint-disable-line max-len | ||
this.debug('file change detected...'); | ||
this.emit('change'); | ||
@@ -77,4 +75,6 @@ this.synced = false; | ||
console.log([ | ||
'[Mendel] Waiting for sync. Can take few moments', | ||
'if an environment performs complex operations.', | ||
'[Mendel] Recent builder (re)start detected,', | ||
'compiling might take a moment...', | ||
'\n To avoid this message,', | ||
'leave your builder always running', | ||
].join(' ')); | ||
@@ -90,3 +90,3 @@ }, 3000); | ||
this.once('error', error => { | ||
console.log('[Mendel SEVERE] Outlet error', error); | ||
console.error('[Mendel SEVERE] Outlet error', error); | ||
this.exit(); | ||
@@ -93,0 +93,0 @@ callback.call(null, error); |
@@ -138,4 +138,4 @@ const debug = require('debug')('mendel:daemon'); | ||
process.once('uncaughtException', (error) => { | ||
console.log('Force closing due to a critical error:'); | ||
console.log(error.stack); | ||
console.error('[Mendel] Force closing due to a critical error:'); | ||
console.error(error.stack); | ||
this.onForceExit(); | ||
@@ -210,3 +210,3 @@ }); | ||
// you are ready to start a client process | ||
console.log(`[Mendel] ready for environment: ${environment}`); | ||
debug(`[Mendel] ready for environment: ${environment}`); | ||
}); | ||
@@ -213,0 +213,0 @@ |
@@ -25,8 +25,10 @@ const chalk = require('chalk'); | ||
if (error instanceof ReferenceError) { | ||
console.log(chalk.yellow([ | ||
'Instance of Mendel daemon may be running.', | ||
console.warn(chalk.yellow([ | ||
'[Mendel] Instance of builder may be running.', | ||
'Attemping to recycle...', | ||
].join('\n'))); | ||
} else { | ||
console.error('Unknown daemon execution error: ', error); | ||
console.error( | ||
'[Mendel] Unknown builder execution error: ', error | ||
); | ||
process.exit(1); | ||
@@ -33,0 +35,0 @@ } |
@@ -27,3 +27,3 @@ const analyticsCollector = require('../helpers/analytics/analytics-collector'); | ||
cp.once('close', () => { | ||
console.error('[ERROR] Worker process unexpectedly exited.'); | ||
console.error('[Mendel] Worker process unexpectedly exited.'); | ||
this._workers.splice(this._workers.indexOf(cp), 1); | ||
@@ -30,0 +30,0 @@ this._idleWorkers.splice(this._idleWorkers.indexOf(pid), 1); |
@@ -60,3 +60,3 @@ const _debug = require('debug'); | ||
const {error, id} = descriptor; | ||
console.error(colors.white(`[Pipeline] "${name}" errored:`)); | ||
console.error(colors.white(`[Mendel] builder "${name}" errored:`)); | ||
console.error(colors.red(error.message)); | ||
@@ -63,0 +63,0 @@ console.error(error.stack); |
@@ -29,3 +29,3 @@ const BaseStep = require('../step'); | ||
console.error([ | ||
`[CRITICAL] while reading "${filePath}".`, | ||
`[Mendel] Critical error while reading "${filePath}".`, | ||
].join(' ')); | ||
@@ -32,0 +32,0 @@ debugError(`Error message for ${filePath}: ${error.stack}`); |
161179
2869