Skip to content

Commit 75d984f

Browse files
committed
Shutdown the coordinator when getting meta information
1 parent cd1d1c8 commit 75d984f

File tree

1 file changed

+28
-3
lines changed

1 file changed

+28
-3
lines changed

ui/src/server_axum.rs

Lines changed: 28 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -612,29 +612,54 @@ struct SandboxCache {
612612
impl SandboxCache {
613613
async fn crates(&self) -> Result<Stamped<MetaCratesResponse>> {
614614
let coordinator = Coordinator::new_docker().await;
615-
self.crates
615+
616+
let c = self
617+
.crates
616618
.fetch(|| async { Ok(coordinator.crates().await.context(CratesSnafu)?.into()) })
619+
.await;
620+
621+
coordinator
622+
.shutdown()
617623
.await
624+
.context(ShutdownCoordinatorSnafu)?;
625+
626+
c
618627
}
619628

620629
async fn versions(&self) -> Result<Stamped<MetaVersionsResponse>> {
621630
let coordinator = Coordinator::new_docker().await;
622631

623-
self.versions
632+
let v = self
633+
.versions
624634
.fetch(|| async { Ok(coordinator.versions().await.context(VersionsSnafu)?.into()) })
635+
.await;
636+
637+
coordinator
638+
.shutdown()
625639
.await
640+
.context(ShutdownCoordinatorSnafu)?;
641+
642+
v
626643
}
627644

628645
async fn raw_versions(&self) -> Result<Stamped<Arc<Versions>>> {
629646
let coordinator = Coordinator::new_docker().await;
630647

631-
self.raw_versions
648+
let rv = self
649+
.raw_versions
632650
.fetch(|| async {
633651
Ok(Arc::new(
634652
coordinator.versions().await.context(VersionsSnafu)?,
635653
))
636654
})
655+
.await;
656+
657+
coordinator
658+
.shutdown()
637659
.await
660+
.context(ShutdownCoordinatorSnafu)?;
661+
662+
rv
638663
}
639664

640665
async fn version_stable(&self) -> Result<Stamped<MetaVersionResponse>> {

0 commit comments

Comments
 (0)