Revert "Spawn daemon in separate process (this should fail in CI)"
This reverts commit f92c44ab59
.
This commit is contained in:
parent
645dabfe82
commit
08033cd09a
4
.github/workflows/build.yaml
vendored
4
.github/workflows/build.yaml
vendored
|
@ -41,8 +41,8 @@ jobs:
|
|||
|
||||
- name: Build package and create closure for ${{ matrix.systems.system }}
|
||||
run: |
|
||||
nix build .# -L --fallback
|
||||
nix-store --export $(nix-store -qR ./result) | xz -9 > "${{ env.ARCHIVE_NAME }}"
|
||||
nix build .# -L --fallback && \
|
||||
nix-store --export $(nix-store -qR ./result) | xz -9 > "${{ env.ARCHIVE_NAME }}"
|
||||
|
||||
- name: Upload magic-nix-cache closure for ${{ matrix.systems.system }}
|
||||
uses: actions/upload-artifact@v3.1.2
|
||||
|
|
|
@ -26,7 +26,6 @@ use std::io::Write;
|
|||
use std::net::SocketAddr;
|
||||
use std::os::unix::fs::PermissionsExt;
|
||||
use std::path::{Path, PathBuf};
|
||||
use std::process::exit;
|
||||
use std::sync::Arc;
|
||||
|
||||
use ::attic::nix_store::NixStore;
|
||||
|
@ -371,21 +370,6 @@ async fn main_cli() -> Result<()> {
|
|||
|
||||
tracing::info!("Listening on {}", args.listen);
|
||||
|
||||
let server = axum::Server::bind(&args.listen)
|
||||
.serve(app.into_make_service())
|
||||
.with_graceful_shutdown(async move {
|
||||
shutdown_receiver.await.ok();
|
||||
tracing::info!("Shutting down");
|
||||
});
|
||||
|
||||
// Spawn here so that post-startup tasks can proceed
|
||||
tokio::spawn(async move {
|
||||
if let Err(e) = server.await {
|
||||
tracing::error!("failed to start up daemon: {e}");
|
||||
exit(1);
|
||||
}
|
||||
});
|
||||
|
||||
// Notify of startup via HTTP
|
||||
if let Some(startup_notification_url) = args.startup_notification_url {
|
||||
tracing::debug!("Startup notification via HTTP POST to {startup_notification_url}");
|
||||
|
@ -427,11 +411,21 @@ async fn main_cli() -> Result<()> {
|
|||
tracing::debug!("Created startup notification file at {startup_notification_file_path:?}");
|
||||
}
|
||||
|
||||
let ret = axum::Server::bind(&args.listen)
|
||||
.serve(app.into_make_service())
|
||||
.with_graceful_shutdown(async move {
|
||||
shutdown_receiver.await.ok();
|
||||
tracing::info!("Shutting down");
|
||||
})
|
||||
.await;
|
||||
|
||||
// Notify diagnostics endpoint
|
||||
if let Some(diagnostic_endpoint) = diagnostic_endpoint {
|
||||
state.metrics.send(diagnostic_endpoint).await;
|
||||
}
|
||||
|
||||
ret?;
|
||||
|
||||
Ok(())
|
||||
}
|
||||
|
||||
|
|
Loading…
Reference in a new issue