chore(core): refactor executors to always read from cached project graph (#6446)

Author: JamesHenry

packages/angular/src/builders/webpack-browser/webpack-browser.impl.ts

@@ -13,7 +13,7 @@ import {
 } from '@nrwl/workspace/src/utils/buildable-libs-utils';
 import { joinPathFragments } from '@nrwl/devkit';
 import { join } from 'path';
-import { createProjectGraphAsync } from '@nrwl/workspace/src/core/project-graph';
+import { readCachedProjectGraph } from '@nrwl/workspace/src/core/project-graph';
 import { Schema } from '@angular-devkit/build-angular/src/browser/schema';
 import { switchMap } from 'rxjs/operators';
 import { existsSync } from 'fs';
@@ -80,32 +80,26 @@ function run(
   options: BrowserBuilderSchema,
   context: BuilderContext
 ): Observable<BuilderOutput> {
-  return from(createProjectGraphAsync()).pipe(
-    switchMap((projGraph) => {
-      const { target, dependencies } = calculateProjectDependencies(
-        projGraph,
-        context
-      );
+  const { target, dependencies } = calculateProjectDependencies(
+    readCachedProjectGraph(),
+    context
+  );
 
-      options.tsConfig = createTmpTsConfig(
-        join(context.workspaceRoot, options.tsConfig),
-        context.workspaceRoot,
-        target.data.root,
-        dependencies
-      );
+  options.tsConfig = createTmpTsConfig(
+    join(context.workspaceRoot, options.tsConfig),
+    context.workspaceRoot,
+    target.data.root,
+    dependencies
+  );
 
-      return of(
-        checkDependentProjectsHaveBeenBuilt(context, dependencies)
-      ).pipe(
-        switchMap((result) => {
-          if (result) {
-            return buildApp(options, context);
-          } else {
-            // just pass on the result
-            return of({ success: false });
-          }
-        })
-      );
+  return of(checkDependentProjectsHaveBeenBuilt(context, dependencies)).pipe(
+    switchMap((result) => {
+      if (result) {
+        return buildApp(options, context);
+      } else {
+        // just pass on the result
+        return of({ success: false });
+      }
     })
   );
 }

packages/angular/src/executors/delegate-build/delegate-build.impl.ts

@@ -4,7 +4,7 @@ import {
   parseTargetString,
   runExecutor,
 } from '@nrwl/devkit';
-import { createProjectGraphAsync } from '@nrwl/workspace/src/core/project-graph';
+import { readCachedProjectGraph } from '@nrwl/workspace/src/core/project-graph';
 import {
   calculateProjectDependencies,
   checkDependentProjectsHaveBeenBuilt,
@@ -16,10 +16,8 @@ export async function* delegateBuildExecutor(
   options: DelegateBuildExecutorSchema,
   context: ExecutorContext
 ) {
-  const projGraph = await createProjectGraphAsync();
-
   const { target, dependencies } = calculateProjectDependencies(
-    projGraph,
+    readCachedProjectGraph(),
     context.root,
     context.projectName,
     context.targetName,

packages/angular/src/executors/package/package.impl.ts

@@ -1,6 +1,6 @@
 import * as ng from '@angular/compiler-cli';
 import type { ExecutorContext } from '@nrwl/devkit';
-import { createProjectGraphAsync } from '@nrwl/workspace/src/core/project-graph';
+import { readCachedProjectGraph } from '@nrwl/workspace/src/core/project-graph';
 import type { DependentBuildableProjectNode } from '@nrwl/workspace/src/utilities/buildable-libs-utils';
 import {
   calculateProjectDependencies,
@@ -50,9 +50,8 @@ export function createLibraryExecutor(
     options: BuildAngularLibraryExecutorOptions,
     context: ExecutorContext
   ) {
-    const projGraph = await createProjectGraphAsync();
     const { target, dependencies } = calculateProjectDependencies(
-      projGraph,
+      readCachedProjectGraph(),
       context.root,
       context.projectName,
       context.targetName,

packages/next/src/executors/build/build.impl.ts

@@ -11,7 +11,7 @@ import { NextBuildBuilderOptions } from '../../utils/types';
 import { createPackageJson } from './lib/create-package-json';
 import { createNextConfigFile } from './lib/create-next-config-file';
 import { directoryExists } from '@nrwl/workspace/src/utilities/fileutils';
-import { createProjectGraphAsync } from '@nrwl/workspace/src/core/project-graph';
+import { readCachedProjectGraph } from '@nrwl/workspace/src/core/project-graph';
 import {
   calculateProjectDependencies,
   DependentBuildableProjectNode,
@@ -32,9 +32,8 @@ export default async function buildExecutor(
   const root = resolve(context.root, options.root);
 
   if (!options.buildLibsFromSource && context.targetName) {
-    const projGraph = await createProjectGraphAsync();
     const result = calculateProjectDependencies(
-      projGraph,
+      readCachedProjectGraph(),
       context.root,
       context.projectName,
       context.targetName,

packages/next/src/executors/build/lib/create-package-json.ts

@@ -1,6 +1,6 @@
 import { ExecutorContext } from '@nrwl/devkit';
 
-import { createProjectGraphAsync } from '@nrwl/workspace/src/core/project-graph';
+import { readCachedProjectGraph } from '@nrwl/workspace/src/core/project-graph';
 import { writeJsonFile } from '@nrwl/workspace/src/utilities/fileutils';
 import { createPackageJson as generatePackageJson } from '@nrwl/workspace/src/utilities/create-package-json';
 
@@ -10,7 +10,7 @@ export async function createPackageJson(
   options: NextBuildBuilderOptions,
   context: ExecutorContext
 ) {
-  const depGraph = await createProjectGraphAsync();
+  const depGraph = readCachedProjectGraph();
   const packageJson = generatePackageJson(context.projectName, depGraph, {
     root: context.root,
     projectRoot: context.workspace.projects[context.projectName].sourceRoot,

packages/next/src/executors/export/export.impl.ts

@@ -12,7 +12,7 @@ import {
   NextBuildBuilderOptions,
   NextExportBuilderOptions,
 } from '../../utils/types';
-import { createProjectGraphAsync } from '@nrwl/workspace/src/core/project-graph';
+import { readCachedProjectGraph } from '@nrwl/workspace/src/core/project-graph';
 import {
   calculateProjectDependencies,
   DependentBuildableProjectNode,
@@ -29,9 +29,8 @@ export default async function exportExecutor(
 ) {
   let dependencies: DependentBuildableProjectNode[] = [];
   if (!options.buildLibsFromSource) {
-    const projGraph = await createProjectGraphAsync();
     const result = calculateProjectDependencies(
-      projGraph,
+      readCachedProjectGraph(),
       context.root,
       context.projectName,
       'build', // this should be generalized

packages/next/src/executors/server/server.impl.ts

@@ -23,7 +23,7 @@ import {
 } from '../../utils/types';
 import { customServer } from './lib/custom-server';
 import { defaultServer } from './lib/default-server';
-import { createProjectGraphAsync } from '@nrwl/workspace/src/core/project-graph';
+import { readCachedProjectGraph } from '@nrwl/workspace/src/core/project-graph';
 import {
   calculateProjectDependencies,
   DependentBuildableProjectNode,
@@ -56,9 +56,8 @@ export default async function* serveExecutor(
 
   const root = resolve(context.root, buildOptions.root);
   if (!options.buildLibsFromSource) {
-    const projGraph = await createProjectGraphAsync();
     const result = calculateProjectDependencies(
-      projGraph,
+      readCachedProjectGraph(),
       context.root,
       context.projectName,
       'build', // should be generalized

packages/node/src/executors/build/build.impl.spec.ts

@@ -17,8 +17,8 @@ describe('Node Build Executor', () => {
 
   beforeEach(async () => {
     jest
-      .spyOn(projectGraph, 'createProjectGraphAsync')
-      .mockReturnValue(Promise.resolve({} as ProjectGraph));
+      .spyOn(projectGraph, 'readCachedProjectGraph')
+      .mockReturnValue({} as ProjectGraph);
 
     (<any>runWebpack).mockReturnValue(of({ hasErrors: () => false }));
     context = {

packages/node/src/executors/build/build.impl.ts

@@ -1,6 +1,6 @@
 import { ExecutorContext } from '@nrwl/devkit';
 
-import { createProjectGraphAsync } from '@nrwl/workspace/src/core/project-graph';
+import { readCachedProjectGraph } from '@nrwl/workspace/src/core/project-graph';
 import {
   calculateProjectDependencies,
   checkDependentProjectsHaveBeenBuilt,
@@ -48,7 +48,7 @@ export async function* buildExecutor(
     sourceRoot,
     root
   );
-  const projGraph = await createProjectGraphAsync();
+  const projGraph = readCachedProjectGraph();
   if (!options.buildLibsFromSource) {
     const { target, dependencies } = calculateProjectDependencies(
       projGraph,

packages/node/src/executors/package/package.impl.spec.ts

@@ -89,8 +89,8 @@ describe('NodePackageBuilder', () => {
   describe('Without library dependencies', () => {
     beforeEach(() => {
       jest
-        .spyOn(projectGraph, 'createProjectGraphAsync')
-        .mockImplementation(async () => {
+        .spyOn(projectGraph, 'readCachedProjectGraph')
+        .mockImplementation(() => {
           return {
             nodes: {
               nodelib: {
@@ -263,8 +263,8 @@ describe('NodePackageBuilder', () => {
     beforeEach(() => {
       // fake that dep project has been built
       jest
-        .spyOn(projectGraph, 'createProjectGraphAsync')
-        .mockImplementation(async () => {
+        .spyOn(projectGraph, 'readCachedProjectGraph')
+        .mockImplementation(() => {
           return {
             nodes: {
               nodelib: {