henry/AITrader
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Remove QueueScheduler usage (avoid SSR runtime error)

Browse Source
This commit is contained in:
henry
2026-05-16 14:41:06 +02:00
parent 1b31a4a131
commit 5f5a48067c
1 changed files with 1 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
app/lib/queue.ts
+1 -2
View File
@@ -1,5 +1,5 @@
import pkg from "bullmq"; import pkg from "bullmq";
const { Queue, Worker, QueueScheduler } = pkg as any; const { Queue, Worker } = pkg as any;
import IORedis from "ioredis"; import IORedis from "ioredis";
import { OpenRouterClient } from "./openrouter"; import { OpenRouterClient } from "./openrouter";
import { TradingGraph } from "../agents/tradingGraph"; 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(); const redis = process.env.REDIS_URL ? new IORedis(process.env.REDIS_URL) : new IORedis();
export const analyzeQueue = new Queue("analyze", { connection: redis }); export const analyzeQueue = new Queue("analyze", { connection: redis });
export const queueScheduler = new QueueScheduler("analyze", { connection: redis });
// Worker to process analyze jobs // Worker to process analyze jobs
export const worker = new Worker( export const worker = new Worker(