We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 821b918 commit 59afe71Copy full SHA for 59afe71
1 file changed
packages/redis-worker/src/worker.test.ts
@@ -1,12 +1,17 @@
1
import { redisTest } from "@internal/testcontainers";
2
import { Logger } from "@trigger.dev/core/logger";
3
import { describe } from "node:test";
4
-import { expect } from "vitest";
+import { afterEach, expect } from "vitest";
5
import { z } from "zod";
6
import { Worker } from "./worker.js";
7
import { createRedisClient } from "@internal/redis";
8
+import { shutdownManager } from "@trigger.dev/core/v3/serverOnly";
9
10
describe("Worker", () => {
11
+ afterEach(() => {
12
+ (shutdownManager as unknown as { _reset: () => void })._reset();
13
+ });
14
+
15
redisTest("Process items that don't throw", { timeout: 30_000 }, async ({ redisContainer }) => {
16
const processedItems: number[] = [];
17
const worker = new Worker({
0 commit comments