@@ -16,11 +16,8 @@ vi.mock("~/services/platform.v3.server", async (importOriginal) => {
1616
1717import { RunEngine } from "@internal/run-engine" ;
1818import { setupAuthenticatedEnvironment } from "@internal/run-engine/tests" ;
19- // Per-test redis (isolated): each test spins up its own RunEngine and runs batch work, which leaves
20- // background activity on redis that outlives the test - sharing a worker redis across the 16 cases
21- // here caused cross-test interference and 30s seal-timeout flakes. Same carve-out as the run-engine
22- // batch tests. The NoClickhouse variant skips the worker-scoped ClickHouse boot+migrate (these tests
23- // never touch ClickHouse), which the cold-start test would otherwise pay inside its test timeout.
19+ // Per-test redis isolation: each test runs its own RunEngine whose background work outlives the test
20+ // body. NoClickhouse because this suite never touches ClickHouse - skips the worker-scoped boot+migrate.
2421import { containerTestWithIsolatedRedisNoClickhouse as containerTest } from "@internal/testcontainers" ;
2522import { trace } from "@opentelemetry/api" ;
2623import { PrismaClient } from "@trigger.dev/database" ;
@@ -34,11 +31,8 @@ import {
3431} from "../../app/runEngine/services/streamBatchItems.server" ;
3532import { ServiceValidationError } from "../../app/v3/services/baseService.server" ;
3633
37- // 120s (not 30s): each of the 16 cases here boots its own per-test Redis container and spins up a
38- // full RunEngine, and a cold container boot counts against the test's own timeout. Under CI Docker
39- // contention that boot can take tens of seconds, so 30s was too tight and the flake landed on
40- // whichever test happened to boot while Docker was busiest. 120s matches the run-engine package
41- // convention for tests of this footprint (RunEngine + per-test container).
34+ // 120s: a cold per-test container boot counts against the test's own timeout, and under CI Docker
35+ // contention 30s was too tight. Matches the run-engine convention for this footprint.
4236vi . setConfig ( { testTimeout : 120_000 } ) ;
4337
4438describe ( "StreamBatchItemsService" , ( ) => {
0 commit comments