Skip to content

Commit 5063ce0

Browse files
committed
Add queue log
1 parent 4f1d694 commit 5063ce0

File tree

2 files changed

+4
-0
lines changed

2 files changed

+4
-0
lines changed

projects/app/src/service/events/generateQA.ts

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -36,6 +36,8 @@ const reduceQueue = () => {
3636

3737
export async function generateQA(): Promise<any> {
3838
const max = global.systemEnv?.qaMaxProcess || 10;
39+
addLog.debug(`[QA Queue] Queue size: ${global.qaQueueLen}`);
40+
3941
if (global.qaQueueLen >= max) return;
4042
global.qaQueueLen++;
4143

projects/app/src/service/events/generateVector.ts

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -35,6 +35,8 @@ const reduceQueueAndReturn = (delay = 0) => {
3535
/* 索引生成队列。每导入一次,就是一个单独的线程 */
3636
export async function generateVector(): Promise<any> {
3737
const max = global.systemEnv?.vectorMaxProcess || 10;
38+
addLog.debug(`[Vector Queue] Queue size: ${global.vectorQueueLen}`);
39+
3840
if (global.vectorQueueLen >= max) return;
3941
global.vectorQueueLen++;
4042
const start = Date.now();

0 commit comments

Comments
 (0)