Method execute_single_task

src/server/scheduler.rs:776–785

Execute a single task

(
        context: &AppContext,
        docker_client: Arc<dyn DockerClient>,
        task: &Task,
        event_sender: Option<ServerEventSender>,
    )

impl TaskJob {
    /// Execute a single task
    async fn execute_single_task(
        context: &AppContext,
        docker_client: Arc<dyn DockerClient>,
        task: &Task,
        event_sender: Option<ServerEventSender>,
    ) -> Result<(), TaskExecutionError> {
        let docker_manager = DockerManager::new(context, docker_client, event_sender.clone());
        let task_runner = TaskRunner::new(context, docker_manager, event_sender);
        task_runner.run_queued(task).await.map(|_| ())
    }
}

#[cfg(test)]