Function printExecutionGraph

cli/console.ts:279–321

(executionGraph: dataform.ExecutionGraph, asJson: boolean)

}

export function printExecutionGraph(executionGraph: dataform.ExecutionGraph, asJson: boolean) {
  if (asJson) {
    writeStdOut(prettyJsonStringify(executionGraph.toJSON()));
  } else {
    const actionsByType = {
      table: [] as dataform.IExecutionAction[],
      assertion: [] as dataform.IExecutionAction[],
      operation: [] as dataform.IExecutionAction[]
    };
    executionGraph.actions.forEach(action => {
      if (
        !(action.type === "table" || action.type === "assertion" || action.type === "operation")
      ) {
        throw new Error(`Unrecognized action type: ${action.type}`);
      }
      actionsByType[action.type].push(action);
    });
    const datasetActions = actionsByType.table;
    if (datasetActions && datasetActions.length) {
      writeStdOut(`${datasetActions.length} dataset(s):`);
      datasetActions.forEach(datasetAction =>
        writeStdOut(
          datasetString(datasetAction.target, datasetAction.type, datasetAction.tasks.length === 0),
          1
        )
      );
    }
    const assertionActions = actionsByType.assertion;
    if (assertionActions && assertionActions.length) {
      writeStdOut(`${assertionActions.length} assertion(s):`);
      assertionActions.forEach(assertionAction =>
        writeStdOut(assertionString(assertionAction.target, assertionAction.tasks.length === 0), 1)
      );
    }
    const operationActions = actionsByType.operation;
    if (operationActions && operationActions.length) {
      writeStdOut(`${operationActions.length} operation(s):`);
      operationActions.forEach(operationAction =>
        writeStdOut(operationString(operationAction.target, operationAction.tasks.length === 0), 1)
      );
    }
  }
}

export function printExecutedAction(
  executedAction: dataform.IActionResult,