diff --git a/src/capmc.rs b/src/capmc.rs index 4496d38..65b1b58 100644 --- a/src/capmc.rs +++ b/src/capmc.rs @@ -437,7 +437,7 @@ pub mod utils { .collect(); print!( - "\rWaiting nodes to power on. Transitioning: {:?} ==> ON: {:?}. Trying again in {} seconds. Attempt {} of {}", + "\rWaiting nodes to power on. Transitioning: {:?} ==> ON: {:?}. Trying again in {} seconds. Attempt {} of {}.", xname_vec.iter().filter(|xname| !node_on_vec.contains(xname)).collect::>(), node_on_vec, delay_secs, @@ -499,7 +499,7 @@ pub mod utils { .collect(); print!( - "\rWaiting nodes to power off. Transitioning: {:?} ==> OFF: {:?}. Trying again in {} seconds. Attempt {} of {}", + "\rWaiting nodes to power off. Transitioning: {:?} ==> OFF: {:?}. Trying again in {} seconds. Attempt {} of {}.", xname_vec.iter().filter(|xname| !node_off_vec.contains(xname)).collect::>(), node_off_vec, delay_secs, diff --git a/src/cfs/component/mesa/http_client.rs b/src/cfs/component/mesa/http_client.rs index 141acee..cc3a4ab 100644 --- a/src/cfs/component/mesa/http_client.rs +++ b/src/cfs/component/mesa/http_client.rs @@ -87,7 +87,7 @@ pub async fn get_multiple( let width = num_chunks.checked_ilog10().unwrap_or(0) as usize + 1; for sub_node_list in hsm_groups_node_list.chunks(chunk_size) { - print!("\rGetting CFS components [{i:>width$}/{num_chunks}]"); + print!("\rGetting CFS components (batch size - {num_chunks}) [{i:>width$}/{num_chunks}]."); io::stdout().flush().unwrap(); let shasta_token_string = shasta_token.to_string(); diff --git a/src/cfs/session.rs b/src/cfs/session.rs index e299d33..cb5b2ca 100644 --- a/src/cfs/session.rs +++ b/src/cfs/session.rs @@ -1374,7 +1374,7 @@ pub mod mesa { print!("\x1B[2K"); // Clear current line io::stdout().flush().unwrap(); print!( - "\rWaiting CFS session '{}' with status '{}'. Checking again in 2 secs. Attempt {} of {}", + "\rWaiting CFS session '{}' with status '{}'. Checking again in 2 secs. Attempt {} of {}.", cfs_session_id, cfs_session_status, i, max ); io::stdout().flush().unwrap(); diff --git a/src/common/local_git_repo.rs b/src/common/local_git_repo.rs index 99b826e..0095006 100644 --- a/src/common/local_git_repo.rs +++ b/src/common/local_git_repo.rs @@ -246,13 +246,13 @@ pub fn fetch<'a>( cb.transfer_progress(|stats| { if stats.received_objects() == stats.total_objects() { print!( - "Resolving deltas {}/{}\r", + "Resolving deltas {}/{}.\r", stats.indexed_deltas(), stats.total_deltas() ); } else if stats.total_objects() > 0 { print!( - "Received {}/{} objects ({}) in {} bytes\r", + "Received {}/{} objects ({}) in {} bytes.\r", stats.received_objects(), stats.total_objects(), stats.indexed_objects(), diff --git a/src/ims/job/utils.rs b/src/ims/job/utils.rs index d9525d3..109f687 100644 --- a/src/ims/job/utils.rs +++ b/src/ims/job/utils.rs @@ -34,7 +34,7 @@ pub async fn wait_ims_job_to_finish( print!("\x1B[2K"); // Clear current line io::stdout().flush().unwrap(); print!( - "\rWaiting IMS job '{}' with job status '{}'. Checking again in 2 secs. Attempt {} of {}", + "\rWaiting IMS job '{}' with job status '{}'. Checking again in 2 secs. Attempt {} of {}.", ims_job_id, ims_job_status, i, max ); io::stdout().flush().unwrap();