diff --git a/src/storage/redis.rs b/src/storage/redis.rs index f4a2774..ae6af95 100644 --- a/src/storage/redis.rs +++ b/src/storage/redis.rs @@ -323,7 +323,7 @@ impl RedisDriver { ("status".to_string(), status_str), ("updated_at".to_string(), ts.to_string()), ]; - let _: usize = cm.hset_multiple(&key, &pairs).await.map_err(|e| { + let _: () = cm.hset_multiple(&key, &pairs).await.map_err(|e| { error!(db=%db, key=%key, error=%e, "HSET update_job_status failed"); e })?; @@ -372,7 +372,7 @@ impl RedisDriver { ("status".to_string(), status_str), ("updated_at".to_string(), ts.to_string()), ]; - let _: usize = cm.hset_multiple(&key, &pairs).await.map_err(|e| { + let _: () = cm.hset_multiple(&key, &pairs).await.map_err(|e| { error!(db=%db, key=%key, error=%e, "HSET update_flow_status failed"); e })?;