chore(dependencies): upgrade vitest and coverage packages

- Updated `@vitest/coverage-v8` and `vitest` to version `4.1.7` in multiple package.json files.
- Refactored AI filter response schema in `aiRunFilterService.server.ts` to comply with OpenAI's JSON structure requirements.
- Removed unused pool options from vitest configuration files across several internal packages.

Author: danton267

apps/webapp/app/v3/services/aiRunFilterService.server.ts

@@ -14,17 +14,25 @@ const AIFilters = TaskRunListSearchFilters.omit({
   to: z.string().optional().describe("The ISO datetime to filter to"),
 });
 
+// The response is wrapped in an object with a single `response` field because
+// OpenAI structured outputs (both the Chat and Responses APIs) require the root
+// JSON Schema to be `type: "object"`. A bare `z.discriminatedUnion` compiles to
+// a root-level `anyOf`, which OpenAI rejects ("schema must be of type object").
+// Nesting the union under a property keeps the discriminated-union ergonomics
+// while satisfying the root-object constraint.
 const AIFilterResponseSchema = z
-  .discriminatedUnion("success", [
-    z.object({
-      success: z.literal(true),
-      filters: AIFilters,
-    }),
-    z.object({
-      success: z.literal(false),
-      error: z.string().describe("A short human-readable error message"),
-    }),
-  ])
+  .object({
+    response: z.discriminatedUnion("success", [
+      z.object({
+        success: z.literal(true),
+        filters: AIFilters,
+      }),
+      z.object({
+        success: z.literal(false),
+        error: z.string().describe("A short human-readable error message"),
+      }),
+    ]),
+  })
   .describe("The response from the AI filter service");
 
 export interface QueryQueues {
@@ -88,6 +96,16 @@ export class AIRunFilterService {
       const result = await generateText({
         model: this.model,
         experimental_output: Output.object({ schema: AIFilterResponseSchema }),
+        // Disable OpenAI strict JSON-schema mode. The filters schema has many
+        // optional fields, and strict mode requires every property to appear in
+        // `required` (it rejects bare optionals). Non-strict mode treats the
+        // schema as guidance; the `AIFilters.safeParse` below still validates
+        // the result, so correctness is preserved.
+        providerOptions: {
+          openai: {
+            strictJsonSchema: false,
+          },
+        },
         tools: {
           lookupTags: tool({
             description: "Look up available tags in the environment",
@@ -198,21 +216,24 @@ export class AIRunFilterService {
   
   The filters object should only contain the fields that are actually being filtered. Do not include fields with empty arrays or undefined values.
   
-  CRITICAL: The response must be a valid JSON object with exactly this structure:
+  CRITICAL: The response must be a valid JSON object with a single top-level "response" key wrapping this structure:
   {
-    "success": true,
-    "filters": {
-      // only include fields that have actual values
-    },
-    "explanation": "string explaining what filters were applied"
+    "response": {
+      "success": true,
+      "filters": {
+        // only include fields that have actual values
+      }
+    }
   }
-  
+
   or if you can't figure out the filters then return:
   {
-    "success": false,
-    "error": "<short human understandable suggestion>"
+    "response": {
+      "success": false,
+      "error": "<short human understandable suggestion>"
+    }
   }
-  
+
   Make the error no more than 8 words.
   `,
         prompt: text,
@@ -224,19 +245,21 @@ export class AIRunFilterService {
         },
       });
 
-      if (!result.experimental_output.success) {
+      const output = result.experimental_output.response;
+
+      if (!output.success) {
         return {
           success: false,
-          error: result.experimental_output.error,
+          error: output.error,
         };
       }
 
       // Validate the filters against the schema to catch any issues
-      const validationResult = AIFilters.safeParse(result.experimental_output.filters);
+      const validationResult = AIFilters.safeParse(output.filters);
       if (!validationResult.success) {
         logger.error("AI filter validation failed", {
           errors: validationResult.error.errors,
-          filters: result.experimental_output.filters,
+          filters: output.filters,
         });
 
         return {

internal-packages/clickhouse/vitest.config.ts

@@ -6,11 +6,6 @@ export default defineConfig({
     globals: true,
     isolate: true,
     fileParallelism: false,
-    poolOptions: {
-      threads: {
-        singleThread: true,
-      },
-    },
     testTimeout: 60_000,
     coverage: {
       provider: "v8",

internal-packages/llm-model-catalog/package.json

@@ -11,7 +11,7 @@
   },
   "devDependencies": {
     "@internal/testcontainers": "workspace:*",
-    "vitest": "3.1.4"
+    "vitest": "4.1.7"
   },
   "scripts": {
     "test": "vitest --sequence.concurrent=false --no-file-parallelism",

internal-packages/llm-model-catalog/vitest.config.ts

@@ -6,11 +6,6 @@ export default defineConfig({
     globals: true,
     isolate: true,
     fileParallelism: false,
-    poolOptions: {
-      threads: {
-        singleThread: true,
-      },
-    },
     testTimeout: 120_000,
   },
 });

internal-packages/replication/vitest.config.ts

@@ -6,11 +6,6 @@ export default defineConfig({
     globals: true,
     isolate: true,
     fileParallelism: false,
-    poolOptions: {
-      threads: {
-        singleThread: true,
-      },
-    },
     testTimeout: 60_000,
     coverage: {
       provider: "v8",

internal-packages/run-engine/src/engine/tests/utils/engineTest.ts

@@ -1,4 +1,4 @@
-import { TaskContext, test, TestAPI } from "vitest";
+import { TestContext, test, TestAPI } from "vitest";
 import {
   logCleanup,
   network,
@@ -36,7 +36,7 @@ type EngineOptions = {
   };
 };
 
-const engineOptions = async ({}: TaskContext, use: Use<EngineOptions>) => {
+const engineOptions = async ({}: TestContext, use: Use<EngineOptions>) => {
   const options: EngineOptions = {
     worker: {
       workers: 1,
@@ -74,7 +74,7 @@ const engine = async (
     engineOptions: EngineOptions;
     redisOptions: RedisOptions;
     prisma: PrismaClient;
-  } & TaskContext,
+  } & TestContext,
   use: Use<RunEngine>
 ) => {
   const engine = new RunEngine({

internal-packages/run-engine/vitest.config.ts

@@ -6,11 +6,6 @@ export default defineConfig({
     globals: true,
     isolate: true,
     fileParallelism: false,
-    poolOptions: {
-      threads: {
-        singleThread: true,
-      },
-    },
     testTimeout: 120_000,
     coverage: {
       provider: "v8",

internal-packages/sdk-compat-tests/package.json

@@ -15,6 +15,6 @@
     "esbuild": "^0.24.0",
     "execa": "^9.3.0",
     "typescript": "^5.5.0",
-    "vitest": "3.1.4"
+    "vitest": "4.1.7"
   }
 }

internal-packages/testcontainers/src/index.ts

@@ -3,7 +3,7 @@ import { StartedRedisContainer } from "@testcontainers/redis";
 import { PrismaClient } from "@trigger.dev/database";
 import { RedisOptions } from "ioredis";
 import { Network, type StartedNetwork } from "testcontainers";
-import { TaskContext, test } from "vitest";
+import { TestContext, test } from "vitest";
 import {
   createClickHouseContainer,
   createElectricContainer,
@@ -58,7 +58,7 @@ export type {
 
 type Use<T> = (value: T) => Promise<void>;
 
-export const network = async ({ task }: TaskContext, use: Use<StartedNetwork>) => {
+export const network = async ({ task }: TestContext, use: Use<StartedNetwork>) => {
   const testName = task.name;
 
   logSetup("network: starting", { testName });
@@ -85,7 +85,7 @@ export const network = async ({ task }: TaskContext, use: Use<StartedNetwork>) =
 };
 
 export const postgresContainer = async (
-  { network, task }: { network: StartedNetwork } & TaskContext,
+  { network, task }: { network: StartedNetwork } & TestContext,
   use: Use<StartedPostgreSqlContainer>
 ) => {
   const { container, metadata } = await withContainerSetup({
@@ -98,7 +98,7 @@ export const postgresContainer = async (
 };
 
 export const prisma = async (
-  { postgresContainer, task }: { postgresContainer: StartedPostgreSqlContainer } & TaskContext,
+  { postgresContainer, task }: { postgresContainer: StartedPostgreSqlContainer } & TestContext,
   use: Use<PrismaClient>
 ) => {
   const testName = task.name;
@@ -123,7 +123,7 @@ export const prisma = async (
 export const postgresTest = test.extend<PostgresContext>({ network, postgresContainer, prisma });
 
 export const redisContainer = async (
-  { network, task }: { network: StartedNetwork } & TaskContext,
+  { network, task }: { network: StartedNetwork } & TestContext,
   use: Use<StartedRedisContainer>
 ) => {
   const { container, metadata } = await withContainerSetup({
@@ -180,7 +180,7 @@ const electricOrigin = async (
     postgresContainer,
     network,
     task,
-  }: { postgresContainer: StartedPostgreSqlContainer; network: StartedNetwork } & TaskContext,
+  }: { postgresContainer: StartedPostgreSqlContainer; network: StartedNetwork } & TestContext,
   use: Use<string>
 ) => {
   const { origin, container, metadata } = await withContainerSetup({
@@ -193,7 +193,7 @@ const electricOrigin = async (
 };
 
 const clickhouseContainer = async (
-  { network, task }: { network: StartedNetwork } & TaskContext,
+  { network, task }: { network: StartedNetwork } & TestContext,
   use: Use<StartedClickHouseContainer>
 ) => {
   const { container, metadata } = await withContainerSetup({
@@ -206,7 +206,7 @@ const clickhouseContainer = async (
 };
 
 const clickhouseClient = async (
-  { clickhouseContainer, task }: { clickhouseContainer: StartedClickHouseContainer } & TaskContext,
+  { clickhouseContainer, task }: { clickhouseContainer: StartedClickHouseContainer } & TestContext,
   use: Use<ClickHouseClient>
 ) => {
   const testName = task.name;
@@ -268,7 +268,7 @@ export const containerWithElectricAndRedisTest = test.extend<ContainerWithElectr
 });
 
 const minioContainer = async (
-  { network, task }: { network: StartedNetwork } & TaskContext,
+  { network, task }: { network: StartedNetwork } & TestContext,
   use: Use<StartedMinIOContainer>
 ) => {
   const { container, metadata } = await withContainerSetup({

internal-packages/testcontainers/src/logs.ts

@@ -1,5 +1,5 @@
 import { env, isCI } from "std-env";
-import { TaskContext } from "vitest";
+import { TestContext } from "vitest";
 import { DockerDiagnostics, getDockerDiagnostics } from "./docker";
 import { StartedTestContainer } from "testcontainers";
 
@@ -31,7 +31,7 @@ export function getContainerMetadata(container: StartedTestContainer) {
   };
 }
 
-export function getTaskMetadata(task: TaskContext["task"]) {
+export function getTaskMetadata(task: TestContext["task"]) {
   return {
     testName: task.name,
   };