diff --git a/app/lib/queue.ts b/app/lib/queue.ts index b3d24c0..7500f62 100644 --- a/app/lib/queue.ts +++ b/app/lib/queue.ts @@ -1,5 +1,5 @@ import pkg from "bullmq"; -const { Queue, Worker, QueueScheduler } = pkg as any; +const { Queue, Worker } = pkg as any; import IORedis from "ioredis"; import { OpenRouterClient } from "./openrouter"; import { TradingGraph } from "../agents/tradingGraph"; @@ -11,7 +11,6 @@ const connection = process.env.REDIS_URL ? { connection: process.env.REDIS_URL } const redis = process.env.REDIS_URL ? new IORedis(process.env.REDIS_URL) : new IORedis(); export const analyzeQueue = new Queue("analyze", { connection: redis }); -export const queueScheduler = new QueueScheduler("analyze", { connection: redis }); // Worker to process analyze jobs export const worker = new Worker(