Error Handling

​

Basic Error Handling

1. Captures the error details
2. Updates job status
3. Logs the failure
4. Initiates retry logic (if configured)

schedo.defineJob(
  'example-job',
  '* * * * *',
  async (ctx) => {
    try {
      await riskyOperation();
    } catch (error) {
      // Rethrow to trigger retry mechanism
      throw error;
    }
  }
);

​

Retry Configuration

schedo.defineJob(
  'retry-example',
  '0 * * * *',
  async (ctx) => {
    // Job implementation
  },
  {
    // Retry configuration
    retries: 3,                    // Number of retry attempts
    retryDelay: 60000,            // Delay between retries (ms)
  }
);

​

Error Context

schedo.defineJob(
  'context-example',
  '0 * * * *',
  async (ctx) => {
    try {
      await operation();
    } catch (error) {
      // Access execution context
      console.log('Job failed:', {
        jobCode: ctx.jobCode,
        executionId: ctx.executionId,
        attempt: ctx.attempt
      });
      throw error;
    }
  }
);

​

Best Practices

1. Error Handling with Retries
   async (ctx) => {
     try {
       await operation();
     } catch (error) {
       if (isTransientError(error)) {
         throw error; // Let Schedo handle retries
       } else {
         // Handle non-retryable errors
         console.error('Permanent failure:', error);
         throw error;
       }
     }
   }
   
2. Resource Cleanup
   async (ctx) => {
     let resource;
     try {
       resource = await allocateResource();
       await useResource(resource);
     } catch (error) {
       throw error;
     } finally {
       if (resource) {
         await releaseResource(resource);
       }
     }
   }
   

​

Job Execution Errors

• Execution status
• Scheduled and actual pickup time
• Duration
• Error output and stack trace

​

Next Steps