chore: updated oceanprotocol-job-details version

Author: spin3l

.DS_Store

@@ -19,21 +19,21 @@ repos:
 
       - id: ruff
         name: ruff
-        entry: ruff check --fix
+        entry: uv run ruff check --fix
         language: system
         types: [python]
         require_serial: true
 
       - id: ruff-format
         name: ruff-format
-        entry: ruff format
+        entry: uv run ruff format
         language: system
         types: [python]
         require_serial: true
 
-      - id: mypy
-        name: mypy
-        entry: mypy
+      - id: ty
+        name: ty
+        entry: uv run ty check
         language: system
         types: [python]
         exclude: ^tests/|test_.*\.py$

.pre-commit-config.yaml

@@ -18,19 +18,19 @@
 )
 
 from oceanprotocol_job_details import (
+    EmptyInputParameters,
     EmptyJobDetails,
     ParametrizedJobDetails,
     load_job_details,
     run_in_executor,
 )
 from oceanprotocol_job_details.ocean import _BaseJobDetails
 from pydantic import BaseModel, JsonValue
-from returns.result import Failure, Success
 from typing_extensions import override
 
 from ocean_runner.config import Config
 
-InputT = TypeVar("InputT", bound=BaseModel | None)
+InputT = TypeVar("InputT", bound=BaseModel)
 ResultT = TypeVar("ResultT")
 T = TypeVar("T")
 
@@ -251,19 +251,18 @@ class ParametrizedAlgorithm(Algorithm[InputT, ResultT]):
     @override
     @cached_property
     def job_details(self) -> ParametrizedJobDetails[InputT]:
-        match self._job_details.read():
-            case Success(parametrized_job_details):
-                return parametrized_job_details
-            case Failure(error):
-                raise error
-            case _:  # pragma: no cover
-                raise RuntimeError("Unreachable code")
+        result = self._job_details.read()
 
+        if isinstance(result, Exception):
+            raise result
 
-class EmptyAlgorithm(Algorithm[None, ResultT]):
+        return result
+
+
+class EmptyAlgorithm(Algorithm[EmptyInputParameters, ResultT]):
     """For algorithms with no custom parameters"""
 
     @override
     @cached_property
-    def job_details(self) -> EmptyJobDetails[None]:
-        return cast(EmptyJobDetails[None], self._job_details)
+    def job_details(self) -> EmptyJobDetails[EmptyInputParameters]:
+        return cast(EmptyJobDetails[EmptyInputParameters], self._job_details)

ocean_runner/runner.py

@@ -16,10 +16,9 @@ classifiers = [
 ]
 dependencies = [
     "aiofiles>=25.1.0",
-    "oceanprotocol-job-details>=0.4.4",
+    "oceanprotocol-job-details>=0.4.5",
     "pydantic>=2.12.5",
     "pydantic-settings>=2.12.0",
-    "returns[compatible-mypy]>=0.26.0",
 ]
 
 [project.urls]
@@ -42,12 +41,12 @@ build-backend = "hatchling.build"
 [dependency-groups]
 dev = [
     "coverage-badge>=1.1.2",
-    "mypy<1.18.0",
     "pre-commit>=4.5.1",
     "pytest>=9.0.2",
     "pytest-cov>=7.0.0",
     "pytest-mock>=3.15.1",
     "ruff>=0.14.14",
+    "ty>=0.0.29",
     "types-aiofiles>=25.1.0.20251011",
 ]
 

pyproject.toml

@@ -1,8 +1,7 @@
-from returns.result import Failure
-from unittest.mock import patch
 import logging
 from functools import partial
 from pathlib import Path
+from unittest.mock import patch
 
 import aiofiles
 from pydantic import BaseModel
@@ -84,10 +83,7 @@ class MockError(Exception): ...
     algorithm = Algorithm[CustomInput, int].create(config)
     algorithm.load()
 
-    with patch(
-        "oceanprotocol_job_details.JobDetails.read",
-        return_value=Failure(MockError()),
-    ):
+    with patch("oceanprotocol_job_details.JobDetails.read", return_value=MockError()):
         with raises(MockError):
             algorithm.job_details