herocode/herocoordinator
13
0
Fork 0
Code Issues 1 Pull Requests Actions Packages Projects Releases Wiki Activity

Fix remainder of HSET return value deconding

Browse Source 
Signed-off-by: Lee Smet <lee.smet@hotmail.com>
This commit is contained in:
Lee Smet
2025-09-03 20:16:53 +02:00
parent 60946af1df
commit 7aa35b6d06
1 changed files with 8 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
src/storage/redis.rs
View File

@@ -400,7 +400,7 @@ impl RedisDriver {
("status".to_string(), status_str), ("status".to_string(), status_str),
("updated_at".to_string(), ts.to_string()), ("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"); error!(db=%db, key=%key, error=%e, "HSET update_message_status failed");
e e
})?; })?;
@@ -437,7 +437,7 @@ impl RedisDriver {
let ts = crate::time::current_timestamp(); let ts = crate::time::current_timestamp();
pairs.push(("updated_at".to_string(), ts.to_string())); 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"); error!(db=%db, key=%key, error=%e, "HSET update_message_transport failed");
e e
})?; })?;
@@ -473,7 +473,7 @@ impl RedisDriver {
("env_vars".to_string(), env_vars_str), ("env_vars".to_string(), env_vars_str),
("updated_at".to_string(), ts.to_string()), ("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"); error!(db=%db, key=%key, error=%e, "HSET update_flow_env_vars_merge failed");
e e
})?; })?;
@@ -509,7 +509,7 @@ impl RedisDriver {
("result".to_string(), result_str), ("result".to_string(), result_str),
("updated_at".to_string(), ts.to_string()), ("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"); error!(db=%db, key=%key, error=%e, "HSET update_flow_result_merge failed");
e e
})?; })?;
@@ -546,7 +546,7 @@ impl RedisDriver {
("env_vars".to_string(), env_vars_str), ("env_vars".to_string(), env_vars_str),
("updated_at".to_string(), ts.to_string()), ("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"); error!(db=%db, key=%key, error=%e, "HSET update_job_env_vars_merge failed");
e e
})?; })?;
@@ -583,7 +583,7 @@ impl RedisDriver {
("result".to_string(), result_str), ("result".to_string(), result_str),
("updated_at".to_string(), ts.to_string()), ("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"); error!(db=%db, key=%key, error=%e, "HSET update_job_result_merge failed");
e e
})?; })?;
@@ -601,7 +601,7 @@ impl RedisDriver {
("jobs".to_string(), jobs_str), ("jobs".to_string(), jobs_str),
("updated_at".to_string(), ts.to_string()), ("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"); error!(db=%db, key=%key, error=%e, "HSET update_flow_jobs_set failed");
e e
})?; })?;
@@ -635,7 +635,7 @@ impl RedisDriver {
("logs".to_string(), logs_str), ("logs".to_string(), logs_str),
("updated_at".to_string(), ts.to_string()), ("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"); error!(db=%db, key=%key, error=%e, "HSET append_message_logs failed");
e e
})?; })?;