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 2024-08-26 23:05:53 +08:00
parent 6c61ac5106
commit 19cfc9e351
1 changed files with 9 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
back/shared/pLimit.ts
View File

@ -123,12 +123,15 @@ class TaskLimit {
let runs = this.queuedCrons.get(cron.id); let runs = this.queuedCrons.get(cron.id);
const result = runs?.length ? [...runs, fn] : [fn]; const result = runs?.length ? [...runs, fn] : [fn];
const repeatTimes = this.repeatCronNotifyMap.get(cron.id) || 0; const repeatTimes = this.repeatCronNotifyMap.get(cron.id) || 0;
if (result?.length > 5 && repeatTimes < 3) { if (result?.length > 5) {
this.repeatCronNotifyMap.set(cron.id, repeatTimes + 1); if (repeatTimes < 3) {
this.notificationService.externalNotify( this.repeatCronNotifyMap.set(cron.id, repeatTimes + 1);
'任务重复运行', this.notificationService.externalNotify(
`任务：${cron.name}，命令：${cron.command}，定时：${cron.schedule}，处于运行中的超过 5 个，请检查定时设置`, '任务重复运行',
); `任务：${cron.name}，命令：${cron.command}，定时：${cron.schedule}，处于运行中的超过 5 个，请检查定时设置`,
);
}
Logger.warn(`[schedule][任务重复运行] 参数 ${JSON.stringify(cron)}`);
return; return;
} }
this.queuedCrons.set(cron.id, result); this.queuedCrons.set(cron.id, result);