reverted back to multiple TaskWorkers

Signed-off-by: Hao Luo <howlowck@gmail.com>
2022-10-13 16:50:56 -05:00
parent cbb618c669
commit 86de58739d
1 changed files with 15 additions and 11 deletions
@@ -201,6 +201,20 @@ export async function createRouter(

  const actionRegistry = new TemplateActionRegistry();

+  const workers = [];
+  for (let i = 0; i < (taskWorkers || 1); i++) {
+    const worker = await TaskWorker.create({
+      taskBroker,
+      actionRegistry,
+      integrations,
+      logger,
+      workingDirectory,
+      additionalTemplateFilters,
+      additionalTemplateGlobals,
+    });
+    workers.push(worker);
+  }
+
  const actionsToRegister = Array.isArray(actions)
    ? actions
    : createBuiltinActions({
@@ -213,17 +227,7 @@ export async function createRouter(
      });

  actionsToRegister.forEach(action => actionRegistry.register(action));
-
-  const worker = await TaskWorker.create({
-    taskBroker,
-    actionRegistry,
-    integrations,
-    logger,
-    workingDirectory,
-    additionalTemplateFilters,
-    additionalTemplateGlobals,
-  });
-  worker.start();
+  workers.forEach(worker => worker.start());

  const dryRunner = createDryRunner({
    actionRegistry,