Update logger level and enhance schedule validation logic

- Changed logger level from ERROR to INFO to capture important operational messages, including schedule setup, errors, and warnings.
- Introduced validation functions to check if a schedule exists and handle "not found" errors more gracefully, improving error handling in the setupWeeklyReportSchedule function.

These changes enhance logging clarity and improve the robustness of schedule management.

Author: anatolyshipitz

workers/main/src/configs/schedules.ts

@@ -5,36 +5,56 @@ import { workerConfig } from './worker';
 
 const SCHEDULE_ID = 'weekly-financial-report-schedule';
 
+/**
+ * Checks if an error is a "not found" error
+ */
+function validateIsScheduleNotFoundError(error: unknown): boolean {
+  return (
+    (error as { code?: number }).code === 5 ||
+    (error instanceof Error &&
+      error.message.toLowerCase().includes('not found'))
+  );
+}
+
+/**
+ * Checks if schedule exists, returns true if it exists
+ */
+async function validateScheduleExists(client: Client): Promise<boolean> {
+  try {
+    const scheduleHandle = client.schedule.getHandle(SCHEDULE_ID);
+
+    await scheduleHandle.describe();
+    logger.info(`Schedule ${SCHEDULE_ID} already exists, skipping creation`);
+
+    return true;
+  } catch (error) {
+    if (!validateIsScheduleNotFoundError(error)) {
+      throw error;
+    }
+    logger.info(`Schedule ${SCHEDULE_ID} not found, creating new schedule`);
+
+    return false;
+  }
+}
+
 /**
  * Sets up the weekly financial report schedule
  * Schedule runs every Tuesday at 1 PM America/New_York time (EST/EDT)
  * @param client - Temporal client instance
  */
 export async function setupWeeklyReportSchedule(client: Client): Promise<void> {
   try {
-    const scheduleHandle = client.schedule.getHandle(SCHEDULE_ID);
-
-    // Check if schedule already exists
-    try {
-      await scheduleHandle.describe();
-      logger.info(`Schedule ${SCHEDULE_ID} already exists, skipping creation`);
+    const isScheduleExists = await validateScheduleExists(client);
 
+    if (isScheduleExists) {
       return;
-    } catch (error) {
-      const errorMessage =
-        error instanceof Error ? error.message : String(error);
-
-      // Schedule doesn't exist, create it
-      logger.info(
-        `Schedule ${SCHEDULE_ID} not found, creating schedule. Reason: ${errorMessage}`,
-      );
     }
 
     await client.schedule.create({
       scheduleId: SCHEDULE_ID,
       spec: {
-        cronExpressions: ['0 13 * * 2'], // Every Tuesday at 1 PM
-        timezone: 'America/New_York', // Automatically handles EST/EDT transitions
+        cronExpressions: ['0 13 * * 2'],
+        timezone: 'America/New_York',
       },
       action: {
         type: 'startWorkflow',
@@ -43,8 +63,8 @@ export async function setupWeeklyReportSchedule(client: Client): Promise<void> {
         workflowId: `weekly-financial-report-scheduled`,
       },
       policies: {
-        overlap: 'SKIP', // Skip if previous run is still in progress
-        catchupWindow: '1 day', // Catch up missed runs within 1 day
+        overlap: 'SKIP',
+        catchupWindow: '1 day',
       },
     });
 

workers/main/src/logger.ts

@@ -2,6 +2,7 @@ import { DefaultLogger } from '@temporalio/worker';
 
 /**
  * Shared logger instance for the worker
- * Using ERROR level to reduce noise in production
+ * Using INFO level to capture important operational messages
+ * including schedule setup, errors, and warnings
  */
-export const logger = new DefaultLogger('ERROR');
+export const logger = new DefaultLogger('INFO');