diff --git a/coordinator/src/redis.rs b/coordinator/src/redis.rs index 1bc3f3501..a5c26d28a 100644 --- a/coordinator/src/redis.rs +++ b/coordinator/src/redis.rs @@ -183,7 +183,7 @@ impl RedisClientImpl { self.connection .clone() - .keys(&key) + .del(&key) .await .map_err(|e| anyhow::format_err!(e)) .context(format!("DEL {key:?}"))