style(run-ops): apply oxfmt

Co-Authored-By: Claude Opus 4.8 (1M context) <noreply@anthropic.com>

Author: d-cs

apps/webapp/app/v3/services/bulk/BulkActionV2.server.ts

@@ -27,10 +27,7 @@ import { formatDateTime } from "~/components/primitives/DateTime";
 import pMap from "p-map";
 import { type PrismaReplicaClient } from "~/db.server";
 import { isSplitEnabled } from "~/v3/runOpsMigration/splitMode.server";
-import {
-  hydrateRunsAcrossSeam,
-  type SeamReadDeps,
-} from "./BulkActionV2.batchReadThrough.server";
+import { hydrateRunsAcrossSeam, type SeamReadDeps } from "./BulkActionV2.batchReadThrough.server";
 
 export type ProcessToCompletionOptions = {
   /** Absolute timestamp (ms) after which processing stops and returns incomplete. */

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

@@ -397,4 +397,3 @@ export class ResumeBatchRunService extends BaseService {
     }
   }
 }
-

apps/webapp/test/idempotencyDedupResidency.test.ts

@@ -4,7 +4,12 @@ import { generateKsuidId } from "@trigger.dev/core/v3/isomorphic";
 import { describe, expect, vi } from "vitest";
 
 // Stub so the runStore singleton doesn't eagerly connect at import.
-vi.mock("~/db.server", () => ({ prisma: {}, $replica: {}, runOpsNewPrisma: {}, runOpsLegacyPrisma: {} }));
+vi.mock("~/db.server", () => ({
+  prisma: {},
+  $replica: {},
+  runOpsNewPrisma: {},
+  runOpsLegacyPrisma: {},
+}));
 // Keep split off so resolveIdempotencyDedupClient returns this.prisma (the hetero fixture client).
 vi.mock("~/v3/runOpsMigration/splitMode.server", () => ({ isSplitEnabled: async () => false }));
 

apps/webapp/test/idempotencyKeyConcernLegacyAuthority.test.ts

@@ -9,7 +9,12 @@ import { describe, expect, vi } from "vitest";
 // exercised — the passed client runs the query. Mirrors the shipped
 // `mollifierClaimResolution` test: env-wiring mock only; the DB under test is
 // the real PG14 + PG17 hetero-fixture containers.
-vi.mock("~/db.server", () => ({ prisma: {}, $replica: {}, runOpsNewPrisma: {}, runOpsLegacyPrisma: {} }));
+vi.mock("~/db.server", () => ({
+  prisma: {},
+  $replica: {},
+  runOpsNewPrisma: {},
+  runOpsLegacyPrisma: {},
+}));
 // Keep split off so resolveIdempotencyDedupClient returns this.prisma (the hetero fixture client).
 vi.mock("~/v3/runOpsMigration/splitMode.server", () => ({ isSplitEnabled: async () => false }));
 

apps/webapp/test/performTaskRunAlertsStoreRouting.test.ts

@@ -210,7 +210,9 @@ const TASK_RUN_CROSS_SEAM_FKS = [
 
 async function dropTaskRunCrossSeamFks(prisma: PrismaClient) {
   for (const constraint of TASK_RUN_CROSS_SEAM_FKS) {
-    await prisma.$executeRawUnsafe(`ALTER TABLE "TaskRun" DROP CONSTRAINT IF EXISTS "${constraint}"`);
+    await prisma.$executeRawUnsafe(
+      `ALTER TABLE "TaskRun" DROP CONSTRAINT IF EXISTS "${constraint}"`
+    );
   }
 }
 

apps/webapp/test/realtime/streamRegistrationRouting.test.ts

@@ -174,26 +174,26 @@ describe("realtime stream registration — run-ops store routed writes", () => {
     "completed run guard issues no push",
     { timeout: 60_000 },
     async ({ prisma17 }) => {
-    const store = new PostgresRunStore({ prisma: prisma17, readOnlyPrisma: prisma17 });
-
-    const runId = "run_routed_push_completed";
-    await seedRun(prisma17, {
-      runId,
-      slugSuffix: "completed17",
-      completedAt: new Date("2026-06-01T00:00:00.000Z"),
-    });
-
-    const streamId = "stream-late";
-    const result = await routedRegisterStream(store, prisma17, runId, streamId);
-
-    // The completedAt guard blocks the push (route returns 400).
-    expect(result.pushed).toBe(false);
-
-    const row = await prisma17.taskRun.findFirst({
-      where: { id: runId },
-      select: { realtimeStreams: true },
-    });
-    expect(row?.realtimeStreams).toEqual([]);
+      const store = new PostgresRunStore({ prisma: prisma17, readOnlyPrisma: prisma17 });
+
+      const runId = "run_routed_push_completed";
+      await seedRun(prisma17, {
+        runId,
+        slugSuffix: "completed17",
+        completedAt: new Date("2026-06-01T00:00:00.000Z"),
+      });
+
+      const streamId = "stream-late";
+      const result = await routedRegisterStream(store, prisma17, runId, streamId);
+
+      // The completedAt guard blocks the push (route returns 400).
+      expect(result.pushed).toBe(false);
+
+      const row = await prisma17.taskRun.findFirst({
+        where: { id: runId },
+        select: { realtimeStreams: true },
+      });
+      expect(row?.realtimeStreams).toEqual([]);
     }
   );
 

apps/webapp/test/resetIdempotencyKeyLegacyAuthority.test.ts

@@ -32,7 +32,10 @@ function makeService(legacyPrisma: PrismaClient) {
 }
 
 function makeEnv(opts: { id: string; organizationId: string }): AuthenticatedEnvironment {
-  return { id: opts.id, organizationId: opts.organizationId } as unknown as AuthenticatedEnvironment;
+  return {
+    id: opts.id,
+    organizationId: opts.organizationId,
+  } as unknown as AuthenticatedEnvironment;
 }
 
 async function seedOrgProjectEnv(prisma: PrismaClient, suffix: string) {

apps/webapp/test/streamLoader.controlPlane.test.ts

@@ -19,7 +19,12 @@ async function seedControlPlane(prisma: PrismaClient) {
     data: { title: `Org ${s}`, slug: `org-${s}`, streamBasinName: `basin-${s}` },
   });
   const project = await prisma.project.create({
-    data: { name: `P ${s}`, slug: `p-${s}`, externalRef: `proj_${s}`, organizationId: organization.id },
+    data: {
+      name: `P ${s}`,
+      slug: `p-${s}`,
+      externalRef: `proj_${s}`,
+      organizationId: organization.id,
+    },
   });
   const environment = await prisma.runtimeEnvironment.create({
     data: {