Cron Job Execution

// apps/azalt/src/server/db/types/cron-job.ts (simplified)
interface CronJobExecution {
  id: string;
  cronJobId: string;
  status: "running" | "success" | "failed" | "timeout";
  triggerType: "scheduled" | "manual";
  triggeredById: string | null;    // User ID for manual triggers
  startedAt: Date;
  finishedAt: Date | null;
  executionTimeMs: number | null;  // Duration in milliseconds
  logs: string | null;             // Console output
  error: string | null;            // Error message if failed
  output: JsonValue | null;        // Return value from script
}

// In your cron job code
console.log('Starting data sync...');
console.log(`Processing ${items.length} items`);
console.error('Warning: API rate limit approaching');

// These appear in execution.logs as:
// [2024-01-15T10:30:00.000Z] Starting data sync...
// [2024-01-15T10:30:01.234Z] Processing 150 items
// [2024-01-15T10:30:02.567Z] Warning: API rate limit approaching

// In your cron job code
const results = await processData();
return {
  processed: results.length,
  errors: results.filter(r => r.error).length,
  timestamp: new Date().toISOString()
};

// This object is stored in execution.output

interface ExecutionStats {
  totalExecutions: number;      // All-time execution count
  successCount: number;         // Successful executions
  failedCount: number;          // Failed executions
  lastSuccess: Date | null;     // Most recent success
  lastFailure: Date | null;     // Most recent failure
  avgExecutionTimeMs: number | null;  // Average duration
}

// Get execution details via API
const execution = await api.cronJob.getExecution({ id: 'exec-123' });

// Check status and error
if (execution.status === 'failed') {
  console.log('Error:', execution.error);
  console.log('Logs:', execution.logs);
  console.log('Duration:', execution.executionTimeMs, 'ms');
}

// For timeout issues
if (execution.status === 'timeout') {
  console.log('Job exceeded 5-minute limit');
  console.log('Last logged output:', execution.logs);
}