Execute a task from the queue with status updates. Transitions the task to Running, then delegates to `run_with_lifecycle` which handles execution and completion status updates.
(&self, task: &Task)
| 100 | /// Transitions the task to Running, then delegates to `run_with_lifecycle` which |
| 101 | /// handles execution and completion status updates. |
| 102 | pub async fn run_queued(&self, task: &Task) -> Result<TaskExecutionResult, TaskExecutionError> { |
| 103 | if let Err(e) = self.task_storage.mark_running(&task.id).await { |
| 104 | emit_or_print( |
| 105 | &self.event_sender, |
| 106 | ServerEvent::WarningMessage(format!("Error updating task status: {e}")), |
| 107 | ); |
| 108 | } |
| 109 | self.run_with_lifecycle(task).await |
| 110 | } |
| 111 | |
| 112 | /// Execute a task in a Docker container and update storage with the result. |
| 113 | /// |
no test coverage detected