fix #1032 Exclusive Access: show validation error (#1035)

* Removing uneeded interface

* WIP:exlcusive access class

* WIP: saving results

* exclusive access v1

* remove prints for debug

* fix: status return code

* status code "Submitted" -> Enqueued

* refactor: enable saving and serialization  and ExclusiveRemoteTask

* refactor: comment out debug print statement in ExclusiveRemoteTask

* refactor: streamline task status query logic and remove unused geometry field

* use dataclass for ExclusiveCustomRemoteTask

* refactor: use black to clean up whitespace and improve code formatting in HTTPHandler and ExclusiveRemoteTask

* clean up duplicated imports

* fix: add missing newline for improved code readability

* merge

* add validation error message

* black reformat

---------

Co-authored-by: Phillip Weinberg <weinbe58@gmail.com>

Author: yzcj105

src/bloqade/analog/task/exclusive.py

@@ -102,7 +102,7 @@ def submit_task_via_zapier(
         else:
             print(f"HTTP request failed with status code: {response.status_code}")
             print("HTTP responce: ", response.text)
-            return "Failed"
+            return "HTTP Request Failed"
 
     def query_task_status(self, task_id: str):
         response = request(
@@ -115,21 +115,39 @@ def query_task_status(self, task_id: str):
             },
         )
         if response.status_code != 200:
-            return "Not Found"
+            return "HTTP Request Failed."
         response_data = response.json()
         # Get "matched" from the response
         matches = response_data.get("matches", None)
         # The return is a list of dictionaries
         # Verify if the list contains only one element
         if matches is None:
             print("No task found with the given ID.")
-            return "Failed"
+            return "Task searching Failed"
         elif len(matches) > 1:
             print("Multiple tasks found with the given ID.")
-            return "Failed"
+            return "Task searching Failed"
+
+        record = matches[0]
 
         # Extract the status from the first dictionary
-        status = matches[0].get("status")
+        status = record.get("status")
+
+        if status == "Failed validation":
+            googledoc = record.get("resultsFileUrl")
+
+            # convert the preview URL to download URL
+            googledoc = convert_preview_to_download(googledoc)
+            res = get(googledoc)
+            res.raise_for_status()
+            data = res.json()
+            # get the "statusCode" and "message" from the data and print them out.
+            status_code = data.get("statusCode", "NA")
+            message = data.get("message", "NA")
+            print(
+                f"Task validation failed with status code: {status_code}, message: {message}"
+            )
+
         return status
 
     def fetch_results(self, task_id: str):
@@ -283,7 +301,10 @@ def status(self) -> QuEraTaskStatusCode:
             return QuEraTaskStatusCode.Unsubmitted
         res = self._http_handler.query_task_status(self._task_id)
         if res == "Failed":
-            raise ValueError("Query task status failed.")
+            return QuEraTaskStatusCode.Failed
+        elif res == "Failed validation":
+
+            return QuEraTaskStatusCode.Failed
         elif res == "Submitted":
             return QuEraTaskStatusCode.Enqueued
         # TODO: please add all possible status