DOP-4549 return early

api/controllers/v1/slack.ts

@@ -235,9 +235,19 @@ export const DeployRepo = async (event: any = {}): Promise<any> => {
   }
   const deployable = await getDeployableJobs(values, entitlement, repoBranchesRepository, docsetsRepository);
   console.log(JSON.stringify(deployable));
+  return {
+    statusCode: 200,
+    headers: { 'Content-Type': 'application/json' },
+    body: 'success!',
+  };
   if (deployable.length > 0) {
     await deployRepo(deployable, consoleLogger, jobRepository, c.get('jobsQueueUrl'));
     console.log('Repos have been deployed');
+    return {
+      statusCode: 200,
+      headers: { 'Content-Type': 'application/json' },
+      body: 'success!',
+    };
   }
   return {
     statusCode: 200,

src/repositories/jobRepository.ts

@@ -69,7 +69,10 @@ export class JobRepository extends BaseRepository {
       throw new DBError('insertBulkJobs: Unable to insert multiple jobs');
     }
     // Insertion/re-enqueueing should be sent to jobs queue and updates for an existing job should be sent to jobUpdates Queue
-    this._logger.info('insertBulkJobs', `Total Jobs Expected : ${jobs.length}, Total Jobs Sent: ${jobIds.length}`);
+    this._logger.info(
+      'insertBulkJobs',
+      `Total Jobs Expected : ${jobs.length}, Jobs: ${JSON.stringify(jobIds)}, Total Jobs Sent: ${jobIds.length}`
+    );
     await Promise.all(
       Object.values(jobIds).map(async (jobId: string) => {
         await this._queueConnector.sendMessage(new JobQueueMessage(jobId, JobStatus.inQueue), url, 0);