fix: utf-16 json encoder support (#28486)

Co-authored-by: Eyal Ezer <eyal.ezer@ge.com>

superset/sqllab/execution_context_convertor.py

@@ -52,13 +52,22 @@ class ExecutionContextConvertor:
 
     def serialize_payload(self) -> str:
         if self._exc_status == SqlJsonExecutionStatus.HAS_RESULTS:
-            return json.dumps(
-                apply_display_max_row_configuration_if_require(
-                    self.payload, self._max_row_in_display_configuration
-                ),
-                default=utils.pessimistic_json_iso_dttm_ser,
-                ignore_nan=True,
+            sql_results = apply_display_max_row_configuration_if_require(
+                self.payload, self._max_row_in_display_configuration
             )
+            try:
+                return json.dumps(
+                    sql_results,
+                    default=utils.pessimistic_json_iso_dttm_ser,
+                    ignore_nan=True,
+                )
+            except UnicodeDecodeError:
+                return json.dumps(
+                    sql_results,
+                    default=utils.pessimistic_json_iso_dttm_ser,
+                    ensure_ascii=False,
+                    ignore_nan=True,
+                )
 
         return json.dumps(
             {"query": self.payload}, default=utils.json_int_dttm_ser, ignore_nan=True

superset/utils/core.py

@@ -482,7 +482,10 @@ def base_json_conv(obj: Any) -> Any:
         try:
             return obj.decode("utf-8")
         except Exception:  # pylint: disable=broad-except
-            return "[bytes]"
+            try:
+                return obj.decode("utf-16")
+            except Exception:  # pylint: disable=broad-except
+                return "[bytes]"
 
     raise TypeError(f"Unserializable object {obj} of type {type(obj)}")
 

tests/integration_tests/utils_tests.py

@@ -127,7 +127,8 @@ class TestUtils(SupersetTestCase):
         assert isinstance(base_json_conv(time()), str)
         assert isinstance(base_json_conv(timedelta(0)), str)
         assert isinstance(base_json_conv(b""), str)
-        assert base_json_conv(bytes("", encoding="utf-16")) == "[bytes]"
+        assert isinstance(base_json_conv(b"\xff\xfe"), str)
+        assert base_json_conv(b"\xff") == "[bytes]"
 
         with pytest.raises(TypeError):
             base_json_conv(np.datetime64())

tests/unit_tests/utils/test_core.py

@@ -437,3 +437,13 @@ def test_pessimistic_json_iso_dttm_ser_nonutf8():
     json_str = json.dumps(data, default=pessimistic_json_iso_dttm_ser)
     reloaded_data = json.loads(json_str)
     assert reloaded_data["INVALID_UTF8_BYTES"] == "[bytes]"
+
+
+def test_pessimistic_json_iso_dttm_ser_utf16():
+    data = {
+        "VALID_UTF16_BYTES": b"\xff\xfeS0\x930k0a0o0\x16NLu",
+    }
+    assert isinstance(data["VALID_UTF16_BYTES"], bytes)
+    json_str = json.dumps(data, default=pessimistic_json_iso_dttm_ser)
+    reloaded_data = json.loads(json_str)
+    assert reloaded_data["VALID_UTF16_BYTES"] == "こんにちは世界"