fixes error assertion if case

DiceDB · Nov 17, 2024 · f2267bd · f2267bd
1 parent 76b0ea6
commit f2267bd
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/internal/worker/worker.go b/internal/worker/worker.go
@@ -222,6 +222,8 @@ func (w *BaseWorker) executeCommand(ctx context.Context, diceDBCmd *cmd.DiceDBCm
 				var customErr *diceerrors.PreProcessError
 				if errors.As(err, &customErr) {
 					workerErr = w.ioHandler.Write(ctx, customErr.Result)
+				} else {
+					workerErr = w.ioHandler.Write(ctx, err)
 				}
 				if workerErr != nil {
 					slog.Debug("Error executing for worker", slog.String("workerID", w.id), slog.Any("error", workerErr))