@@ -189,10 +189,10 @@ async function dequeueOne(engine: RunEngine) {
189189}
190190
191191describe ( "runAttemptSystem routes through the RunStore" , ( ) => {
192- // Test A — startRunAttempt routes the EXECUTING run write (and the minimal load
192+ // startRunAttempt routes the EXECUTING run write (and the minimal load
193193 // read) through the store, resolved by the owning run id.
194194 containerTest (
195- "Test A: startRunAttempt routes the run write through the store" ,
195+ "startRunAttempt routes the run write through the store" ,
196196 async ( { prisma, redisOptions } ) => {
197197 const store = new CountingRunStore ( { prisma, readOnlyPrisma : prisma } ) ;
198198 const environment = await setupAuthenticatedEnvironment ( prisma , "PRODUCTION" ) ;
@@ -226,9 +226,9 @@ describe("runAttemptSystem routes through the RunStore", () => {
226226 }
227227 ) ;
228228
229- // Test B — attemptSucceeded finalizes COMPLETED_SUCCESSFULLY through the store, with
229+ // attemptSucceeded finalizes COMPLETED_SUCCESSFULLY through the store, with
230230 containerTest (
231- "Test B: attemptSucceeded finalizes through the store" ,
231+ "attemptSucceeded finalizes through the store" ,
232232 async ( { prisma, redisOptions } ) => {
233233 const store = new CountingRunStore ( { prisma, readOnlyPrisma : prisma } ) ;
234234 const environment = await setupAuthenticatedEnvironment ( prisma , "PRODUCTION" ) ;
@@ -274,10 +274,10 @@ describe("runAttemptSystem routes through the RunStore", () => {
274274 }
275275 ) ;
276276
277- // Test C — attemptFailed -> retry routes the retry update through recordRetryOutcome,
277+ // attemptFailed -> retry routes the retry update through recordRetryOutcome,
278278 // preserving the deep runtimeEnvironment.{project,organization,orgMember} include.
279279 containerTest (
280- "Test C: attemptFailed retry routes through the store with the deep include preserved" ,
280+ "attemptFailed retry routes through the store with the deep include preserved" ,
281281 async ( { prisma, redisOptions } ) => {
282282 const store = new CountingRunStore ( { prisma, readOnlyPrisma : prisma } ) ;
283283 const environment = await setupAuthenticatedEnvironment ( prisma , "PRODUCTION" ) ;
@@ -328,9 +328,9 @@ describe("runAttemptSystem routes through the RunStore", () => {
328328 }
329329 ) ;
330330
331- // Test D — single -client passthrough: a start->succeed round-trip on the DEFAULT
331+ // Single -client passthrough: a start->succeed round-trip on the DEFAULT
332332 containerTest (
333- "Test D: single-DB binds one client (passthrough)" ,
333+ "single-DB binds one client (passthrough)" ,
334334 async ( { prisma, redisOptions } ) => {
335335 const environment = await setupAuthenticatedEnvironment ( prisma , "PRODUCTION" ) ;
336336 const engine = new RunEngine ( createEngineOptions ( redisOptions , prisma , undefined ) ) ;
@@ -371,9 +371,9 @@ describe("runAttemptSystem routes through the RunStore", () => {
371371 }
372372 ) ;
373373
374- // Test E — cancelRun routes the CANCELED update through the dedicated cancelRun method
374+ // cancelRun routes the CANCELED update through the dedicated cancelRun method
375375 containerTest (
376- "Test E: cancelRun routes the CANCELED update through the store" ,
376+ "cancelRun routes the CANCELED update through the store" ,
377377 async ( { prisma, redisOptions } ) => {
378378 const store = new CountingRunStore ( { prisma, readOnlyPrisma : prisma } ) ;
379379 const environment = await setupAuthenticatedEnvironment ( prisma , "PRODUCTION" ) ;
@@ -426,9 +426,9 @@ describe("runAttemptSystem routes through the RunStore", () => {
426426 }
427427 ) ;
428428
429- // Test F — cancelRun child fan-out stays single-DB: cancelling a parent enqueues
429+ // cancelRun child fan-out stays single-DB: cancelling a parent enqueues
430430 containerTest (
431- "Test F: cancelRun child fan-out stays single-DB" ,
431+ "cancelRun child fan-out stays single-DB" ,
432432 async ( { prisma, redisOptions } ) => {
433433 const store = new CountingRunStore ( { prisma, readOnlyPrisma : prisma } ) ;
434434 const environment = await setupAuthenticatedEnvironment ( prisma , "PRODUCTION" ) ;
@@ -482,9 +482,9 @@ describe("runAttemptSystem routes through the RunStore", () => {
482482 }
483483 ) ;
484484
485- // Test G — bulk -action push on an already-finished run routes through the dedicated
485+ // Bulk -action push on an already-finished run routes through the dedicated
486486 containerTest (
487- "Test G: bulk-action push on a finished run routes through recordBulkActionMembership" ,
487+ "bulk-action push on a finished run routes through recordBulkActionMembership" ,
488488 async ( { prisma, redisOptions } ) => {
489489 const store = new CountingRunStore ( { prisma, readOnlyPrisma : prisma } ) ;
490490 const environment = await setupAuthenticatedEnvironment ( prisma , "PRODUCTION" ) ;
@@ -597,12 +597,12 @@ function buildCreateRunInput(p: {
597597}
598598
599599describe ( "runAttemptSystem store routing — cross-version (heterogeneous Postgres)" , ( ) => {
600- // Test H — the attempt-lifecycle store methods this unit routes to (startAttempt ->
600+ // The attempt-lifecycle store methods this unit routes to (startAttempt ->
601601 // completeAttemptSuccess) land their TaskRun write + FINISHED snapshot on the dedicated
602602 // run-ops store, while a legacy/control-plane store over the same migrated schema is
603603 // untouched. Proves the run-ops store owns the attempt lifecycle cross-version.
604604 heteroPostgresTest (
605- "Test H: attempt lifecycle lands on the dedicated run-ops store" ,
605+ "attempt lifecycle lands on the dedicated run-ops store" ,
606606 async ( { prisma14, prisma17 } ) => {
607607 const newStore = new PostgresRunStore ( { prisma : prisma17 , readOnlyPrisma : prisma17 } ) ;
608608 const { organization, project, environment } = await seedEnvironment ( prisma17 ) ;
0 commit comments