diff --git a/crates/schema/database/redis_schema/src/payloads/premium/premium_avt_payload.rs b/crates/schema/database/redis_schema/src/payloads/premium/premium_avt_payload.rs index 7f509f7825..b03853b188 100644 --- a/crates/schema/database/redis_schema/src/payloads/premium/premium_avt_payload.rs +++ b/crates/schema/database/redis_schema/src/payloads/premium/premium_avt_payload.rs @@ -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(()) } } diff --git a/crates/schema/database/redis_schema/src/payloads/premium/premium_ip_address_payload.rs b/crates/schema/database/redis_schema/src/payloads/premium/premium_ip_address_payload.rs index 9e243dd0bf..0abf57472a 100644 --- a/crates/schema/database/redis_schema/src/payloads/premium/premium_ip_address_payload.rs +++ b/crates/schema/database/redis_schema/src/payloads/premium/premium_ip_address_payload.rs @@ -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(()) } } diff --git a/crates/schema/database/redis_schema/src/payloads/premium/premium_user_payload.rs b/crates/schema/database/redis_schema/src/payloads/premium/premium_user_payload.rs index b8da764aec..dc016a2692 100644 --- a/crates/schema/database/redis_schema/src/payloads/premium/premium_user_payload.rs +++ b/crates/schema/database/redis_schema/src/payloads/premium/premium_user_payload.rs @@ -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(()) } } diff --git a/crates/schema/database/redis_schema/src/traits/hkey_store_adapter.rs b/crates/schema/database/redis_schema/src/traits/hkey_store_adapter.rs index eac40b3b58..5d5a924465 100644 --- a/crates/schema/database/redis_schema/src/traits/hkey_store_adapter.rs +++ b/crates/schema/database/redis_schema/src/traits/hkey_store_adapter.rs @@ -16,7 +16,7 @@ pub trait HkeyStoreAdapter { fn persist_to_redis(&self, redis_key: &str, redis: &mut PooledConnection) -> AnyhowResult<()> { let map = self.serialize_payload()?; - redis.hset_multiple(redis_key, &map)?; + redis.hset_multiple::<_, _, _, ()>(redis_key, &map)?; Ok(()) } diff --git a/crates/service/web/storyteller_web/src/http_server/deprecated_endpoints/w2l/enqueue_infer_w2l.rs b/crates/service/web/storyteller_web/src/http_server/deprecated_endpoints/w2l/enqueue_infer_w2l.rs index c599b59ee8..8b9923844f 100644 --- a/crates/service/web/storyteller_web/src/http_server/deprecated_endpoints/w2l/enqueue_infer_w2l.rs +++ b/crates/service/web/storyteller_web/src/http_server/deprecated_endpoints/w2l/enqueue_infer_w2l.rs @@ -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 diff --git a/crates/service/web/storyteller_web/src/http_server/deprecated_endpoints/w2l/enqueue_infer_w2l_with_uploads.rs b/crates/service/web/storyteller_web/src/http_server/deprecated_endpoints/w2l/enqueue_infer_w2l_with_uploads.rs index ddd218b76a..777e7d97d6 100644 --- a/crates/service/web/storyteller_web/src/http_server/deprecated_endpoints/w2l/enqueue_infer_w2l_with_uploads.rs +++ b/crates/service/web/storyteller_web/src/http_server/deprecated_endpoints/w2l/enqueue_infer_w2l_with_uploads.rs @@ -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 diff --git a/crates/service/web/storyteller_web/src/http_server/endpoints/tts/enqueue_infer_tts_handler/enqueue_infer_tts_handler.rs b/crates/service/web/storyteller_web/src/http_server/endpoints/tts/enqueue_infer_tts_handler/enqueue_infer_tts_handler.rs index 45861bf714..fab5bbec30 100644 --- a/crates/service/web/storyteller_web/src/http_server/endpoints/tts/enqueue_infer_tts_handler/enqueue_infer_tts_handler.rs +++ b/crates/service/web/storyteller_web/src/http_server/endpoints/tts/enqueue_infer_tts_handler/enqueue_infer_tts_handler.rs @@ -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 diff --git a/crates/service/web/storyteller_web/src/http_server/endpoints/voice_conversion/enqueue_voice_conversion_inference_handler.rs b/crates/service/web/storyteller_web/src/http_server/endpoints/voice_conversion/enqueue_voice_conversion_inference_handler.rs index e3f1389899..26f57bf0c1 100644 --- a/crates/service/web/storyteller_web/src/http_server/endpoints/voice_conversion/enqueue_voice_conversion_inference_handler.rs +++ b/crates/service/web/storyteller_web/src/http_server/endpoints/voice_conversion/enqueue_voice_conversion_inference_handler.rs @@ -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