Async Background Task Error Handling

2. Backend Wrapper (The "Safe Runner")

Wrap your background logic in a robust specific error handler that guarantees a DB write.

async function safeBackgroundTask(taskId: string, taskLogic: () => Promise<any>) {
  try {
    // 1. Run the actual logic
    const result = await taskLogic();
    
    // 2. On Success: Write result
    await db.update(taskId, {
      status: 'completed',
      result_data: result
    });
    
  } catch (error) {
    console.error(`Task ${taskId} failed:`, error);
    
    // 3. On Failure: CRITICAL - Write error to DB
    // This allows the frontend to stop polling
    await db.update(taskId, {
      status: 'failed',
      error_message: error.message || 'Unknown system error'
    });
  }
}

3. Frontend Polling

The polling logic should check for both success and failure states.

const poll = setInterval(async () => {
  const status = await checkStatus(taskId);
  
  if (status.state === 'completed') {
    showResult(status.data);
    clearInterval(poll);
  } 
  else if (status.state === 'failed') {
    // Handle the explicit error state
    showError(status.error_message);
    clearInterval(poll);
  }
  // If 'pending', continue polling...
}, 2000);

Checklist for Implementation

• Schema: Does the DB have an error column?
• Catch: Is the background task wrapped in a top-level try/catch?
• Persist: Does the catch block write to the DB?
• UI: Does the frontend poll handler check for error states?

Reference

Refer to TrafficLens implementation where last_error was added to traffic_latest table to resolve infinite scraping loops.