Function awaitStaleSyncWithinGrace

packages/core/sdk/src/executor.ts:5073–5091

(graceMs: number)

    // swallows its scan errors the same way each rebuild already swallows its
    // own.
    const awaitStaleSyncWithinGrace = (graceMs: number) =>
      Effect.gen(function* () {
        const fiber = yield* Effect.forkDetach(
          syncStaleConnectionTools.pipe(
            Effect.catch((error) =>
              Effect.logWarning("executor stale tool sync scan failed", {
                error: describeSyncFailure(error),
              }),
            ),
          ),
        );
        // On hosts that cancel request-scoped I/O once the response settles
        // (Cloudflare Workers), hand the host the rebuilds' completion so the
        // catalog still converges after the read stops waiting.
        config.waitUntil?.(
          new Promise<void>((resolve) => fiber.addObserver(() => resolve(undefined))),
        );
        yield* Fiber.await(fiber).pipe(Effect.timeoutOption(graceMs), Effect.asVoid);
      });

    const toolsList = (filter?: ToolListFilter): Effect.Effect<readonly Tool[], StorageFailure> =>
      Effect.gen(function* () {