Function postInsertAll

apps/sim/lib/data-drains/destinations/bigquery.ts:105–131

(
  input: InsertAllInput,
  url: string,
  body: string,
  forceRefresh = false
)

}

async function postInsertAll(
  input: InsertAllInput,
  url: string,
  body: string,
  forceRefresh = false
): Promise<Response> {
  const token = await getAccessToken(input.jwt, forceRefresh)
  const perAttempt = AbortSignal.any([input.signal, AbortSignal.timeout(PER_ATTEMPT_TIMEOUT_MS)])
  try {
    return await fetch(url, {
      method: 'POST',
      headers: {
        Authorization: `Bearer ${token}`,
        'Content-Type': 'application/json',
        'User-Agent': USER_AGENT,
      },
      body,
      signal: perAttempt,
    })
  } catch (error) {
    logger.warn('BigQuery request failed', {
      table: `${input.config.projectId}.${input.config.datasetId}.${input.config.tableId}`,
      error: toError(error).message,
    })
    throw error
  }
}

/**
 * Builds a stable `insertId` for best-effort dedup (~60s window). Prefixed