File tree Expand file tree Collapse file tree 1 file changed +6
-1
lines changed
packages/redis-worker/src Expand file tree Collapse file tree 1 file changed +6
-1
lines changed Original file line number Diff line number Diff line change 11import { redisTest } from "@internal/testcontainers" ;
22import { Logger } from "@trigger.dev/core/logger" ;
33import { describe } from "node:test" ;
4- import { expect } from "vitest" ;
4+ import { afterEach , expect } from "vitest" ;
55import { z } from "zod" ;
66import { Worker } from "./worker.js" ;
77import { createRedisClient } from "@internal/redis" ;
8+ import { shutdownManager } from "@trigger.dev/core/v3/serverOnly" ;
89
910describe ( "Worker" , ( ) => {
11+ afterEach ( ( ) => {
12+ ( shutdownManager as unknown as { _reset : ( ) => void } ) . _reset ( ) ;
13+ } ) ;
14+
1015 redisTest ( "Process items that don't throw" , { timeout : 30_000 } , async ( { redisContainer } ) => {
1116 const processedItems : number [ ] = [ ] ;
1217 const worker = new Worker ( {
You can’t perform that action at this time.
0 commit comments