Merge branch 'main' of https://github.com/AgrospAI/ocean-runner

Author: spin3l

_data/outputs/result.txt

@@ -1 +1 @@
-0.05
+0.005

ocean_runner/__init__.py

@@ -1,4 +1,4 @@
 from ocean_runner.config import Config, Environment
 from ocean_runner.runner import Algorithm
 
-__all__ = [Config, Algorithm, Environment]  # type: ignore
+__all__ = ["Config", "Algorithm", "Environment"]

ocean_runner/runner.py

@@ -29,7 +29,7 @@ def default_error_callback(
     error: Exception,
 ) -> None:
     algorithm.logger.exception("Error during algorithm execution")
-    raise error
+    raise Algorithm.Error() from error
 
 
 def default_validation(algorithm: Algorithm[InputT, ResultT]) -> None:
@@ -184,7 +184,7 @@ async def execute(self) -> ResultT | None:
                 self.job_details.paths.outputs,
             )
 
-        except Exception as e:
+        except Algorithm.Error as e:
             await run_in_executor(self._functions.error, self, e)
 
         return self._result

tests/test_runner.py

@@ -100,7 +100,7 @@ def run(algorithm: Algorithm):
 
     @setup_algorithm.on_error
     def callback(algorithm: Algorithm, error: Exception):
-        raise error
+        raise Algorithm.Error() from error
 
     with raises(Algorithm.Error):
         setup_algorithm()