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:
hanhh 2021-08-20 10:59:59 +08:00
parent d9a9d2ee4f
commit 7092be97eb
1 changed files with 14 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
back/services/cron.ts
View File

@ -232,7 +232,7 @@ export default class CronService {
return; return;
} }
let { _id, command } = cron; let { _id, command, log_path } = cron;
this.logger.silly('Running job'); this.logger.silly('Running job');
this.logger.silly('ID: ' + _id); this.logger.silly('ID: ' + _id);
@ -251,7 +251,20 @@ export default class CronService {
{ _id }, { _id },
{ $set: { status: CrontabStatus.running, pid: cp.pid } }, { $set: { status: CrontabStatus.running, pid: cp.pid } },
); );
cp.stderr.on('data', (data) => {
this.logger.info(`stderr: ${data}`);
if (log_path) {
fs.appendFileSync(`${log_path}`, `${data}`);
}
});
cp.on('error', (err) => {
this.logger.info(`err: ${err}`);
if (log_path) {
fs.appendFileSync(`${log_path}`, `${JSON.stringify(err)}`);
}
});
cp.on('close', (code) => { cp.on('close', (code) => {
this.logger.info(`${command} pid: ${cp.pid} closed ${code}`);
this.cronDb.update( this.cronDb.update(
{ _id }, { _id },
{ $set: { status: CrontabStatus.idle }, $unset: { pid: true } }, { $set: { status: CrontabStatus.idle }, $unset: { pid: true } },