mirror of
https://github.com/juspay/hyperswitch.git
synced 2025-11-01 19:42:27 +08:00
chore: address Rust 1.68 clippy lints (#728)
This commit is contained in:
@ -345,13 +345,14 @@ where
|
|||||||
let lock_val = "LOCKED";
|
let lock_val = "LOCKED";
|
||||||
let ttl = settings.producer.lock_ttl;
|
let ttl = settings.producer.lock_ttl;
|
||||||
|
|
||||||
let result = if state
|
if state
|
||||||
.store
|
.store
|
||||||
.acquire_pt_lock(tag, lock_key, lock_val, ttl)
|
.acquire_pt_lock(tag, lock_key, lock_val, ttl)
|
||||||
.await
|
.await
|
||||||
.change_context(errors::ProcessTrackerError::ERedisError(
|
.change_context(errors::ProcessTrackerError::ERedisError(
|
||||||
errors::RedisError::RedisConnectionError.into(),
|
errors::RedisError::RedisConnectionError.into(),
|
||||||
))? {
|
))?
|
||||||
|
{
|
||||||
let result = callback().await;
|
let result = callback().await;
|
||||||
state
|
state
|
||||||
.store
|
.store
|
||||||
@ -361,8 +362,7 @@ where
|
|||||||
result
|
result
|
||||||
} else {
|
} else {
|
||||||
Ok(())
|
Ok(())
|
||||||
};
|
}
|
||||||
result
|
|
||||||
}
|
}
|
||||||
|
|
||||||
pub(crate) async fn signal_handler(
|
pub(crate) async fn signal_handler(
|
||||||
|
|||||||
Reference in New Issue
Block a user