diff --git a/packages/ui/certd-server/src/modules/cron/cron.ts b/packages/ui/certd-server/src/modules/cron/cron.ts index fc2373271..303a02644 100644 --- a/packages/ui/certd-server/src/modules/cron/cron.ts +++ b/packages/ui/certd-server/src/modules/cron/cron.ts @@ -1,5 +1,5 @@ import parser from 'cron-parser'; -import { ILogger } from '@certd/basic'; +import { ILogger, logger } from '@certd/basic'; export type CronTaskReq = { /** @@ -52,7 +52,7 @@ export class Cron { queue: CronTask[] = []; constructor(opts: any) { - this.logger = opts.logger; + this.logger = opts.logger || logger; this.immediateTriggerOnce = opts.immediateTriggerOnce; } diff --git a/packages/ui/certd-server/src/modules/pipeline/service/pipeline-service.ts b/packages/ui/certd-server/src/modules/pipeline/service/pipeline-service.ts index ce56a832f..85b959305 100644 --- a/packages/ui/certd-server/src/modules/pipeline/service/pipeline-service.ts +++ b/packages/ui/certd-server/src/modules/pipeline/service/pipeline-service.ts @@ -441,6 +441,7 @@ export class PipelineService extends BaseService { pipeline = await this.info(id); } else { pipeline = id; + id = pipeline.id; } if (!pipeline) { return; @@ -456,6 +457,7 @@ export class PipelineService extends BaseService { removeCron(pipelineId, trigger) { const name = this.buildCronKey(pipelineId, trigger.id); this.cron.remove(name); + logger.info("当前定时器数量:", this.cron.getTaskSize()); } registerCron(pipelineId, trigger) {