Method _run_task

core/background.py:137–166

Execute a background task with timeout and error handling.

(self, task: BackgroundTask)

        return True
    
    async def _run_task(self, task: BackgroundTask):
        """Execute a background task with timeout and error handling."""
        try:
            # Run the task function
            if asyncio.iscoroutinefunction(task.func):
                await asyncio.wait_for(task.func(), timeout=task.timeout)
            else:
                # Run sync function in executor
                loop = asyncio.get_event_loop()
                await loop.run_in_executor(None, task.func)
            
            task.status = BackgroundTaskStatus.COMPLETED
            task.stopped_at = time.time()
            success(f"Background: completed task '{task.name}'")
            
        except asyncio.TimeoutError:
            task.status = BackgroundTaskStatus.FAILED
            task.error = f"Timeout after {task.timeout}s"
            error(f"Background: task '{task.name}' timed out")
            
        except asyncio.CancelledError:
            task.status = BackgroundTaskStatus.STOPPED
            task.stopped_at = time.time()
            info(f"Background: stopped task '{task.name}'")
            
        except Exception as e:
            task.status = BackgroundTaskStatus.FAILED
            task.error = str(e)
            task.stopped_at = time.time()
            error(f"Background: task '{task.name}' failed: {e}")
    
    def stop_task(self, task_id: str) -> bool:
        """