|
1 | 1 | import { ClickHouse } from "@internal/clickhouse"; |
2 | 2 | import { containerTest } from "@internal/testcontainers"; |
3 | 3 | import { Logger } from "@trigger.dev/core/logger"; |
| 4 | +import { readFile } from "node:fs/promises"; |
4 | 5 | import { setTimeout } from "node:timers/promises"; |
5 | 6 | import { z } from "zod"; |
6 | | -import { TaskRunStatus } from "~/database-types"; |
7 | 7 | import { RunsReplicationService } from "~/services/runsReplicationService.server"; |
8 | | -import { createInMemoryTracing } from "./utils/tracing"; |
9 | | -import superjson from "superjson"; |
10 | | -import { readFile } from "node:fs/promises"; |
11 | 8 | import { detectBadJsonStrings } from "~/utils/detectBadJsonStrings"; |
12 | 9 |
|
13 | 10 | vi.setConfig({ testTimeout: 60_000 }); |
14 | 11 |
|
15 | 12 | describe("RunsReplicationService (part 2/2)", () => { |
16 | | - containerTest.skip( |
| 13 | + containerTest( |
17 | 14 | "should handover leadership to a second service, and the second service should be able to extend the leader lock", |
18 | 15 | async ({ clickhouseContainer, redisOptions, postgresContainer, prisma }) => { |
19 | 16 | await prisma.$executeRawUnsafe(`ALTER TABLE public."TaskRun" REPLICA IDENTITY FULL;`); |
@@ -142,7 +139,7 @@ describe("RunsReplicationService (part 2/2)", () => { |
142 | 139 | } |
143 | 140 | ); |
144 | 141 |
|
145 | | - containerTest.skip( |
| 142 | + containerTest( |
146 | 143 | "should replicate all 1,000 TaskRuns inserted in bulk to ClickHouse", |
147 | 144 | async ({ clickhouseContainer, redisOptions, postgresContainer, prisma }) => { |
148 | 145 | await prisma.$executeRawUnsafe(`ALTER TABLE public."TaskRun" REPLICA IDENTITY FULL;`); |
@@ -256,7 +253,7 @@ describe("RunsReplicationService (part 2/2)", () => { |
256 | 253 | } |
257 | 254 | ); |
258 | 255 |
|
259 | | - containerTest.skip( |
| 256 | + containerTest( |
260 | 257 | "should replicate all 1,000 TaskRuns inserted in bulk to ClickHouse with updates", |
261 | 258 | async ({ clickhouseContainer, redisOptions, postgresContainer, prisma }) => { |
262 | 259 | await prisma.$executeRawUnsafe(`ALTER TABLE public."TaskRun" REPLICA IDENTITY FULL;`); |
@@ -376,7 +373,7 @@ describe("RunsReplicationService (part 2/2)", () => { |
376 | 373 | } |
377 | 374 | ); |
378 | 375 |
|
379 | | - containerTest.skip( |
| 376 | + containerTest( |
380 | 377 | "should replicate all events in a single transaction (insert, update)", |
381 | 378 | async ({ clickhouseContainer, redisOptions, postgresContainer, prisma }) => { |
382 | 379 | await prisma.$executeRawUnsafe(`ALTER TABLE public."TaskRun" REPLICA IDENTITY FULL;`); |
|
0 commit comments