diff --git a/orchestrator/src/server/api/routes/pipeline.test.ts b/orchestrator/src/server/api/routes/pipeline.test.ts
index 0d7dc34..68c80f3 100644
--- a/orchestrator/src/server/api/routes/pipeline.test.ts
+++ b/orchestrator/src/server/api/routes/pipeline.test.ts
@@ -54,11 +54,14 @@ describe.sequential('Pipeline API routes', () => {
 
     const reader = res.body?.getReader();
     if (reader) {
-      const chunk = await reader.read();
-      controller.abort();
-      await reader.cancel();
-      const text = new TextDecoder().decode(chunk.value);
-      expect(text).toContain('data:');
+      try {
+        const { value } = await reader.read();
+        const text = new TextDecoder().decode(value);
+        expect(text).toContain('data:');
+      } finally {
+        await reader.cancel();
+        controller.abort();
+      }
     } else {
       controller.abort();
     }