function startQueryExecution(queryString, connection = {}) {
  const athenaClient = newAthenaClient(connection);

  // Check to see if a custom maxrows is set, otherwise use default
  const maxRows = resolvePositiveNumber(
    connection.maxrows_override,
    connection.maxRows
  );
  const maxRowsPlusOne = maxRows + 1;
  const limitedQuery = sqlLimiter.limit(queryString, ['limit'], maxRowsPlusOne);

  appLog.trace(limitedQuery);
  return athenaClient
    .query({ sql: limitedQuery })
    .then((results) => {
      return results.QueryExecutionId;
    })
    .catch((error) => {
      appLog.error(`Error found ${error}`);
      throw error;
    });
}
Run query for connection and return execution ID to enable query cancellation
Should return execution ID
@param {string} queryString
@param {object} connection