open-source/qinglong
1
0
Fork 0
mirror of https://github.com/whyour/qinglong.git synced 2025-05-23 23:06:06 +08:00
Code Issues Packages Projects Releases Wiki Activity

修改任务队列日志打印

Browse Source
This commit is contained in:
whyour 2023-10-08 22:11:46 +08:00
parent a340964c82
commit aac109621a
1 changed files with 7 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
back/shared/pLimit.ts
View File

@ -33,12 +33,17 @@ class TaskLimit {
}) })
this.cronLimit.on('completed', (param) => { this.cronLimit.on('completed', (param) => {
Logger.info( Logger.info(
`[schedule][任务处理完成] 运行中任务数: ${this.cronLimitActiveCount - 1}, 等待中任务数: ${this.cronLimitPendingCount}, 参数 ${JSON.stringify(param)}`, `[schedule][任务处理成功] 参数 ${JSON.stringify(param)}`,
); );
}); });
this.cronLimit.on('error', error => { this.cronLimit.on('error', error => {
Logger.error( Logger.error(
`[schedule][处理任务错误] 运行中任务数: ${this.cronLimitActiveCount}, 等待中任务数: ${this.cronLimitPendingCount}, 参数 ${JSON.stringify(error)}`, `[schedule][任务处理错误] 参数 ${JSON.stringify(error)}`,
);
});
this.cronLimit.on('next', () => {
Logger.info(
`[schedule][任务处理结束] 运行中任务数: ${this.cronLimitActiveCount}, 等待中任务数: ${this.cronLimitPendingCount}`,
); );
}); });
this.cronLimit.on('idle', () => { this.cronLimit.on('idle', () => {