src/pipeline-tasks/pipeline-tasks.module.ts

@@ -19,9 +19,12 @@ import { PubSub } from 'apollo-server-express';
 @Module({
   imports: [
     TypeOrmModule.forFeature([PipelineTask, Pipeline]),
-    BullModule.registerQueue({
+    BullModule.registerQueue(
-      name: PIPELINE_TASK_QUEUE,
+      {
-    }),
+        name: PIPELINE_TASK_QUEUE,
+      },
+      { name: PIPELINE_TASK_LOG_QUEUE },
+    ),
     RedisModule,
     ReposModule,
   ],

src/pipeline-tasks/pipeline-tasks.service.spec.ts

@@ -32,7 +32,6 @@ describe('PipelineTasksService', () => {
     ({
       pipelineId: 'test',
       commit: 'test',
-      pipeline: { branch: 'master' },
       units: [],
     } as PipelineTask);
 
@@ -80,7 +79,6 @@ describe('PipelineTasksService', () => {
     jest
       .spyOn(taskRepository, 'create')
       .mockImplementation((data: any) => data);
-    jest.spyOn(taskRepository, 'findOne').mockImplementation(async () => null);
   });
 
   it('should be defined', () => {
@@ -105,7 +103,6 @@ describe('PipelineTasksService', () => {
       const save = jest
         .spyOn(taskRepository, 'save')
         .mockImplementation(async (data: any) => data);
-      const findOne = jest.spyOn(taskRepository, 'findOne');
       jest
         .spyOn(service, 'doNextTask')
         .mockImplementation(async () => undefined);
@@ -115,7 +112,6 @@ describe('PipelineTasksService', () => {
           commit: 'test',
           units: [],
         });
-      expect(findOne).toBeCalled();
     });
     it('add task', async () => {
       const lpush = jest.spyOn(redisClient, 'lpush');