[cluster-test] Remove log prune

Log prune was previously used to cleanup cloudwatch logs
Since we don't longer use cloud watch this is not needed

testsuite/cluster-test/Cargo.toml

@@ -21,7 +21,6 @@ rusoto_core = {version = "0.41.0", features=["rustls"], default_features = false
 rusoto_ec2 = {version = "0.41.0", features=["rustls"], default_features = false}
 rusoto_ecr = {version = "0.41.0", features=["rustls"], default_features = false}
 rusoto_ecs = {version = "0.41.0", features=["rustls"], default_features = false}
-rusoto_logs = {version = "0.41.0", features=["rustls"], default_features = false}
 serde_json = "1.0"
 termion = "1.5.3"
 serde = { version = "1.0.89", features = ["derive"] }

testsuite/cluster-test/src/lib.rs

@@ -9,7 +9,6 @@ pub mod experiments;
 pub mod github;
 pub mod health;
 pub mod instance;
-pub mod log_prune;
 pub mod prometheus;
 pub mod slack;
 pub mod suite;

testsuite/cluster-test/src/main.rs

@@ -17,7 +17,6 @@ use cluster_test::{
     effects::{Action, Effect, Reboot, StopContainer},
     experiments::{Experiment, RebootRandomValidators},
     health::{DebugPortLogThread, HealthCheckRunner, LogTail},
-    log_prune::LogPruner,
     slack::SlackClient,
     suite::ExperimentSuite,
     tx_emitter::TxEmitter,
@@ -48,7 +47,7 @@ const HEALTH_POLL_INTERVAL: Duration = Duration::from_secs(5);
 struct Args {
     #[structopt(short = "w", long, conflicts_with = "swarm")]
     workplace: Option<String>,
-    #[structopt(short = "p", long, use_delimiter = true, conflicts_with = "prune-logs")]
+    #[structopt(short = "p", long, use_delimiter = true)]
     peers: Vec<String>,
 
     #[structopt(
@@ -68,8 +67,6 @@ struct Args {
     #[structopt(long, group = "action")]
     health_check: bool,
     #[structopt(long, group = "action")]
-    prune_logs: bool,
-    #[structopt(long, group = "action")]
     reboot: bool,
     #[structopt(long, group = "action")]
     restart: bool,
@@ -156,11 +153,7 @@ pub fn main() {
         panic!("Can only use --emit-tx option in --swarm mode");
     }
 
-    if args.prune_logs {
-        let util = ClusterUtil::setup(&args);
-        util.prune_logs();
-        return;
-    } else if args.emit_tx {
+    if args.emit_tx {
         let thread_params = EmitThreadParams {
             wait_millis: args.wait_millis,
             wait_committed: !args.burst,
@@ -343,11 +336,6 @@ impl ClusterUtil {
         }
     }
 
-    pub fn prune_logs(&self) {
-        let log_prune = LogPruner::new(self.aws.clone());
-        log_prune.prune_logs();
-    }
-
     pub fn emit_tx(self, accounts_per_client: usize, thread_params: EmitThreadParams) {
         let mut emitter = TxEmitter::new(&self.cluster);
         emitter