fix(job): fixed rental finalization after job completed

golemfactory · Jul 9, 2024 · 22856f1 · 22856f1
1 parent f8ac831
commit 22856f1
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 1 deletion.
diff --git a/src/experimental/job/job.ts b/src/experimental/job/job.ts
@@ -151,7 +151,7 @@ export class Job<Output = unknown> {
 
     signal.addEventListener("abort", onAbort, { once: true });
 
-    return workOnGolem(exeUnit);
+    return workOnGolem(exeUnit).finally(() => rental.stopAndFinalize());
   }
 
   /**

diff --git a/src/experimental/job/job_manager.ts b/src/experimental/job/job_manager.ts
@@ -41,6 +41,7 @@ export class JobManager {
         url: this.config?.yagna?.basePath,
       },
       dataTransferProtocol: storageProvider,
+      logger: this.logger,
     });
   }
-Original file line number
+Diff line change
@@ Expand Up / @@ -151,7 +151,7 @@ export class Job<Output = unknown> { @@
         signal.addEventListener("abort", onAbort, { once: true });
-        return workOnGolem(exeUnit);
+        return workOnGolem(exeUnit).finally(() => rental.stopAndFinalize());
       }
       /**
@@ Expand Down @@