Skip to content

Commit

Permalink
chore: 1.20.11
Browse files Browse the repository at this point in the history
  • Loading branch information
greper committed May 30, 2024
1 parent ab4a0ae commit aaea6aa
Showing 1 changed file with 18 additions and 18 deletions.
Original file line number Diff line number Diff line change
@@ -1,20 +1,20 @@
import { Config, Inject, Provide, Scope, ScopeEnum } from '@midwayjs/decorator';
import { InjectEntityModel } from '@midwayjs/typeorm';
import { In, Repository } from 'typeorm';
import { BaseService } from '../../../basic/base-service';
import { PipelineEntity } from '../entity/pipeline';
import { PipelineDetail } from '../entity/vo/pipeline-detail';
import { Executor, Pipeline, ResultType, RunHistory } from '@certd/pipeline';
import { AccessService } from './access-service';
import { DbStorage } from './db-storage';
import { StorageService } from './storage-service';
import { Cron } from '../../plugin/cron/cron';
import { HistoryService } from './history-service';
import { HistoryEntity } from '../entity/history';
import { HistoryLogEntity } from '../entity/history-log';
import { HistoryLogService } from './history-log-service';
import { logger } from '../../../utils/logger';
import { EmailService } from '../../basic/service/email-service';
import {Config, Inject, Provide, Scope, ScopeEnum} from '@midwayjs/decorator';
import {InjectEntityModel} from '@midwayjs/typeorm';
import {In, Repository} from 'typeorm';
import {BaseService} from '../../../basic/base-service';
import {PipelineEntity} from '../entity/pipeline';
import {PipelineDetail} from '../entity/vo/pipeline-detail';
import {Executor, Pipeline, ResultType, RunHistory} from '@certd/pipeline';
import {AccessService} from './access-service';
import {DbStorage} from './db-storage';
import {StorageService} from './storage-service';
import {Cron} from '../../plugin/cron/cron';
import {HistoryService} from './history-service';
import {HistoryEntity} from '../entity/history';
import {HistoryLogEntity} from '../entity/history-log';
import {HistoryLogService} from './history-log-service';
import {logger} from '../../../utils/logger';
import {EmailService} from '../../basic/service/email-service';

const runningTasks: Map<string | number, Executor> = new Map();

Expand Down Expand Up @@ -131,7 +131,6 @@ export class PipelineService extends BaseService<PipelineEntity> {
for (const trigger of pipeline.triggers) {
this.registerCron(pipeline.id, trigger);
}
logger.info('当前定时器数量:', this.cron.getListSize());
}

async trigger(id) {
Expand Down Expand Up @@ -183,6 +182,7 @@ export class PipelineService extends BaseService<PipelineEntity> {
await this.run(pipelineId, trigger.id);
},
});
logger.info('当前定时器数量:', this.cron.getListSize());
}

async run(id: number, triggerId: string) {
Expand Down

0 comments on commit aaea6aa

Please sign in to comment.