Fix error message in valkeyClusterAsyncFormattedCommand

Keep the error message received from valkeyAsyncFormattedCommand() in the cluster context. Signed-off-by: Björn Svensson <[email protected]>
valkey-io · Aug 19, 2024 · facee13 · facee13
1 parent a472f2a
commit facee13
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/src/valkeycluster.c b/src/valkeycluster.c
@@ -3417,6 +3417,7 @@ int valkeyClusterAsyncFormattedCommand(valkeyClusterAsyncContext *acc,
     status = valkeyAsyncFormattedCommand(ac, valkeyClusterAsyncCallback, cad,
                                          cmd, len);
     if (status != VALKEY_OK) {
+        valkeyClusterAsyncSetError(acc, ac->err, ac->errstr);
         goto error;
     }
     return VALKEY_OK;
@@ -3485,8 +3486,10 @@ int valkeyClusterAsyncFormattedCommandToNode(valkeyClusterAsyncContext *acc,
 
     status = valkeyAsyncFormattedCommand(ac, valkeyClusterAsyncCallback, cad,
                                          cmd, len);
-    if (status != VALKEY_OK)
+    if (status != VALKEY_OK) {
+        valkeyClusterAsyncSetError(acc, ac->err, ac->errstr);
         goto error;
+    }
 
     return VALKEY_OK;