diff --git a/src/engine/src/core/tasks/TaskInputFileStagingService.py b/src/engine/src/core/tasks/TaskInputFileStagingService.py index ca48ee38..c7200c03 100644 --- a/src/engine/src/core/tasks/TaskInputFileStagingService.py +++ b/src/engine/src/core/tasks/TaskInputFileStagingService.py @@ -37,22 +37,22 @@ def stage(self, task: Task): task_id=value_from[key].task_id, _id=value_from[key].output_id ) - except Exception: - raise TaskInputStagingError(f"No output found for task '{value_from[key].task_id}' with output id of '{value_from[key].output_id}'") + except Exception as e: + raise TaskInputStagingError(f"No output found for task '{value_from[key].task_id}' with output id of '{value_from[key].output_id}' | {e}") if key == "args": try: value = self._value_from_service.get_arg_value_by_key( value_from[key] ) - except Exception: - raise TaskInputStagingError(f"Error attempting to fetch value from args at key '{key}'") + except Exception as e: + raise TaskInputStagingError(f"Error attempting to fetch value from args at key '{value_from[key]}' | {e}") if key == "env": try: value = self._value_from_service.get_env_value_by_key( value_from[key] ) - except Exception: - raise TaskInputStagingError(f"Error attempting to fetch value from env at key '{key}'") + except Exception as e: + raise TaskInputStagingError(f"Error attempting to fetch value from env at key '{value_from[key]}' | {e}") self._create_input_(task, input_id, value)