Handle cancelled persisted results as terminal failures.

Treat cancelled result states as immediate runtime errors and add coverage so result polling no longer times out on terminal cancellation.

Author: eddietejeda

hotdata_runtime/client.py

@@ -25,6 +25,7 @@
 from hotdata_runtime.result import QueryResult
 
 _TERMINAL = frozenset({"succeeded", "failed", "cancelled"})
+_RESULT_FAILURE = frozenset({"failed", "cancelled"})
 
 
 class HotdataClient:
@@ -206,9 +207,9 @@ def _wait_result_ready(
             last = results.get_result(result_id)
             if last.status == "ready":
                 return last
-            if last.status == "failed":
+            if last.status in _RESULT_FAILURE:
                 raise RuntimeError(
-                    last.error_message or "Result persistence failed"
+                    last.error_message or f"Result {last.status}"
                 )
             time.sleep(interval_s)
         raise TimeoutError(

tests/test_client.py

@@ -109,3 +109,15 @@ def test_list_qualified_table_names_passes_connection_id():
         client.list_qualified_table_names(limit=5, connection_id="conn_a")
     it.assert_called_once()
     assert it.call_args.kwargs["connection_id"] == "conn_a"
+
+
+def test_wait_result_ready_raises_on_cancelled():
+    client = HotdataClient("k", "ws", host="https://api.hotdata.dev")
+
+    class FakeResultsApi:
+        def get_result(self, result_id: str):
+            return SimpleNamespace(status="cancelled", error_message=None)
+
+    with patch.object(client, "_results_api", return_value=FakeResultsApi()):
+        with pytest.raises(RuntimeError, match="cancelled"):
+            client._wait_result_ready("res_1", timeout_s=0.1, interval_s=0)