diff --git a/runner.ts b/runner.ts index 12f168ea..443beea8 100644 --- a/runner.ts +++ b/runner.ts @@ -16,8 +16,6 @@ if (process.env.HAWK_CATCHER_TOKEN) { HawkCatcher.init(process.env.HAWK_CATCHER_TOKEN); } -console.log('process.env', process.env); - type WorkerConstructor = new () => Worker; const BEGINNING_OF_ARGS = 2; @@ -29,8 +27,6 @@ const BEGINNING_OF_ARGS = 2; */ const workerNames = process.argv.slice(BEGINNING_OF_ARGS); -console.log('workerNames', workerNames); - /** * Workers dispatcher. * Load, run and finish workers. @@ -59,8 +55,6 @@ class WorkerRunner { */ this.loadPackages() .then((workerConstructors) => { - console.log('packages loaded'); - this.constructWorkers(workerConstructors); }) // .then(() => { @@ -171,12 +165,8 @@ class WorkerRunner { * @param workerConstructors - worker constructors to create new instances */ private constructWorkers(workerConstructors: WorkerConstructor[]): void { - console.log('constructWorkers', workerConstructors); - return workerConstructors.forEach((WorkerClass) => { try { - console.log('constructing worker', WorkerClass); - const worker = new WorkerClass(); this.workers.push(worker); @@ -312,10 +302,8 @@ class WorkerRunner { } } -console.log('Starting worker runner'); - -// eslint-disable-next-line no-new try { + // eslint-disable-next-line no-new new WorkerRunner(); } catch (error) { console.error('Error running worker runner', error); diff --git a/workers/grouper/src/redisHelper.ts b/workers/grouper/src/redisHelper.ts index 32df5876..40a7cc24 100644 --- a/workers/grouper/src/redisHelper.ts +++ b/workers/grouper/src/redisHelper.ts @@ -28,14 +28,10 @@ export default class RedisHelper { */ constructor() { try { - console.log('redis constructor', process.env.REDIS_URL); - - this.redisClient = createClient({ url: process.env.REDIS_URL }); - this.redisClient.on('error', (error) => { console.log('redis error', error); - + if (error) { this.logger.error('Redis error: ', error); HawkCatcher.send(error);