Skip to content

Commit b816dee

Browse files
committed
chore: prettier-format split test files + testcontainers package
1 parent 683fe41 commit b816dee

16 files changed

Lines changed: 368 additions & 389 deletions

apps/webapp/test/engine/streamBatchItems.test.ts

Lines changed: 4 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -1588,10 +1588,7 @@ describe("createNdjsonParserStream", () => {
15881588
const parser = createNdjsonParserStream(1024);
15891589
const results = await collectStream(stream.pipeThrough(parser));
15901590

1591-
expect(results).toEqual([
1592-
{ payload: "line1\nline2\nline3" },
1593-
{ payload: "no newlines" },
1594-
]);
1591+
expect(results).toEqual([{ payload: "line1\nline2\nline3" }, { payload: "no newlines" }]);
15951592
});
15961593

15971594
it("should skip empty lines", async () => {
@@ -1892,7 +1889,9 @@ describe("extractIndexAndTask", () => {
18921889
});
18931890

18941891
it("should not match nested keys", () => {
1895-
const bytes = encoder.encode('{"nested":{"index":999,"task":"inner"},"index":5,"task":"outer"}');
1892+
const bytes = encoder.encode(
1893+
'{"nested":{"index":999,"task":"inner"},"index":5,"task":"outer"}'
1894+
);
18961895
const result = extractIndexAndTask(bytes);
18971896
expect(result.index).toBe(5);
18981897
expect(result.task).toBe("outer");

apps/webapp/test/runsReplicationService.part3.test.ts

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -304,5 +304,4 @@ describe("RunsReplicationService (part 3/7)", () => {
304304
await runsReplicationService.stop();
305305
}
306306
);
307-
308307
});

apps/webapp/test/runsReplicationService.part5.test.ts

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -144,5 +144,4 @@ describe("RunsReplicationService (part 5/7)", () => {
144144
await runsReplicationService.stop();
145145
}
146146
);
147-
148147
});

apps/webapp/test/runsReplicationService.part7.test.ts

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -117,5 +117,4 @@ describe("RunsReplicationService (part 7/7)", () => {
117117
await runsReplicationService.stop();
118118
}
119119
);
120-
121120
});

apps/webapp/test/runsRepository.part1.test.ts

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -419,5 +419,4 @@ describe("RunsRepository (part 1/4)", () => {
419419
expect(runs.map((r) => r.status).sort()).toEqual(["COMPLETED_SUCCESSFULLY", "PENDING"]);
420420
}
421421
);
422-
423422
});

apps/webapp/test/runsRepository.part2.test.ts

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -453,5 +453,4 @@ describe("RunsRepository (part 2/4)", () => {
453453
expect(runs.map((r) => r.id).sort()).toEqual([run1.id, run3.id].sort());
454454
}
455455
);
456-
457456
});

apps/webapp/test/runsRepository.part3.test.ts

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -340,4 +340,4 @@ describe("RunsRepository (part 3/4)", () => {
340340
expect(productionRuns.runs[0].friendlyId).toBe("run_production");
341341
}
342342
);
343-
});
343+
});

internal-packages/run-engine/src/engine/tests/batchTriggerAndWait.test.ts

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,7 @@
1-
import { assertNonNullable, containerTestWithIsolatedRedis as containerTest } from "@internal/testcontainers";
1+
import {
2+
assertNonNullable,
3+
containerTestWithIsolatedRedis as containerTest,
4+
} from "@internal/testcontainers";
25
import { trace } from "@internal/tracing";
36
import { expect, describe } from "vitest";
47
import { RunEngine } from "../index.js";

internal-packages/run-engine/src/engine/tests/batchTwoPhase.test.ts

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,7 @@
1-
import { assertNonNullable, containerTestWithIsolatedRedis as containerTest } from "@internal/testcontainers";
1+
import {
2+
assertNonNullable,
3+
containerTestWithIsolatedRedis as containerTest,
4+
} from "@internal/testcontainers";
25
import { trace } from "@internal/tracing";
36
import { expect, describe, vi } from "vitest";
47
import { RunEngine } from "../index.js";

0 commit comments

Comments
 (0)