houskeeping: linter run
This commit is contained in:
@@ -127,8 +127,7 @@ impl Controller {
|
|||||||
let project = Project::new(config)?;
|
let project = Project::new(config)?;
|
||||||
|
|
||||||
println!(
|
println!(
|
||||||
"\n{} {}\n",
|
"\nCreated pgd.toml in {}\n",
|
||||||
"Created pgd.toml in",
|
|
||||||
project.path.display().to_string().bright_white().bold()
|
project.path.display().to_string().bright_white().bold()
|
||||||
);
|
);
|
||||||
|
|
||||||
|
|||||||
@@ -1,5 +1,5 @@
|
|||||||
use miette::{Diagnostic, miette};
|
use miette::{Diagnostic, miette};
|
||||||
use std::{io::Write, str::FromStr};
|
use std::str::FromStr;
|
||||||
use thiserror::Error;
|
use thiserror::Error;
|
||||||
|
|
||||||
use bollard::{
|
use bollard::{
|
||||||
@@ -283,11 +283,11 @@ impl DockerController {
|
|||||||
..Default::default()
|
..Default::default()
|
||||||
});
|
});
|
||||||
|
|
||||||
let logs = self
|
|
||||||
|
|
||||||
|
self
|
||||||
.daemon
|
.daemon
|
||||||
.logs(container_id, options)
|
.logs(container_id, options)
|
||||||
.map(|k| k.into_diagnostic().wrap_err("Failed streaming logs"));
|
.map(|k| k.into_diagnostic().wrap_err("Failed streaming logs"))
|
||||||
|
|
||||||
logs
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -8,7 +8,7 @@ use indicatif::{MultiProgress, ProgressBar, ProgressState, ProgressStyle};
|
|||||||
fn new_download_pb(multi: &MultiProgress, layer_id: &str) -> ProgressBar {
|
fn new_download_pb(multi: &MultiProgress, layer_id: &str) -> ProgressBar {
|
||||||
let pb = multi.add(ProgressBar::new(0));
|
let pb = multi.add(ProgressBar::new(0));
|
||||||
pb.set_style(
|
pb.set_style(
|
||||||
ProgressStyle::with_template(&"{spinner:.green} [{elapsed_precise}] {msg} [{wide_bar:.cyan/blue}] {bytes}/{total_bytes} ({eta})".to_string())
|
ProgressStyle::with_template("{spinner:.green} [{elapsed_precise}] {msg} [{wide_bar:.cyan/blue}] {bytes}/{total_bytes} ({eta})")
|
||||||
.unwrap()
|
.unwrap()
|
||||||
.with_key("eta", |state: &ProgressState, w: &mut dyn Write| {
|
.with_key("eta", |state: &ProgressState, w: &mut dyn Write| {
|
||||||
write!(w, "{:.1}s", state.eta().as_secs_f64()).unwrap()
|
write!(w, "{:.1}s", state.eta().as_secs_f64()).unwrap()
|
||||||
|
|||||||
@@ -146,7 +146,7 @@ impl<'a> Reconciler<'a> {
|
|||||||
.is_container_running_by_id(container_id)
|
.is_container_running_by_id(container_id)
|
||||||
.await?
|
.await?
|
||||||
{
|
{
|
||||||
return Ok(());
|
Ok(())
|
||||||
} else {
|
} else {
|
||||||
miette::bail!("Container stopped unexpectedly after start");
|
miette::bail!("Container stopped unexpectedly after start");
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user