chore: update debug level condition

- add destType in cdkv2 handler - include extra fields in fillExcept logger option
rudderlabs · Jun 14, 2024 · cbb9354 · cbb9354
1 parent fe87faa
commit cbb9354
Show file tree

Hide file tree

Showing 2 changed files with 16 additions and 3 deletions.
diff --git a/src/cdk/v2/handler.ts b/src/cdk/v2/handler.ts
@@ -88,7 +88,8 @@ export async function processCdkV2Workflow(
   bindings: Record<string, FixMe> = {},
 ) {
   try {
-    logger.debug(`Processing cdkV2 workflow`);
+    logger.debug(`Processing cdkV2 workflow`, { destType });
+
     const workflowEngine = await getCachedWorkflowEngine(destType, feature, bindings);
     return await executeWorkflow(workflowEngine, parsedEvent, requestMetadata);
   } catch (error) {

diff --git a/src/logger.js b/src/logger.js
@@ -6,7 +6,19 @@ const loggerImpl = process.env.LOGGER_IMPL ?? 'winston';
 
 let logLevel = process.env.LOG_LEVEL ?? 'error';
 
-const logger = structuredLogger({ level: logLevel });
+const logger = structuredLogger({
+  level: logLevel,
+  fillExcept: [
+    'destinationId',
+    'sourceId',
+    'destinationType',
+    'workspaceId',
+    'module',
+    'implementation',
+    'feature',
+    'destType',
+  ],
+});
 
 const getLogger = () => {
   switch (loggerImpl) {
@@ -77,7 +89,7 @@ const log = (logMethod, args) => {
 
 const debug = (...args) => {
   const logger = getLogger();
-  if (LOGLEVELS.debug <= logLevel) {
+  if (LOGLEVELS.debug <= LOGLEVELS[logLevel]) {
     log(logger.debug, args);
   }
 };