Function printExecutedAction

cli/console.ts:323–478

(
  executedAction: dataform.IActionResult,
  executionAction: dataform.IExecutionAction,
  dryRun?: boolean
)

}

export function printExecutedAction(
  executedAction: dataform.IActionResult,
  executionAction: dataform.IExecutionAction,
  dryRun?: boolean
) {
  const jobIds = executedAction.tasks
    .filter(task => task.metadata?.bigquery?.jobId)
    .map(task => task.metadata.bigquery.jobId);
  const bytesBilled = executedAction.tasks
    .filter(task => task.metadata?.bigquery?.jobId)
    .map(task => {
        const bytes = task.metadata.bigquery?.totalBytesBilled?.toNumber?.() ?? 0;
        return formatBytesInHumanReadableFormat(bytes);
    });

  const executionSuffix = formatExecutionSuffix(jobIds, bytesBilled);

  switch (executedAction.status) {
    case dataform.ActionResult.ExecutionStatus.SUCCESSFUL: {
      switch (executionAction.type) {
        case "table": {
          writeStdOut(
            `${successOutput(`Table ${dryRun ? "dry run success" : "created"}: `)} ${datasetString(
              executionAction.target,
              executionAction.tableType,
              executionAction.tasks.length === 0
            )}${executionSuffix}`
          );
          return;
        }
        case "assertion": {
          writeStdOut(
            `${successOutput(
              `Assertion ${dryRun ? "dry run success" : "passed"}: `
            )} ${assertionString(
              executionAction.target,
              executionAction.tasks.length === 0
            )}${executionSuffix}`
          );
          return;
        }
        case "operation": {
          writeStdOut(
            `${successOutput(
              `Operation ${dryRun ? "dry run success" : "completed successfully"}: `
            )} ${operationString(
              executionAction.target,
              executionAction.tasks.length === 0
            )}${executionSuffix}`
          );
          return;
        }
      }
    }
    case dataform.ActionResult.ExecutionStatus.FAILED: {
      switch (executionAction.type) {
        case "table": {
          writeStdErr(