ALPHA: wire is a tool to deploy nixos systems
wire.althaea.zone/
[autofix.ci] apply automated fixes
authored by
autofix-ci[bot]
and committed by
marshmallow
05f6eb66
20aa4e70
+15
-10
+15
-10
wire/lib/src/hive/node.rs
+15
-10
wire/lib/src/hive/node.rs
···
5
5
use enum_dispatch::enum_dispatch;
6
6
use gethostname::gethostname;
7
7
use serde::{Deserialize, Serialize};
8
-
use tokio::sync::oneshot;
9
8
use std::collections::HashMap;
10
9
use std::env;
11
10
use std::fmt::Display;
12
11
use std::io::ErrorKind;
13
12
use std::path::PathBuf;
14
-
use std::sync::{Arc};
13
+
use std::sync::Arc;
14
+
use tokio::sync::oneshot;
15
15
use tracing::{Instrument, Level, debug, error, event, instrument, trace, warn};
16
16
17
17
use crate::commands::common::evaluate_hive_attribute;
···
390
390
clobber_lock.clone(),
391
391
)
392
392
.await
393
-
.map(|output| serde_json::from_str::<Derivation>(&output).expect("failed to parse derivation"));
393
+
.map(|output| {
394
+
serde_json::from_str::<Derivation>(&output).expect("failed to parse derivation")
395
+
});
394
396
395
397
debug!(output = ?output, done = true);
396
398
···
403
405
self.context.state.evaluation_rx = Some(rx);
404
406
405
407
if !matches!(self.context.goal, Goal::Keys) {
406
-
tokio::spawn(GoalExecutor::evaluate_task(
407
-
tx,
408
-
self.context.hive_location.clone(),
409
-
self.context.name.clone(),
410
-
self.context.modifiers,
411
-
self.context.clobber_lock.clone(),
412
-
).in_current_span());
408
+
tokio::spawn(
409
+
GoalExecutor::evaluate_task(
410
+
tx,
411
+
self.context.hive_location.clone(),
412
+
self.context.name.clone(),
413
+
self.context.modifiers,
414
+
self.context.clobber_lock.clone(),
415
+
)
416
+
.in_current_span(),
417
+
);
413
418
}
414
419
415
420
let steps = self