diff --git a/inference/core/interfaces/http/http_api.py b/inference/core/interfaces/http/http_api.py index 4751a6f435..0872180608 100644 --- a/inference/core/interfaces/http/http_api.py +++ b/inference/core/interfaces/http/http_api.py @@ -313,12 +313,12 @@ async def wrapped_route(*args, **kwargs): traceback.print_exc() except WorkflowSyntaxError as error: content = WorkflowErrorResponse( - message=error.public_message, + message=str(error.public_message), error_type=error.__class__.__name__, - context=error.context, - inner_error_type=error.inner_error_type, + context=str(error.context), + inner_error_type=str(error.inner_error_type), inner_error_message=str(error.inner_error), - blocks_errors=error._blocks_errors, + blocks_errors=error.blocks_errors, ) resp = JSONResponse(status_code=400, content=content.model_dump()) except ( @@ -448,15 +448,15 @@ async def wrapped_route(*args, **kwargs): traceback.print_exc() except StepExecutionError as error: content = WorkflowErrorResponse( - message=error.public_message, + message=str(error.public_message), error_type=error.__class__.__name__, - context=error.context, - inner_error_type=error.inner_error_type, + context=str(error.context), + inner_error_type=str(error.inner_error_type), inner_error_message=str(error.inner_error), blocks_errors=[ WorkflowBlockError( - block_id=error._block_id, - block_type=error._block_type, + block_id=error.block_id, + block_type=error.block_type, ), ], ) diff --git a/inference/core/version.py b/inference/core/version.py index 2846024df0..8dbd93a003 100644 --- a/inference/core/version.py +++ b/inference/core/version.py @@ -1,4 +1,4 @@ -__version__ = "0.37.0" +__version__ = "0.37.1" if __name__ == "__main__": diff --git a/inference/core/workflows/core_steps/loader.py b/inference/core/workflows/core_steps/loader.py index a6b59317b0..3ade98a7a7 100644 --- a/inference/core/workflows/core_steps/loader.py +++ b/inference/core/workflows/core_steps/loader.py @@ -2,6 +2,7 @@ from inference.core.cache import cache from inference.core.env import ( + ALLOW_WORKFLOW_BLOCKS_ACCESSING_ENVIRONMENTAL_VARIABLES, ALLOW_WORKFLOW_BLOCKS_ACCESSING_LOCAL_STORAGE, API_KEY, WORKFLOW_BLOCKS_WRITE_DIRECTORY, @@ -441,7 +442,7 @@ "thread_pool_executor": None, "allow_access_to_file_system": ALLOW_WORKFLOW_BLOCKS_ACCESSING_LOCAL_STORAGE, "allowed_write_directory": WORKFLOW_BLOCKS_WRITE_DIRECTORY, - "allow_access_to_environmental_variables": ALLOW_WORKFLOW_BLOCKS_ACCESSING_LOCAL_STORAGE, + "allow_access_to_environmental_variables": ALLOW_WORKFLOW_BLOCKS_ACCESSING_ENVIRONMENTAL_VARIABLES, } KINDS_SERIALIZERS = { diff --git a/inference/core/workflows/errors.py b/inference/core/workflows/errors.py index 568c2c3ee0..5c23c6eaf2 100644 --- a/inference/core/workflows/errors.py +++ b/inference/core/workflows/errors.py @@ -76,12 +76,12 @@ class WorkflowDefinitionError(WorkflowCompilerError): class WorkflowSyntaxError(WorkflowDefinitionError): def __init__( self, - *args, blocks_errors: Optional[List[WorkflowBlockError]] = None, + *args, **kwargs, ): super().__init__(*args, **kwargs) - self._blocks_errors = blocks_errors + self.blocks_errors = blocks_errors class DuplicatedNameError(WorkflowDefinitionError): @@ -139,14 +139,14 @@ class InvalidBlockBehaviourError(WorkflowExecutionEngineError): class StepExecutionError(WorkflowExecutionEngineError): def __init__( self, - *args, block_id: str, block_type: str, + *args, **kwargs, ): super().__init__(*args, **kwargs) - self._block_id = block_id - self._block_type = block_type + self.block_id = block_id + self.block_type = block_type class ExecutionEngineRuntimeError(WorkflowExecutionEngineError): diff --git a/inference/core/workflows/execution_engine/v1/executor/core.py b/inference/core/workflows/execution_engine/v1/executor/core.py index 9f4cdef7d2..f39cbd1e34 100644 --- a/inference/core/workflows/execution_engine/v1/executor/core.py +++ b/inference/core/workflows/execution_engine/v1/executor/core.py @@ -139,7 +139,7 @@ def safe_execute_step( block_type=workflow.steps[step_selector.split(".")[-1]].manifest.type, public_message=str(error), context="workflow_execution | step_execution", - inner_error=error, + inner_error=str(error), ) from error