style(run-ops): apply oxfmt

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

Author: d-cs

apps/webapp/app/services/runsReplicationInstance.server.ts

@@ -68,7 +68,7 @@ export function buildReplicationSources(args: {
 export class SplitReplicationMisconfiguredError extends Error {
   constructor() {
     super(
-      "RUN_OPS_SPLIT_ENABLED is on but the runs-replication sources[] has no \"new\" source: " +
+      'RUN_OPS_SPLIT_ENABLED is on but the runs-replication sources[] has no "new" source: ' +
         "ksuid runs on the new DB would not replicate to ClickHouse, under-counting every " +
         "ClickHouse-fronted aggregate. Enable the new replication source " +
         "(RUN_REPLICATION_NEW_ENABLED / RUN_OPS_DATABASE_URL) or turn the split off."
@@ -162,8 +162,7 @@ function initializeRunsReplicationInstance() {
           splitEnabled,
           legacyUrl: DATABASE_URL,
           newUrl: env.RUN_OPS_DATABASE_URL ?? env.TASK_RUN_DATABASE_URL,
-          newSourceOverride:
-            env.RUN_REPLICATION_NEW_ENABLED === "disabled" ? false : undefined,
+          newSourceOverride: env.RUN_REPLICATION_NEW_ENABLED === "disabled" ? false : undefined,
           legacySlotName: env.RUN_REPLICATION_SLOT_NAME,
           legacyPublicationName: env.RUN_REPLICATION_PUBLICATION_NAME,
           legacyOriginGeneration: env.RUN_REPLICATION_LEGACY_ORIGIN_GENERATION,

apps/webapp/test/runsReplicationInstance.test.ts

@@ -168,7 +168,7 @@ describe("assertReplicationCoversSplit (boot gate-coupling)", () => {
     newOriginGeneration: 1,
   };
 
-  it("throws when split is on but sources[] has no \"new\" source (the silent under-count)", () => {
+  it('throws when split is on but sources[] has no "new" source (the silent under-count)', () => {
     // Split on, but the new replication source is forced off — ksuid runs would not
     // reach ClickHouse. This is the exact misconfiguration the boot gate must refuse to boot with.
     const sources = buildReplicationSources({
@@ -268,9 +268,16 @@ describe("RunsReplication new-source backfill origin generation (integration)",
 
       // Create org/project/env/run on the legacy DB (the FK schema lives there).
       // This simulates a pre-existing run that was migrated to the dedicated DB.
-      const organization = await prisma.organization.create({ data: { title: "bf-gen", slug: "bf-gen" } });
+      const organization = await prisma.organization.create({
+        data: { title: "bf-gen", slug: "bf-gen" },
+      });
       const project = await prisma.project.create({
-        data: { name: "bf-gen", slug: "bf-gen", organizationId: organization.id, externalRef: "bf-gen" },
+        data: {
+          name: "bf-gen",
+          slug: "bf-gen",
+          organizationId: organization.id,
+          externalRef: "bf-gen",
+        },
       });
       const runtimeEnvironment = await prisma.runtimeEnvironment.create({
         data: {
@@ -303,16 +310,14 @@ describe("RunsReplication new-source backfill origin generation (integration)",
 
       try {
         // Backfill the run via the "new" source — must encode gen=1 in _version.
-        await service.backfill(
-          [{ ...run, masterQueue: run.workerQueue ?? "main" }],
-          "new"
-        );
+        await service.backfill([{ ...run, masterQueue: run.workerQueue ?? "main" }], "new");
 
         await setTimeout(500);
 
         const queryRuns = clickhouse.reader.query({
           name: "runs-replication-backfill-gen",
-          query: "SELECT run_id, _version FROM trigger_dev.task_runs_v2 WHERE run_id = {run_id:String}",
+          query:
+            "SELECT run_id, _version FROM trigger_dev.task_runs_v2 WHERE run_id = {run_id:String}",
           schema: z.object({ run_id: z.string(), _version: z.number() }),
           params: z.object({ run_id: z.string() }),
         });