Method
submit_by_tool
(
&self,
tool_name: &str,
command: Box<dyn SessionCommand>,
)
Source from the content-addressed store, hash-verified
| 373 | } |
| 374 | |
| 375 | pub async fn submit_by_tool( |
| 376 | &self, |
| 377 | tool_name: &str, |
| 378 | command: Box<dyn SessionCommand>, |
| 379 | ) -> oneshot::Receiver<Result<Value>> { |
| 380 | self.submit(SessionLane::from_tool_name(tool_name), command) |
| 381 | .await |
| 382 | } |
| 383 | |
| 384 | pub async fn complete_external_task(&self, task_id: &str, result: ExternalTaskResult) -> bool { |
| 385 | let pending = { self.external_tasks.write().await.remove(task_id) }; |