lkddi/certd
1
0
Fork 0
mirror of https://github.com/certd/certd.git synced 2026-04-24 12:27:25 +08:00
Code Issues Packages Projects Releases Wiki Activity

chore: 修复清除定时任务未生效的bug

Browse Source
This commit is contained in:
xiaojunnuo
2025-12-16 00:34:32 +08:00
parent 63d8bcf882
commit ab8fbaf21d
2 changed files with 4 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
packages/ui/certd-server/src/modules/cron/cron.ts
+2 -2
View File
@@ -1,5 +1,5 @@
import parser from 'cron-parser'; import parser from 'cron-parser';
import { ILogger } from '@certd/basic'; import { ILogger, logger } from '@certd/basic';
export type CronTaskReq = { export type CronTaskReq = {
/** /**
@@ -52,7 +52,7 @@ export class Cron {
queue: CronTask[] = []; queue: CronTask[] = [];
constructor(opts: any) { constructor(opts: any) {
this.logger = opts.logger; this.logger = opts.logger || logger;
this.immediateTriggerOnce = opts.immediateTriggerOnce; this.immediateTriggerOnce = opts.immediateTriggerOnce;
} }
packages/ui/certd-server/src/modules/pipeline/service/pipeline-service.ts
+2
View File
@@ -441,6 +441,7 @@ export class PipelineService extends BaseService<PipelineEntity> {
pipeline = await this.info(id); pipeline = await this.info(id);
} else { } else {
pipeline = id; pipeline = id;
id = pipeline.id;
} }
if (!pipeline) { if (!pipeline) {
return; return;
@@ -456,6 +457,7 @@ export class PipelineService extends BaseService<PipelineEntity> {
removeCron(pipelineId, trigger) { removeCron(pipelineId, trigger) {
const name = this.buildCronKey(pipelineId, trigger.id); const name = this.buildCronKey(pipelineId, trigger.id);
this.cron.remove(name); this.cron.remove(name);
logger.info("当前定时器数量：", this.cron.getTaskSize());
} }
registerCron(pipelineId, trigger) { registerCron(pipelineId, trigger) {