|
|
@@ -12,7 +12,6 @@ use crate::{
|
|
|
ssh::{run_ssh, run_ssh_follow, run_ssh_with_retry},
|
|
|
};
|
|
|
|
|
|
-#[allow(clippy::too_many_arguments)]
|
|
|
pub async fn serve(
|
|
|
config: &Config,
|
|
|
recipe_name: &str,
|
|
|
@@ -20,9 +19,8 @@ pub async fn serve(
|
|
|
node_name: Option<&str>,
|
|
|
keep: bool,
|
|
|
skip_before_serve: bool,
|
|
|
- follow: bool,
|
|
|
dry_run: bool,
|
|
|
-) -> Result<()> {
|
|
|
+) -> Result<Cluster> {
|
|
|
let recipe = load_recipe(recipe_name).await?;
|
|
|
let rn = recipe.name.clone();
|
|
|
let re = recipe.engine.clone();
|
|
|
@@ -93,11 +91,7 @@ pub async fn serve(
|
|
|
dry_run,
|
|
|
)
|
|
|
.await?;
|
|
|
- if !dry_run && follow {
|
|
|
- info!("{}", fluent_i18n::t!("container-log-header"));
|
|
|
- show_logs(config, &cluster, recipe_name, true, dry_run).await?;
|
|
|
- }
|
|
|
- Ok(())
|
|
|
+ Ok(cluster)
|
|
|
}
|
|
|
pub(crate) fn logs_tail_cmd(recipe_name: &str, rank: u32, tail: usize) -> String {
|
|
|
format!(
|