Merge pull request #998 from roboflow/fix/handle-WorkflowSyntaxError-…

…separately-from-WorkflowDefinitionError Handle WorkflowSyntaxError separately from WorkflowDefinitionError
roboflow · Feb 5, 2025 · 53c7572 · 53c7572
2 parents 7e36cae + 1e8cc15
commit 53c7572
Showing 1 changed file with 17 additions and 9 deletions.
diff --git a/inference/core/interfaces/http/http_api.py b/inference/core/interfaces/http/http_api.py
@@ -217,6 +217,7 @@
     WorkflowDefinitionError,
     WorkflowError,
     WorkflowExecutionEngineVersionError,
+    WorkflowSyntaxError,
 )
 from inference.core.workflows.execution_engine.core import (
     ExecutionEngine,
@@ -310,6 +311,15 @@ async def wrapped_route(*args, **kwargs):
                 },
             )
             traceback.print_exc()
+        except WorkflowSyntaxError as error:
+            content = WorkflowErrorResponse(
+                message=error.public_message,
+                error_type=error.__class__.__name__,
+                context=error.context,
+                inner_error_type=error.inner_error_type,
+                inner_error_message=str(error.inner_error),
+            )
+            resp = JSONResponse(status_code=400, content=content)
         except (
             WorkflowDefinitionError,
             ExecutionGraphStructureError,
@@ -322,17 +332,15 @@ async def wrapped_route(*args, **kwargs):
             WorkflowExecutionEngineVersionError,
             NotSupportedExecutionEngineError,
         ) as error:
-            content = WorkflowErrorResponse(
-                message=error.public_message,
-                error_type=error.__class__.__name__,
-                context=error.context,
-                inner_error_type=error.inner_error_type,
-                inner_error_message=str(error.inner_error),
-                blocks_errors=error._blocks_errors,
-            )
             resp = JSONResponse(
                 status_code=400,
-                content=content.model_dump(),
+                content={
+                    "message": error.public_message,
+                    "error_type": error.__class__.__name__,
+                    "context": error.context,
+                    "inner_error_type": error.inner_error_type,
+                    "inner_error_message": str(error.inner_error),
+                },
             )
         except (
             ProcessesManagerInvalidPayload,