Method _parse_hybrid_search_resp3

redis/commands/search/commands.py:531–558

Parse RESP3 FT.HYBRID response into HybridResult/HybridCursorResult. Top-level keys are normalised to strings. Values are preserved as delivered by the wire (bytes when ``NEVER_DECODE`` is set, strings otherwise) so byte/str semantics match the RESP2 legacy parser.

(self, res, **kwargs)

    # ---- RESP3 HYBRID parsers ----

    def _parse_hybrid_search_resp3(self, res, **kwargs):
        """Parse RESP3 FT.HYBRID response into HybridResult/HybridCursorResult.

        Top-level keys are normalised to strings.  Values are preserved
        as delivered by the wire (bytes when ``NEVER_DECODE`` is set,
        strings otherwise) so byte/str semantics match the RESP2 legacy
        parser.
        """
        res = {str_if_bytes(k): v for k, v in res.items()}
        if "cursor" in kwargs:
            return HybridCursorResult(
                search_cursor_id=int(res["SEARCH"]),
                vsim_cursor_id=int(res["VSIM"]),
            )

        results: List[Dict[str, Any]] = []
        for res_item in res.get("results", []):
            if isinstance(res_item, dict):
                results.append({str_if_bytes(k): v for k, v in res_item.items()})
            else:
                results.append(pairs_to_dict(res_item, decode_keys=True))

        return HybridResult(
            total_results=int(res.get("total_results", 0)),
            results=results,
            warnings=res.get("warnings", []),
            execution_time=float(res.get("execution_time", 0)),
        )

    def _parse_hybrid_search_resp3_unified(self, res, **kwargs):
        """Parse RESP3 FT.HYBRID into the approved unified HybridResult."""