From 24ba51df94dab6cdd2b7aaf64eb5132119fe460c Mon Sep 17 00:00:00 2001 From: conorbros Date: Wed, 13 Sep 2023 22:59:45 +1000 Subject: [PATCH] remove debugreturner changes --- shotover/src/transforms/debug/returner.rs | 4 ++-- .../transforms/distributed/tuneable_consistency_scatter.rs | 4 +--- 2 files changed, 3 insertions(+), 5 deletions(-) diff --git a/shotover/src/transforms/debug/returner.rs b/shotover/src/transforms/debug/returner.rs index 4b59d1825..96398a4f7 100644 --- a/shotover/src/transforms/debug/returner.rs +++ b/shotover/src/transforms/debug/returner.rs @@ -26,7 +26,7 @@ pub enum Response { #[serde(skip)] Message(Messages), Redis(String), - Fail(String), + Fail, } #[derive(Debug, Clone)] @@ -68,7 +68,7 @@ impl Transform for DebugReturner { ))) }) .collect()), - Response::Fail(s) => Err(anyhow!(s.clone())), + Response::Fail => Err(anyhow!("Intentional Fail")), } } } diff --git a/shotover/src/transforms/distributed/tuneable_consistency_scatter.rs b/shotover/src/transforms/distributed/tuneable_consistency_scatter.rs index 0633ccded..cc5249c47 100644 --- a/shotover/src/transforms/distributed/tuneable_consistency_scatter.rs +++ b/shotover/src/transforms/distributed/tuneable_consistency_scatter.rs @@ -321,9 +321,7 @@ mod scatter_transform_tests { ))]); let ok_repeat = Box::new(DebugReturner::new(Response::Message(response.clone()))); - let err_repeat = Box::new(DebugReturner::new(Response::Fail( - "intentional fail".into(), - ))); + let err_repeat = Box::new(DebugReturner::new(Response::Fail)); let mut two_of_three = HashMap::new(); two_of_three.insert(