Skip to content

Commit ee13ebb

Browse files
committed
Use the new single replacingmergetree task events table for replication
1 parent fa4185b commit ee13ebb

10 files changed

Lines changed: 298 additions & 1396 deletions

File tree

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

Lines changed: 1 addition & 32 deletions
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,5 @@
11
import { ClickHouse } from "@internal/clickhouse";
22
import { EventEmitter } from "node:events";
3-
import { prisma } from "~/db.server";
43
import { singleton } from "~/utils/singleton";
54
import { engine } from "~/v3/runEngine.server";
65
import { logger } from "./logger.server";
@@ -250,35 +249,5 @@ export const runsDashboard = singleton("runsDashboard", () => {
250249
});
251250

252251
async function runCreated(time: Date, runId: string, service: RunsDashboardService) {
253-
const run = await prisma.taskRun.findFirst({
254-
where: {
255-
id: runId,
256-
},
257-
});
258-
259-
if (!run) {
260-
logger.error("RunDashboard: runCreated: run not found", {
261-
runId,
262-
});
263-
264-
return;
265-
}
266-
267-
if (!run.environmentType) {
268-
logger.error("RunDashboard: runCreated: run environment type not found", {
269-
runId,
270-
});
271-
272-
return;
273-
}
274-
275-
if (!run.organizationId) {
276-
logger.error("RunDashboard: runCreated: run organization id not found", {
277-
runId,
278-
});
279-
280-
return;
281-
}
282-
283-
await service.runCreated(time, run, run.environmentType, run.organizationId);
252+
// Noop for now
284253
}

0 commit comments

Comments
 (0)