feat(core): run createDependencies plugins concurrently

packages/nx/src/project-graph/build-project-graph.ts

@@ -210,10 +210,12 @@ function createContext(
 }
 
 async function updateProjectGraphWithPlugins(
-  context: ProjectGraphProcessorContext,
+  projectGraphProcessorContext: ProjectGraphProcessorContext,
   initProjectGraph: ProjectGraph
 ) {
-  const plugins = await loadNxPlugins(context.nxJsonConfiguration?.plugins);
+  const plugins = await loadNxPlugins(
+    projectGraphProcessorContext.nxJsonConfiguration?.plugins
+  );
   let graph = initProjectGraph;
   for (const plugin of plugins) {
     try {
@@ -229,7 +231,10 @@ async function updateProjectGraphWithPlugins(
         //     'Nx has recently released a v2 model for project graph plugins. The `processProjectGraph` method is deprecated. Plugins should use some combination of `createNodes` and `createDependencies` instead.',
         //   ],
         // });
-        graph = await plugin.processProjectGraph(graph, context);
+        graph = await plugin.processProjectGraph(
+          graph,
+          projectGraphProcessorContext
+        );
       }
     } catch (e) {
       let message = `Failed to process the project graph with "${plugin.name}".`;
@@ -240,40 +245,48 @@ async function updateProjectGraphWithPlugins(
       throw new Error(message);
     }
   }
-  for (const plugin of plugins) {
-    try {
-      if (isNxPluginV2(plugin) && plugin.createDependencies) {
-        const builder = new ProjectGraphBuilder(graph, context.fileMap);
-        const newDependencies = await plugin.createDependencies({
-          externalNodes: graph.externalNodes,
-          fileMap: context.fileMap,
-          filesToProcess: context.filesToProcess,
-          nxJsonConfiguration: context.nxJsonConfiguration,
-          projects: context.projectsConfigurations.projects,
-          workspaceRoot: workspaceRoot,
+
+  const createDependencyPlugins = plugins.filter(
+    (plugin) => isNxPluginV2(plugin) && plugin.createDependencies
+  );
+  const createDependenciesContext = {
+    externalNodes: graph.externalNodes,
+    fileMap: projectGraphProcessorContext.fileMap,
+    filesToProcess: projectGraphProcessorContext.filesToProcess,
+    nxJsonConfiguration: projectGraphProcessorContext.nxJsonConfiguration,
+    projects: projectGraphProcessorContext.projectsConfigurations.projects,
+    workspaceRoot: workspaceRoot,
+  };
+  const builder = new ProjectGraphBuilder(
+    graph,
+    projectGraphProcessorContext.fileMap
+  );
+  await Promise.all(
+    createDependencyPlugins.map(async (plugin) => {
+      try {
+        const dependencies = await plugin.createDependencies({
+          ...createDependenciesContext,
         });
-        for (const targetProjectDependency of newDependencies) {
+
+        for (const dep of dependencies) {
           builder.addDependency(
-            targetProjectDependency.source,
-            targetProjectDependency.target,
-            targetProjectDependency.type,
-            'sourceFile' in targetProjectDependency
-              ? targetProjectDependency.sourceFile
-              : null
+            dep.source,
+            dep.target,
+            dep.type,
+            'sourceFile' in dep ? dep.sourceFile : null
           );
         }
-        graph = builder.getUpdatedProjectGraph();
-      }
-    } catch (e) {
-      let message = `Failed to process project dependencies with "${plugin.name}".`;
-      if (e instanceof Error) {
-        e.message = message + '\n' + e.message;
-        throw e;
+      } catch (e) {
+        let message = `Failed to process project dependencies with "${plugin.name}".`;
+        if (e instanceof Error) {
+          e.message = message + '\n' + e.message;
+          throw e;
+        }
+        throw new Error(message);
       }
-      throw new Error(message);
-    }
-  }
-  return graph;
+    })
+  );
+  return builder.getUpdatedProjectGraph();
 }
 
 function readRootTsConfig() {