mirror of
https://github.com/juspay/hyperswitch.git
synced 2025-10-29 00:49:42 +08:00
chore: address Rust 1.81.0 clippy lints (#5832)
This commit is contained in:
@ -259,12 +259,11 @@ where
|
||||
|
||||
result
|
||||
.await
|
||||
.map(|result| {
|
||||
.inspect(|_| {
|
||||
logger::debug!(kv_operation= %operation, status="success");
|
||||
let keyvalue = router_env::opentelemetry::KeyValue::new("operation", operation.clone());
|
||||
|
||||
metrics::KV_OPERATION_SUCCESSFUL.add(&metrics::CONTEXT, 1, &[keyvalue]);
|
||||
result
|
||||
})
|
||||
.inspect_err(|err| {
|
||||
logger::error!(kv_operation = %operation, status="error", error = ?err);
|
||||
|
||||
@ -30,7 +30,7 @@ impl PubSubInterface for std::sync::Arc<redis_interface::RedisConnectionPool> {
|
||||
self.subscriber.manage_subscriptions();
|
||||
|
||||
self.subscriber
|
||||
.subscribe(channel)
|
||||
.subscribe::<(), &str>(channel)
|
||||
.await
|
||||
.change_context(redis_errors::RedisError::SubscribeError)?;
|
||||
|
||||
|
||||
Reference in New Issue
Block a user