From 0c6a99d6a01ba9c0adff2942a033f0ade8db87e2 Mon Sep 17 00:00:00 2001 From: Metropass Date: Fri, 19 Feb 2021 10:50:42 -0500 Subject: [PATCH] Added Comments for Logger Discussion --- src/backend/feed/processor.js | 2 +- src/backend/feed/worker.js | 5 +++-- src/backend/lib/shutdown.js | 6 +++--- 3 files changed, 7 insertions(+), 6 deletions(-) diff --git a/src/backend/feed/processor.js b/src/backend/feed/processor.js index 353a4d5fcd..9751c135c5 100644 --- a/src/backend/feed/processor.js +++ b/src/backend/feed/processor.js @@ -207,7 +207,7 @@ module.exports = async function processor(job) { }` ); } else { - logger.error({ error }, `Unable to process feed ${feed.url}`); + logger.debug({ error }, `Unable to process feed ${feed.url}`); throw error; } } diff --git a/src/backend/feed/worker.js b/src/backend/feed/worker.js index 48253df786..d279f4fb7f 100644 --- a/src/backend/feed/worker.js +++ b/src/backend/feed/worker.js @@ -31,9 +31,10 @@ exports.start = async function () { try { await waitOnReady(); logger.info('Connected to elasticsearch!'); - const concurrency = getFeedWorkersCount(); - logger.info(`Starting ${concurrency} instance${concurrency > 1 ? 's' : ''} of feed processor.`); + logger.debug( + `Starting ${concurrency} instance${concurrency > 1 ? 's' : ''} of feed processor.` + ); feedQueue.process(concurrency, path.resolve(__dirname, 'processor.js')); return feedQueue; } catch (error) { diff --git a/src/backend/lib/shutdown.js b/src/backend/lib/shutdown.js index 5b463ddaf4..f78959457a 100644 --- a/src/backend/lib/shutdown.js +++ b/src/backend/lib/shutdown.js @@ -11,7 +11,7 @@ async function stopQueue() { await feedQueue.close(); logger.info('Feed queue shut down.'); } catch (error) { - logger.error({ error }, 'Unable to close feed queue gracefully'); + logger.debug({ error }, 'Unable to close feed queue gracefully'); } } @@ -24,7 +24,7 @@ async function stopWebServer() { await serverClose(); logger.info('Web server shut down.'); } catch (error) { - logger.error({ error }, 'Unable to close web server gracefully'); + logger.debug({ error }, 'Unable to close web server gracefully'); } } @@ -33,7 +33,7 @@ async function cleanShutdown() { await Promise.all([stopQueue(), stopWebServer()]); logger.info('Completing shut down.'); } catch (error) { - logger.error({ error }, 'Failed to perform clean shutdown'); + logger.debug({ error }, 'Failed to perform clean shutdown'); } }