diff --git a/sdk/src/lib/handlers/ResultHandler.spec.ts b/sdk/src/lib/handlers/ResultHandler.spec.ts index e840be3..7b2a0f0 100644 --- a/sdk/src/lib/handlers/ResultHandler.spec.ts +++ b/sdk/src/lib/handlers/ResultHandler.spec.ts @@ -44,12 +44,18 @@ describe('ResultsHandler', () => { it('should error when not succeeded', (done) => { handler.getResult().subscribe({ - next: () => { - done.fail('Should not have succeeded'); + next: (result) => { + expect(result).toEqual({ + uuid: 'uuid', + logs: 'logs', + outputEsdl: '', + resultType: JobResult.ResultType.ERROR, + esdlMessagesList: [], + }); + done() }, - error: (error) => { - expect(error.message).toEqual('Job uuid failed: logs'); - done(); + error: () => { + done.fail('should not have thrown error') }, complete: () => { done.fail('Should not have completed'); diff --git a/sdk/src/lib/handlers/ResultHandler.ts b/sdk/src/lib/handlers/ResultHandler.ts index c1d358e..095e553 100644 --- a/sdk/src/lib/handlers/ResultHandler.ts +++ b/sdk/src/lib/handlers/ResultHandler.ts @@ -11,9 +11,6 @@ export class ResultHandler extends JobHandler { return messages$.pipe( map((message) => { const result = JobResult.deserializeBinary(message.content); - if (result.getResultType() === JobResult.ResultType.ERROR) { - throw new Error(`Job ${result.getUuid()} failed: ${result.getLogs()}`); - } return result.toObject(); }) );