Skip to content

Commit

Permalink
refactor
Browse files Browse the repository at this point in the history
  • Loading branch information
ColoCarletti committed May 14, 2024
1 parent c36713a commit bdba814
Showing 1 changed file with 14 additions and 33 deletions.
47 changes: 14 additions & 33 deletions prover/prover_cli/src/commands/status/batch.rs
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
use std::collections::HashMap;
use std::collections::{BTreeMap, HashMap};

use anyhow::Context as _;
use circuit_definitions::zkevm_circuits::scheduler::aux::BaseLayerCircuitType;
Expand Down Expand Up @@ -339,47 +339,28 @@ fn display_prover_jobs_info(prover_jobs_info: Vec<ProverJobFriInfo>) {
"Prover Jobs".to_owned().bold()
);

let mut jobs_by_circuit_id: HashMap<u32, Vec<ProverJobFriInfo>> = HashMap::new();

let mut jobs_by_circuit_id: BTreeMap<u32, Vec<ProverJobFriInfo>> = BTreeMap::new();
prover_jobs_info.iter().for_each(|job| {
jobs_by_circuit_id
.entry(job.circuit_id)
.or_default()
.push(job.clone())
});

let mut jobs_by_circuit_id: Vec<(u32, Vec<ProverJobFriInfo>)> = jobs_by_circuit_id
.iter()
.map(|(key, value)| (*key, value.clone()))
.collect();

jobs_by_circuit_id.sort_by_key(|job| job.0);

for (circuit_id, prover_jobs_info) in jobs_by_circuit_id {
let status = Status::from(prover_jobs_info.clone());
match status {
Status::InProgress => {
println!(
" > {}: {}",
format!(
"{:?}",
BaseLayerCircuitType::from_numeric_value(circuit_id as u8)
)
.bold(),
status
);
display_job_status_count(prover_jobs_info);
}
_ => println!(
" > {}: {}",
format!(
"{:?}",
BaseLayerCircuitType::from_numeric_value(circuit_id as u8)
)
.bold(),
status
),
};
println!(
" > {}: {}",
format!(
"{:?}",
BaseLayerCircuitType::from_numeric_value(circuit_id as u8)
)
.bold(),
status
);
if matches!(status, Status::InProgress) {
display_job_status_count(prover_jobs_info);
}
}
}

Expand Down

0 comments on commit bdba814

Please sign in to comment.