Method createQueryJob

cli/api/dbadapters/bigquery.ts:401–509

(
    query: string,
    params?: { [name: string]: any },
    rowLimit?: number,
    byteLimit?: number,
    onCancel?: OnCancel,
    labels?: { [label: string]: string },
    location?: string,
    jobPrefix?: string,
    dryRun?: boolean,
    reservation?: string
  )

  }

  private async createQueryJob(
    query: string,
    params?: { [name: string]: any },
    rowLimit?: number,
    byteLimit?: number,
    onCancel?: OnCancel,
    labels?: { [label: string]: string },
    location?: string,
    jobPrefix?: string,
    dryRun?: boolean,
    reservation?: string
  ): Promise<IExecutionResult> {
    let isCancelled = false;
    onCancel?.(() => (isCancelled = true));

    return retry(
      async () => {
        try {
          const job = await this.getClient().createQueryJob(
            this.prepareQueryOptions(
              query,
              rowLimit,
              {
                labels,
                location,
                jobPrefix,
                dryRun,
                reservation
              },
              params
            ) as any
          );
          const resultStream = job[0].getQueryResultsStream();
          return new Promise<IExecutionResult>((resolve, reject) => {
            if (isCancelled) {
              resultStream.end();
              reject(new Error("Query cancelled."));
              return;
            }
            onCancel?.(() => {
              resultStream.end();
              reject(new Error("Query cancelled."));
            });

            const results = new LimitedResultSet({
              rowLimit,
              byteLimit
            });
            resultStream
              .on("error", async (e: IBigQueryError) => {
                // Dry run queries against BigQuery done by this package eagerly fail with
                // "Not found: job". This is a workaround to avoid that.
                // Example: https://github.com/googleapis/python-bigquery/issues/118.
                if (dryRun && e.message?.includes("Not found: Job")) {
                  resolve({ rows: [], metadata: {} });
                  return;
                }