From 7aa35b6d06c0946dde0eeac754a40d663ded7901 Mon Sep 17 00:00:00 2001
From: Lee Smet <lee.smet@hotmail.com>
Date: Wed, 3 Sep 2025 20:16:53 +0200
Subject: [PATCH] Fix remainder of HSET return value deconding

Signed-off-by: Lee Smet <lee.smet@hotmail.com>
---
 src/storage/redis.rs | 16 ++++++++--------
 1 file changed, 8 insertions(+), 8 deletions(-)

diff --git a/src/storage/redis.rs b/src/storage/redis.rs
index ae6af95..f04e9e5 100644
--- a/src/storage/redis.rs
+++ b/src/storage/redis.rs
@@ -400,7 +400,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_message_status failed");
             e
         })?;
@@ -437,7 +437,7 @@ impl RedisDriver {
         let ts = crate::time::current_timestamp();
         pairs.push(("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_message_transport failed");
             e
         })?;
@@ -473,7 +473,7 @@ impl RedisDriver {
             ("env_vars".to_string(), env_vars_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_env_vars_merge failed");
             e
         })?;
@@ -509,7 +509,7 @@ impl RedisDriver {
             ("result".to_string(), result_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_result_merge failed");
             e
         })?;
@@ -546,7 +546,7 @@ impl RedisDriver {
             ("env_vars".to_string(), env_vars_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_env_vars_merge failed");
             e
         })?;
@@ -583,7 +583,7 @@ impl RedisDriver {
             ("result".to_string(), result_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_result_merge failed");
             e
         })?;
@@ -601,7 +601,7 @@ impl RedisDriver {
             ("jobs".to_string(), jobs_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_jobs_set failed");
             e
         })?;
@@ -635,7 +635,7 @@ impl RedisDriver {
             ("logs".to_string(), logs_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 append_message_logs failed");
             e
         })?;