From d7dad72fdbd414175b5c86ab9ca836923016b846 Mon Sep 17 00:00:00 2001
From: Hao Luo <howlowck@gmail.com>
Date: Thu, 13 Oct 2022 16:55:36 -0500
Subject: [PATCH] implemented that only claim new tasks if queue is empty

Signed-off-by: Hao Luo <howlowck@gmail.com>
---
 plugins/scaffolder-backend/src/scaffolder/tasks/TaskWorker.ts | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/plugins/scaffolder-backend/src/scaffolder/tasks/TaskWorker.ts b/plugins/scaffolder-backend/src/scaffolder/tasks/TaskWorker.ts
index 799510b278..1dc8d01aad 100644
--- a/plugins/scaffolder-backend/src/scaffolder/tasks/TaskWorker.ts
+++ b/plugins/scaffolder-backend/src/scaffolder/tasks/TaskWorker.ts
@@ -75,7 +75,7 @@ export class TaskWorker {
       integrations,
       workingDirectory,
       additionalTemplateFilters,
-      concurrentTasksLimit = 10, // Or Infinity
+      concurrentTasksLimit = 2, // Or Infinity
       additionalTemplateGlobals,
     } = options;
 
@@ -98,6 +98,7 @@ export class TaskWorker {
   start() {
     (async () => {
       for (;;) {
+        await this.taskQueue.onEmpty();
         const task = await this.options.taskBroker.claim();
         this.taskQueue.add(() => this.runOneTask(task));
       }