fix(otel): remove clickhouse event repo feature flag support from v3, now v4 only (#2585)

Author: ericallam

apps/webapp/app/v3/eventRepository/index.server.ts

@@ -38,6 +38,24 @@ export async function getEventRepository(
   return { repository: eventRepository, store: getTaskEventStore() };
 }
 
+export async function getV3EventRepository(
+  parentStore: string | undefined
+): Promise<{ repository: IEventRepository; store: string }> {
+  if (typeof parentStore === "string") {
+    if (parentStore === "clickhouse") {
+      return { repository: clickhouseEventRepository, store: "clickhouse" };
+    } else {
+      return { repository: eventRepository, store: getTaskEventStore() };
+    }
+  }
+
+  if (env.EVENT_REPOSITORY_DEFAULT_STORE === "clickhouse") {
+    return { repository: clickhouseEventRepository, store: "clickhouse" };
+  } else {
+    return { repository: eventRepository, store: getTaskEventStore() };
+  }
+}
+
 async function resolveTaskEventRepositoryFlag(
   featureFlags: Record<string, unknown> | undefined
 ): Promise<"clickhouse" | "postgres"> {

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

@@ -22,7 +22,7 @@ import { parseDelay } from "~/utils/delays";
 import { resolveIdempotencyKeyTTL } from "~/utils/idempotencyKeys.server";
 import { handleMetadataPacket } from "~/utils/packets";
 import { marqs } from "~/v3/marqs/index.server";
-import { getEventRepository } from "../eventRepository/index.server";
+import { getV3EventRepository } from "../eventRepository/index.server";
 import { generateFriendlyId } from "../friendlyIdentifiers";
 import { findCurrentWorkerFromEnvironment } from "../models/workerDeployment.server";
 import { guardQueueSizeLimitsForEnv } from "../queueSizeLimits.server";
@@ -291,8 +291,7 @@ export class TriggerTaskServiceV1 extends BaseService {
           })
         : undefined;
 
-      const { repository, store } = await getEventRepository(
-        environment.organization.featureFlags as Record<string, unknown>,
+      const { repository, store } = await getV3EventRepository(
         dependentAttempt?.taskRun.taskEventStore ??
           parentAttempt?.taskRun.taskEventStore ??
           dependentBatchRun?.dependentTaskAttempt?.taskRun.taskEventStore