(&self)
| 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()?; |
| 125 | let snapshot = self.run_store.snapshot(&run_id).await?; |
| 126 | Some(self.run_handle(snapshot.id, snapshot.session_id)) |
| 127 | } |
| 128 | |
| 129 | fn run_handle(&self, run_id: String, session_id: String) -> crate::run::RunHandle { |
| 130 | crate::run::RunHandle::new( |
no test coverage detected