Function gcpRetryCall

tests/functional/raw-node/utils/gcpUtils.js:17–44

(callFn, retryOptions)

    err && (err.name === 'SlowDown' || err.$metadata?.httpStatusCode === 429);

async function gcpRetryCall(callFn, retryOptions) {
    const {
        // 6 attempts with exponential backoff gives up to ~63s of total wait.
        maxAttempts = 6,
        shouldRetry = defaultShouldRetry,
        getDelayMs = attempt => Math.pow(2, attempt) * 1000,
    } = retryOptions || {};

    let lastError;
    for (let attempt = 0; attempt < maxAttempts; attempt++) {
        try {
            return await callFn();
        } catch (err) {
            lastError = err;
            if (!shouldRetry(err, attempt) || attempt === maxAttempts - 1) {
                throw err;
            }
            const delay = getDelayMs(attempt);
            process.stdout.write(
                'Retryable error from GCP, retrying in ' +
                `${delay}ms (attempt ${attempt + 1}): ${err}\n`);
             
            await new Promise(resolve => setTimeout(resolve, delay));
        }
    }

    throw lastError;
}

async function gcpRetry(gcpClient, command, retryOptions, cb) {
    if (cb) {