(&self, run_id: &str)
| 114 | } |
| 115 | |
| 116 | pub(super) async fn cancel_run(&self, run_id: &str) -> bool { |
| 117 | match self.current_run().await { |
| 118 | Some(run) if run.id() == run_id => run.cancel().await, |
| 119 | _ => false, |
| 120 | } |
| 121 | } |
| 122 | |
| 123 | pub(super) async fn current_run(&self) -> Option<crate::run::RunHandle> { |
| 124 | let run_id = self.current_run_id.lock().await.clone()?; |
nothing calls this directly
no test coverage detected