diff --git a/src/pipeline-tasks/pipeline-tasks.service.ts b/src/pipeline-tasks/pipeline-tasks.service.ts index fdc1aa2..d38125e 100644 --- a/src/pipeline-tasks/pipeline-tasks.service.ts +++ b/src/pipeline-tasks/pipeline-tasks.service.ts @@ -5,11 +5,7 @@ import { Repository } from 'typeorm'; import { CreatePipelineTaskInput } from './dtos/create-pipeline-task.input'; import { Pipeline } from '../pipelines/pipeline.entity'; import debug from 'debug'; -import { - AmqpConnection, - RabbitRPC, - RabbitSubscribe, -} from '@golevelup/nestjs-rabbitmq'; +import { AmqpConnection, RabbitRPC } from '@golevelup/nestjs-rabbitmq'; import { EXCHANGE_PIPELINE_TASK_FANOUT, QUEUE_PIPELINE_TASK_DONE,