Add message to assert, and add it to the ProcessGraphInvalidException. …

…https://github.com/Open-EO/openeo-geopyspark-driver/issues/800

openeo_driver/ProcessGraphDeserializer.py

@@ -1871,12 +1871,13 @@ def evaluate_process_from_url(process_id: str, namespace: str, args: dict, env:
 
     try:
         spec = res.json()
-        assert spec["id"].lower() == process_id.lower()
+        msg = f"{process_id=} does not match result from namespace query: '" + spec["id"] + "'"
+        assert spec["id"].lower() == process_id.lower(), msg
         process_graph = spec["process_graph"]
         parameters = spec.get("parameters", [])
     except Exception as e:
         _log.error(f"Failed to load process {process_id!r} from {candidate!r}", exc_info=True)
-        raise ProcessGraphInvalidException() from e
+        raise ProcessGraphInvalidException(str(e)) from e
 
     return _evaluate_process_graph_process(
         process_id=process_id, process_graph=process_graph, parameters=parameters, args=args, env=env

openeo_driver/errors.py

@@ -371,6 +371,12 @@ class ProcessGraphInvalidException(OpenEOApiException):
     _description = "The process doesn't contain a valid process graph, which means it doesn't comply to the general structure / schema."
     _tags = ['Batch Jobs', 'Data Processing', 'Secondary Services', 'User-Defined Processes']
 
+    def __init__(self, message: str = ""):
+        if message == "":
+            super().__init__(message=self.message)
+        else:
+            super().__init__(message=self.message + " " + message)
+
 
 class NoDataForUpdateException(OpenEOApiException):
     status_code = 400