raise error for invalid data

Signed-off-by: varun-edachali-dbx <varun.edachali@databricks.com>

Author: varun-edachali-dbx

src/databricks/sql/backend/utils/http_client.py

@@ -145,7 +145,7 @@ def _make_request(
             if response.content:
                 result = response.json()
                 # Log response content (but limit it for large responses)
-                content_str = json.dumps(result)
+                content_str = json.dumps(result, indent=2, sort_keys=True)
                 if len(content_str) > 1000:
                     logger.debug(
                         f"Response content (truncated): {content_str[:1000]}..."

src/databricks/sql/utils.py

@@ -143,7 +143,7 @@ def build_queue(
             raise NotImplementedError("EXTERNAL_LINKS disposition is not supported yet")
         else:
             # Empty result set
-            return JsonQueue([])
+            raise AssertionError("Result data is not valid")
 
 
 class JsonQueue(ResultSetQueue):

tests/unit/test_result_set_queue_factories.py

@@ -52,13 +52,8 @@ def test_sea_result_set_queue_factory_with_empty_data(self):
         result_data.data = []
         result_data.external_links = None
 
-        # Build queue
-        queue = SeaResultSetQueueFactory.build_queue(result_data)
-
-        # Verify queue type
-        self.assertIsInstance(queue, JsonQueue)
-        self.assertEqual(queue.n_valid_rows, 0)
-        self.assertEqual(queue.data_array, [])
+        with self.assertRaises(AssertionError):
+            SeaResultSetQueueFactory.build_queue(result_data)
 
     def test_sea_result_set_queue_factory_with_external_links(self):
         """Test SeaResultSetQueueFactory with external links."""
@@ -78,13 +73,8 @@ def test_sea_result_set_queue_factory_with_no_data(self):
         result_data.data = None
         result_data.external_links = None
 
-        # Build queue
-        queue = SeaResultSetQueueFactory.build_queue(result_data)
-
-        # Verify queue type
-        self.assertIsInstance(queue, JsonQueue)
-        self.assertEqual(queue.n_valid_rows, 0)
-        self.assertEqual(queue.data_array, [])
+        with self.assertRaises(AssertionError):
+            SeaResultSetQueueFactory.build_queue(result_data)
 
 
 if __name__ == "__main__":