diff --git a/apps/server/src/provider/Layers/GrokAdapter.test.ts b/apps/server/src/provider/Layers/GrokAdapter.test.ts
index 3eb6d627767..5dd4b75e0cc 100644
--- a/apps/server/src/provider/Layers/GrokAdapter.test.ts
+++ b/apps/server/src/provider/Layers/GrokAdapter.test.ts
@@ -486,14 +486,15 @@ it.layer(grokAdapterTestLayer)("GrokAdapterLive", (it) => {
     });
 
     const runBoundedAttempt = Effect.gen(function* () {
-      // Run detached so timing out the join does not wait for a wedged provider
+      // Run detached so timing out the observation does not wait for a wedged provider
       // fiber's cooperative interruption or finalizers.
       const attempt = yield* runAttempt.pipe(Effect.forkDetach);
-      return yield* Fiber.join(attempt).pipe(
+      const exit = yield* Fiber.await(attempt).pipe(
         Effect.timeout("5 seconds"),
         // Request cleanup without turning the timeout back into an unbounded wait.
         Effect.ensuring(Fiber.interrupt(attempt).pipe(Effect.forkDetach, Effect.asVoid)),
       );
+      return yield* exit;
     });
 
     return runBoundedAttempt.pipe(
@@ -940,10 +941,11 @@ it.layer(grokAdapterTestLayer)("GrokAdapterLive", (it) => {
 
     const runBoundedAttempt = Effect.gen(function* () {
       const attempt = yield* runAttempt.pipe(Effect.forkDetach);
-      return yield* Fiber.join(attempt).pipe(
+      const exit = yield* Fiber.await(attempt).pipe(
         Effect.timeout("5 seconds"),
         Effect.ensuring(Fiber.interrupt(attempt).pipe(Effect.forkDetach, Effect.asVoid)),
       );
+      return yield* exit;
     });
 
     return runBoundedAttempt.pipe(