fix: include the last stream execute result in streamingBatch

golemfactory · Jun 27, 2024 · c3c4964 · c3c4964
1 parent 81b1921
commit c3c4964
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/activity/exe-script-executor.ts b/src/activity/exe-script-executor.ts
@@ -218,7 +218,7 @@ export class ExeScriptExecutor {
   private streamingBatch(batchId: string, batchSize: number): Observable<Result> {
     return this.activityModule.observeStreamingBatchEvents(this.activity, batchId).pipe(
       map((resultEvents) => this.parseEventToResult(resultEvents, batchSize)),
-      takeWhile((result) => !result.isBatchFinished),
+      takeWhile((result) => !result.isBatchFinished, true),
       // transform to domain error
       catchError((error) => {
         throw new GolemWorkError(