MCPcopy Create free account
hub / github.com/dtormoen/tsk-tsk / run_queued

Method run_queued

src/task_runner.rs:102–110  ·  view source on GitHub ↗

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)

Source from the content-addressed store, hash-verified

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 ///

Callers 1

execute_single_taskMethod · 0.80

Calls 3

emit_or_printFunction · 0.85
mark_runningMethod · 0.80
run_with_lifecycleMethod · 0.80

Tested by

no test coverage detected