We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent de58c89 commit c8e84c2Copy full SHA for c8e84c2
1 file changed
ocean_runner/runner.py
@@ -18,7 +18,6 @@
18
override,
19
)
20
21
-import aiofiles
22
from oceanprotocol_job_details import (
23
EmptyJobDetails,
24
ParametrizedJobDetails,
@@ -68,8 +67,11 @@ async def default_save(
68
67
result: ResultT,
69
base: Path,
70
) -> None:
+ from aiofiles import open
71
+
72
algorithm.logger.info("Saving results using default save")
- async with aiofiles.open(base / "result.txt", "w+") as f:
73
74
+ async with open(base / "result.txt", "w+") as f:
75
await f.write(str(result))
76
77
@@ -218,6 +220,8 @@ async def execute(self) -> ResultT | None:
218
220
self,
219
221
222
223
+ self.job_details.paths.outputs.mkdir(exist_ok=True)
224
225
await run_in_executor(
226
self._functions.save,
227
0 commit comments