feat: 任务完成后更新数据库中的数据。

This commit is contained in:
Ivan Li 2021-06-20 00:05:24 +08:00
parent 0c3310d3a5
commit 646f68d298

View File

@ -5,11 +5,7 @@ import { Repository } from 'typeorm';
import { CreatePipelineTaskInput } from './dtos/create-pipeline-task.input'; import { CreatePipelineTaskInput } from './dtos/create-pipeline-task.input';
import { Pipeline } from '../pipelines/pipeline.entity'; import { Pipeline } from '../pipelines/pipeline.entity';
import debug from 'debug'; import debug from 'debug';
import { import { AmqpConnection, RabbitRPC } from '@golevelup/nestjs-rabbitmq';
AmqpConnection,
RabbitRPC,
RabbitSubscribe,
} from '@golevelup/nestjs-rabbitmq';
import { import {
EXCHANGE_PIPELINE_TASK_FANOUT, EXCHANGE_PIPELINE_TASK_FANOUT,
QUEUE_PIPELINE_TASK_DONE, QUEUE_PIPELINE_TASK_DONE,