mirrors/magic-nix-cache
1
0
Fork 0
Code Issues Pull requests Actions Packages Projects Releases Wiki Activity

wip: wait for flakehub pushes before shutting down?

Browse source
This commit is contained in:
Cole Helbling 2024-04-24 14:23:22 -07:00
parent 1c83c37f4e
commit f06ed35360
1 changed files with 6 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

10
magic-nix-cache/src/api.rs
View file

@ -45,16 +45,16 @@ async fn workflow_finish(
gha_cache.shutdown().await?; gha_cache.shutdown().await?;
} }
if let Some(sender) = state.shutdown_sender.lock().await.take() {
sender
.send(())
.map_err(|_| Error::Internal("Sending shutdown server message".to_owned()))?;
// Wait for the Attic push workers to finish. // Wait for the Attic push workers to finish.
if let Some(attic_state) = state.flakehub_state.write().await.take() { if let Some(attic_state) = state.flakehub_state.write().await.take() {
tracing::info!("Waiting for FlakeHub cache uploads to finish"); tracing::info!("Waiting for FlakeHub cache uploads to finish");
attic_state.push_session.wait().await?; attic_state.push_session.wait().await?;
} }
if let Some(sender) = state.shutdown_sender.lock().await.take() {
sender
.send(())
.map_err(|_| Error::Internal("Sending shutdown server message".to_owned()))?;
} }
// NOTE(cole-h): see `init_logging` // NOTE(cole-h): see `init_logging`