feat(backoff): added ability to configure number of retries and starting backoff

Author: rycerrat

source/packages/@aws-accelerator/utils/lib/throttle.ts

@@ -13,6 +13,9 @@
 
 import { backOff, IBackOffOptions } from 'exponential-backoff';
 
+const startingDelay = Number(process.env['STARTING_DELAY'] ?? 150);
+const numberOfRetries = Number(process.env['NUMBER_OF_RETRIES'] ?? 12);
+
 /**
  * Auxiliary function to retry AWS SDK calls when a throttling error occurs.
  */
@@ -21,8 +24,8 @@ export function throttlingBackOff<T>(
   options?: Partial<Omit<IBackOffOptions, 'retry'>>,
 ): Promise<T> {
   return backOff(request, {
-    startingDelay: 150,
-    numOfAttempts: 7,
+    startingDelay,
+    numOfAttempts: numberOfRetries,
     jitter: 'full',
     retry: isThrottlingError,
     ...options,
@@ -32,45 +35,47 @@ export function throttlingBackOff<T>(
 export const isThrottlingError = (
   // eslint-disable-next-line @typescript-eslint/no-explicit-any,@typescript-eslint/explicit-module-boundary-types
   e: any,
-): boolean =>
-  e.retryable === true ||
-  // SDKv2 Error Structure
-  e.code === 'ConcurrentModificationException' || // Retry for AWS Organizations
-  e.code === 'InsufficientDeliveryPolicyException' || // Retry for ConfigService
-  e.code === 'NoAvailableDeliveryChannelException' || // Retry for ConfigService
-  e.code === 'ConcurrentModifications' || // Retry for AssociateHostedZone
-  e.code === 'LimitExceededException' || // Retry for SecurityHub
-  e.code === 'OperationNotPermittedException' || // Retry for RAM
-  e.code === 'InvalidStateException' || //retry for ServiceCatalog
-  e.code === 'TooManyRequestsException' ||
-  e.code === 'TooManyUpdates' ||
-  e.code === 'Throttling' ||
-  e.code === 'ThrottlingException' ||
-  e.code === 'InternalErrorException' ||
-  e.code === 'InternalException' ||
-  e.code === 'ECONNRESET' ||
-  e.code === 'ENOTFOUND' ||
-  e.code === 'EPIPE' ||
-  e.code === 'ETIMEDOUT' ||
-  // SDKv3 Error Structure
-  e.name === 'ConcurrentModificationException' || // Retry for AWS Organizations
-  e.name === 'InsufficientDeliveryPolicyException' || // Retry for ConfigService
-  e.name === 'NoAvailableDeliveryChannelException' || // Retry for ConfigService
-  e.name === 'ConcurrentModifications' || // Retry for AssociateHostedZone
-  e.name === 'LimitExceededException' || // Retry for SecurityHub
-  e.name === 'OperationNotPermittedException' || // Retry for RAM
-  e.name === 'CredentialsProviderError' || // Retry for STS
-  e.name === 'TooManyRequestsException' ||
-  e.name === 'TooManyUpdates' ||
-  e.name === 'Throttling' ||
-  e.name === 'ThrottlingException' ||
-  e.name === 'InternalErrorException' ||
-  e.name === 'InternalException' ||
-  e.name === 'ECONNRESET' ||
-  e.name === 'EPIPE' ||
-  e.name === 'ENOTFOUND' ||
-  e.name === 'ETIMEDOUT';
-
+): boolean => {
+  return (
+    e.retryable === true ||
+    // SDKv2 Error Structure
+    e.code === 'ConcurrentModificationException' || // Retry for AWS Organizations
+    e.code === 'InsufficientDeliveryPolicyException' || // Retry for ConfigService
+    e.code === 'NoAvailableDeliveryChannelException' || // Retry for ConfigService
+    e.code === 'ConcurrentModifications' || // Retry for AssociateHostedZone
+    e.code === 'LimitExceededException' || // Retry for SecurityHub
+    e.code === 'OperationNotPermittedException' || // Retry for RAM
+    e.code === 'InvalidStateException' || //retry for ServiceCatalog
+    e.code === 'TooManyRequestsException' ||
+    e.code === 'TooManyUpdates' ||
+    e.code === 'Throttling' ||
+    e.code === 'ThrottlingException' ||
+    e.code === 'InternalErrorException' ||
+    e.code === 'InternalException' ||
+    e.code === 'ECONNRESET' ||
+    e.code === 'ENOTFOUND' ||
+    e.code === 'EPIPE' ||
+    e.code === 'ETIMEDOUT' ||
+    // SDKv3 Error Structure
+    e.name === 'ConcurrentModificationException' || // Retry for AWS Organizations
+    e.name === 'InsufficientDeliveryPolicyException' || // Retry for ConfigService
+    e.name === 'NoAvailableDeliveryChannelException' || // Retry for ConfigService
+    e.name === 'ConcurrentModifications' || // Retry for AssociateHostedZone
+    e.name === 'LimitExceededException' || // Retry for SecurityHub
+    e.name === 'OperationNotPermittedException' || // Retry for RAM
+    e.name === 'CredentialsProviderError' || // Retry for STS
+    e.name === 'TooManyRequestsException' ||
+    e.name === 'TooManyUpdates' ||
+    e.name === 'Throttling' ||
+    e.name === 'ThrottlingException' ||
+    e.name === 'InternalErrorException' ||
+    e.name === 'InternalException' ||
+    e.name === 'ECONNRESET' ||
+    e.name === 'EPIPE' ||
+    e.name === 'ENOTFOUND' ||
+    e.name === 'ETIMEDOUT'
+  );
+};
 // eslint-disable-next-line @typescript-eslint/no-explicit-any
 export async function delay(ms: number): Promise<any> {
   return new Promise(resolve => setTimeout(resolve, ms));