mirror of
https://github.com/storytold/artcraft.git
synced 2026-10-31 23:47:51 +00:00
fix required rust never type behavior (#939)
This commit is contained in:
1 parent
a36fe72832
commit
e7dc0abb36
8 files changed
+8
-8
No files matched your search
@@ -43,7 +43,7 @@ impl PremiumAvtPayload {
|
||||
let expire_at= Utc::now()
|
||||
.add(PremiumUserRedisKey::get_redis_ttl())
|
||||
.timestamp() as usize;
|
||||
redis.expire_at(self.key.as_str(), expire_at)?;
|
||||
redis.expire_at::<_, ()>(self.key.as_str(), expire_at)?;
|
||||
Ok(())
|
||||
}
|
||||
}
|
||||
+1
-1
@@ -44,7 +44,7 @@ impl PremiumIpAddressPayload {
|
||||
let expire_at= Utc::now()
|
||||
.add(PremiumUserRedisKey::get_redis_ttl())
|
||||
.timestamp() as usize;
|
||||
redis.expire_at(self.key.as_str(), expire_at)?;
|
||||
redis.expire_at::<_, ()>(self.key.as_str(), expire_at)?;
|
||||
Ok(())
|
||||
}
|
||||
}
|
||||
@@ -43,7 +43,7 @@ impl PremiumUserPayload {
|
||||
let expire_at= Utc::now()
|
||||
.add(PremiumUserRedisKey::get_redis_ttl())
|
||||
.timestamp() as usize;
|
||||
redis.expire_at(self.key.as_str(), expire_at)?;
|
||||
redis.expire_at::<_, ()>(self.key.as_str(), expire_at)?;
|
||||
Ok(())
|
||||
}
|
||||
}
|
||||
@@ -16,7 +16,7 @@ pub trait HkeyStoreAdapter {
|
||||
|
||||
fn persist_to_redis(&self, redis_key: &str, redis: &mut PooledConnection<RedisConnectionManager>) -> AnyhowResult<()> {
|
||||
let map = self.serialize_payload()?;
|
||||
redis.hset_multiple(redis_key, &map)?;
|
||||
redis.hset_multiple::<_, _, _, ()>(redis_key, &map)?;
|
||||
Ok(())
|
||||
}
|
||||
|
||||
|
||||
+1
-1
@@ -130,7 +130,7 @@ pub async fn infer_w2l_handler(
|
||||
|
||||
let redis_count_key = RedisKeys::w2l_template_usage_count(&w2l_template_token);
|
||||
|
||||
redis.incr(&redis_count_key, 1)
|
||||
redis.incr::<_, _, ()>(&redis_count_key, 1)
|
||||
.map_err(|e| {
|
||||
warn!("redis error: {:?}", e);
|
||||
InferW2lError::ServerError
|
||||
|
||||
+1
-1
@@ -233,7 +233,7 @@ pub async fn enqueue_infer_w2l_with_uploads(
|
||||
|
||||
let redis_count_key = RedisKeys::w2l_template_usage_count(&template_token);
|
||||
|
||||
redis.incr(&redis_count_key, 1)
|
||||
redis.incr::<_, _, ()>(&redis_count_key, 1)
|
||||
.map_err(|e| {
|
||||
warn!("redis error: {:?}", e);
|
||||
InferW2lWithUploadError::ServerError
|
||||
|
||||
+1
-1
@@ -369,7 +369,7 @@ pub async fn enqueue_infer_tts_handler(
|
||||
|
||||
let redis_count_key = RedisKeys::tts_model_usage_count(&request.tts_model_token);
|
||||
|
||||
redis.incr(&redis_count_key, 1)
|
||||
redis.incr::<_, _, ()>(&redis_count_key, 1)
|
||||
.map_err(|e| {
|
||||
warn!("redis error: {:?}", e);
|
||||
InferTtsError::ServerError
|
||||
|
||||
+1
-1
@@ -292,7 +292,7 @@ pub async fn enqueue_voice_conversion_inference_handler(
|
||||
|
||||
let redis_count_key = RedisKeys::web_vc_model_usage_count(&model_token);
|
||||
|
||||
redis.incr(&redis_count_key, 1)
|
||||
redis.incr::<_, _, ()>(&redis_count_key, 1)
|
||||
.map_err(|e| {
|
||||
warn!("redis error: {:?}", e);
|
||||
EnqueueVoiceConversionInferenceError::ServerError
|
||||
|
||||
Reference in new issue
Block a user