Skip to content

Commit 5d26c21

Browse files
committed
test(run-engine): close the emitter when the readiness wait times out
1 parent 306ea8a commit 5d26c21

1 file changed

Lines changed: 1 addition & 0 deletions

File tree

‎internal-packages/run-engine/src/run-queue/metrics.test.ts‎

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -34,6 +34,7 @@ async function emitterReady(emitter: MetricsStreamEmitter) {
3434
const winner = await Promise.race([emitter.waitUntilReady().then(() => "ready"), timedOut]);
3535
abort.abort();
3636
if (winner === "timeout") {
37+
await emitter.close().catch(() => {});
3738
throw new Error("metrics emitter Redis connection never became ready");
3839
}
3940
}

0 commit comments

Comments
 (0)