@@ -20,8 +20,7 @@
 // redirect) and fails if the re-read is reverted (replica miss → buffer empty → "Run not found",
 // cancel never invoked).
 
-import { heteroPostgresTest } from "@internal/testcontainers";
-import { laggingReplica } from "@internal/testcontainers";
+import { heteroPostgresTest, laggingReplica } from "@internal/testcontainers";
 import type { PrismaClient } from "@trigger.dev/database";
 import { describe, expect, vi } from "vitest";
 
 
@@ -41,7 +41,7 @@
 // drive the real caller with NO module mocking at all.
 
 import { heteroPostgresTest, laggingReplica } from "@internal/testcontainers";
-import type { PrismaClient } from "@trigger.dev/database";
+import type { PrismaClient, Session } from "@trigger.dev/database";
 import { describe, expect, vi } from "vitest";
 
 vi.setConfig({ testTimeout: 60_000, hookTimeout: 60_000 });
@@ -127,7 +127,6 @@ import {
   serializeSessionsWithFriendlyRunIds,
 } from "~/services/realtime/sessions.server";
 import type { AuthenticatedEnvironment } from "~/services/apiAuth.server";
-import type { Session } from "@trigger.dev/database";
 
 let seq = 0;
 
 
@@ -199,10 +199,7 @@ import type { CreateRunInput } from "@internal/run-store";
 
 // The REAL exported callers under guard.
 import { loader as realtimeRunLoader } from "~/routes/realtime.v1.runs.$runId";
-import {
-  action as streamStreamIdAction,
-  loader as streamStreamIdLoader,
-} from "~/routes/realtime.v1.streams.$runId.$streamId";
+import { loader as streamStreamIdLoader } from "~/routes/realtime.v1.streams.$runId.$streamId";
 import {
   action as streamTargetAction,
   loader as streamTargetLoader,
@@ -400,34 +397,7 @@ describe("realtime-stream routes — run-ops replica-lag guards", () => {
     }
   );
 
-  // 2. realtime.v1.streams.$runId.$streamId.ts:26 (plain action, backwards-compat ingest).
-  heteroPostgresTest(
-    "realtime.v1.streams.$streamId action finds a live run via the primary re-read",
-    async ({ prisma14 }) => {
-      const prisma = prisma14 as unknown as PrismaClient;
-      const { friendlyId, replica } = await setupLiveRunWithFrozenReplica(prisma);
-
-      const res = await invoke(
-        () =>
-          streamStreamIdAction({
-            request: new Request(`http://localhost/realtime/v1/streams/${friendlyId}/s1`, {
-              method: "POST",
-              body: "chunk-data",
-            }),
-            params: { runId: friendlyId, streamId: "s1" },
-            context: {} as never,
-          }) as Promise<Response>
-      );
-
-      expect(replica.wasHit("taskRun")).toBe(true);
-      // Run found via the primary re-read → reaches ingestData marker. Without the re-read this is a
-      // "Run not found" 404.
-      expect(res.status).toBe(200);
-      expect(await res.clone().text()).toBe("marker:ingestData");
-    }
-  );
-
-  // 3. realtime.v1.streams.$runId.$streamId.ts:90 (createLoaderApiRoute findResource) — SSE subscribe.
+  // 2. realtime.v1.streams.$runId.$streamId.ts:90 (createLoaderApiRoute findResource) — SSE subscribe.
   heteroPostgresTest(
     "realtime.v1.streams.$streamId loader finds a live run via the primary re-read",
     async ({ prisma14 }) => {
 
@@ -122,8 +122,7 @@ vi.mock("~/models/message.server", async (importOriginal) => {
   };
 });
 
-import { PostgresRunStore } from "@internal/run-store";
-import { RoutingRunStore } from "@internal/run-store";
+import { PostgresRunStore, RoutingRunStore } from "@internal/run-store";
 import { action } from "~/routes/resources.taskruns.$runParam.replay";
 
 vi.setConfig({ testTimeout: 60_000, hookTimeout: 60_000 });
 
@@ -152,8 +152,6 @@ import { loader as spansLoader } from "~/routes/api.v1.runs.$runId.spans.$spanId
 import { loader as traceLoader } from "~/routes/api.v1.runs.$runId.trace";
 import { loader as syncTraceRunsLoader } from "~/routes/sync.traces.runs.$traceId";
 
-type AnyClient = PrismaClient | RunOpsPrismaClient;
-
 // A cuid (25 chars after `run_`) classifies LEGACY, so both the create and the friendlyId/traceId
 // reads route to the legacy (control-plane) store — the store that owns these runs.
 const CUID_25 = "c".repeat(25);
 
@@ -23,7 +23,7 @@ import { describe, expect } from "vitest";
 import { PostgresRunStore } from "./PostgresRunStore.js";
 import { RoutingRunStore } from "./runOpsStore.js";
 import { markReadReplicaClient } from "./readReplicaClient.js";
-import type { CreateRunInput, RunStoreSchemaVariant } from "./types.js";
+import type { CreateRunInput } from "./types.js";
 
 type AnyClient = PrismaClient | RunOpsPrismaClient;
 
 
@@ -52,8 +52,6 @@ import { PostgresRunStore } from "./PostgresRunStore.js";
 import { RoutingRunStore } from "./runOpsStore.js";
 import { markReadReplicaClient } from "./readReplicaClient.js";
 
-type AnyClient = PrismaClient | RunOpsPrismaClient;
-
 // A cuid-shaped id (no run-ops v1 marker) classifies LEGACY, so both the create and the friendlyId-keyed
 // reads route to the legacy (control-plane / prisma14, full schema) store first — the common realtime
 // residency and the store whose frozen replica the read hits.
@@ -169,7 +167,7 @@ describe("run-ops split — realtime-STREAM route read views vs. a lagging repli
   heteroRunOpsPostgresTest(
     "runs.$runId findRun(branded $replica) is NULL under lag — subscribeToRun gets a spurious 404 of a live run; a primary fallback recovers it",
     async ({ prisma14, prisma17 }) => {
-      const { router, legacyReplica, seed, runId, friendlyId } = await setupLaggingLegacy(
+      const { router, legacyReplica, seed, friendlyId } = await setupLaggingLegacy(
         prisma14,
         prisma17,
         "rt_run_subscribe"
 
@@ -33,7 +33,6 @@
 import { heteroRunOpsPostgresTest } from "@internal/testcontainers";
 import type { PrismaClient } from "@trigger.dev/database";
 import type { RunOpsPrismaClient } from "@internal/run-ops-database";
-import { generateRunOpsId } from "@trigger.dev/core/v3/isomorphic";
 import { describe, expect } from "vitest";
 import { PostgresRunStore } from "./PostgresRunStore.js";
 import { RoutingRunStore } from "./runOpsStore.js";
 
@@ -25,14 +25,11 @@
 
 import { heteroRunOpsPostgresTest, laggingReplica } from "@internal/testcontainers";
 import type { PrismaClient } from "@trigger.dev/database";
-import type { RunOpsPrismaClient } from "@internal/run-ops-database";
 import { describe, expect } from "vitest";
 import { PostgresRunStore } from "./PostgresRunStore.js";
 import { RoutingRunStore } from "./runOpsStore.js";
 import type { CreateRunInput, ReadClient } from "./types.js";
 
-type AnyClient = PrismaClient | RunOpsPrismaClient;
-
 // ownerEngine (classifyResidency) routes a run-ops v1 body → NEW, everything else → LEGACY.
 const CUID_25 = "d".repeat(25); // → LEGACY (control-plane / prisma14, full schema)
 
 
@@ -34,7 +34,6 @@
 import { heteroRunOpsPostgresTest } from "@internal/testcontainers";
 import type { PrismaClient } from "@trigger.dev/database";
 import type { RunOpsPrismaClient } from "@internal/run-ops-database";
-import { generateRunOpsId } from "@trigger.dev/core/v3/isomorphic";
 import { describe, expect } from "vitest";
 import { PostgresRunStore } from "./PostgresRunStore.js";
 import { RoutingRunStore } from "./runOpsStore.js";