Fix retries

- Calculate delay correctly
- Only retry when rate-limited
- Don't progress delays between retries

bin/templates/api.rb.erb

@@ -28,7 +28,7 @@ module Peddler
           <% method_args << "params:" if operation["query_params"]&.any? %>
 
           <% if operation["rate_limit"] %>
-            retriable(delay: proc { |i| <%= operation["rate_limit"] %> * i }).<%= http_method %>(<%= method_args.join(", ") %>)
+            retriable(delay: <%= 1 / operation["rate_limit"] %>, retry_statuses: [429]).<%= http_method %>(<%= method_args.join(", ") %>)
           <% else %>
             <%= http_method %>(<%= method_args.join(", ") %>)
           <% end %>

lib/peddler/api/amazon_warehousing_and_distribution_2024_05_09.rb

@@ -21,7 +21,7 @@ def get_inbound_shipment(shipment_id, sku_quantities: nil)
           "skuQuantities" => sku_quantities,
         }.compact
 
-        retriable(delay: proc { |i| 2.0 * i }).get(path, params:)
+        retriable(delay: 0.5, retry_statuses: [429]).get(path, params:)
       end
 
       # Retrieves a summary of all the inbound AWD shipments associated with a merchant, with the ability to apply
@@ -51,7 +51,7 @@ def list_inbound_shipments(sort_by: nil, sort_order: nil, shipment_status: nil,
           "nextToken" => next_token,
         }.compact
 
-        retriable(delay: proc { |i| 1.0 * i }).get(path, params:)
+        retriable(delay: 1.0, retry_statuses: [429]).get(path, params:)
       end
 
       # Lists AWD inventory associated with a merchant with the ability to apply optional filters.
@@ -73,7 +73,7 @@ def list_inventory(sku: nil, sort_order: nil, details: nil, next_token: nil, max
           "maxResults" => max_results,
         }.compact
 
-        retriable(delay: proc { |i| 2.0 * i }).get(path, params:)
+        retriable(delay: 0.5, retry_statuses: [429]).get(path, params:)
       end
     end
   end

lib/peddler/api/aplus_content_2020_11_01.rb

@@ -29,7 +29,7 @@ def search_content_documents(marketplace_id, page_token: nil)
           "pageToken" => page_token,
         }.compact
 
-        retriable(delay: proc { |i| 10.0 * i }).get(path, params:)
+        retriable(delay: 0.1, retry_statuses: [429]).get(path, params:)
       end
 
       # Creates a new A+ Content document.
@@ -44,7 +44,7 @@ def create_content_document(marketplace_id, post_content_document_request)
           "marketplaceId" => marketplace_id,
         }.compact
 
-        retriable(delay: proc { |i| 10.0 * i }).post(path, body:, params:)
+        retriable(delay: 0.1, retry_statuses: [429]).post(path, body:, params:)
       end
 
       # Returns an A+ Content document, if available.
@@ -62,7 +62,7 @@ def get_content_document(content_reference_key, marketplace_id, included_data_se
           "includedDataSet" => included_data_set,
         }.compact
 
-        retriable(delay: proc { |i| 10.0 * i }).get(path, params:)
+        retriable(delay: 0.1, retry_statuses: [429]).get(path, params:)
       end
 
       # Updates an existing A+ Content document.
@@ -80,7 +80,7 @@ def update_content_document(content_reference_key, marketplace_id, post_content_
           "marketplaceId" => marketplace_id,
         }.compact
 
-        retriable(delay: proc { |i| 10.0 * i }).post(path, body:, params:)
+        retriable(delay: 0.1, retry_statuses: [429]).post(path, body:, params:)
       end
 
       # Returns a list of ASINs related to the specified A+ Content document, if available. If you do not include the
@@ -109,7 +109,7 @@ def list_content_document_asin_relations(content_reference_key, marketplace_id,
           "pageToken" => page_token,
         }.compact
 
-        retriable(delay: proc { |i| 10.0 * i }).get(path, params:)
+        retriable(delay: 0.1, retry_statuses: [429]).get(path, params:)
       end
 
       # Replaces all ASINs related to the specified A+ Content document, if available. This may add or remove ASINs,
@@ -130,7 +130,7 @@ def post_content_document_asin_relations(content_reference_key, marketplace_id,
           "marketplaceId" => marketplace_id,
         }.compact
 
-        retriable(delay: proc { |i| 10.0 * i }).post(path, body:, params:)
+        retriable(delay: 0.1, retry_statuses: [429]).post(path, body:, params:)
       end
 
       # Checks if the A+ Content document is valid for use on a set of ASINs.
@@ -147,7 +147,7 @@ def validate_content_document_asin_relations(marketplace_id, post_content_docume
           "asinSet" => asin_set,
         }.compact
 
-        retriable(delay: proc { |i| 10.0 * i }).post(path, body:, params:)
+        retriable(delay: 0.1, retry_statuses: [429]).post(path, body:, params:)
       end
 
       # Searches for A+ Content publishing records, if available.
@@ -168,7 +168,7 @@ def search_content_publish_records(marketplace_id, asin, page_token: nil)
           "pageToken" => page_token,
         }.compact
 
-        retriable(delay: proc { |i| 10.0 * i }).get(path, params:)
+        retriable(delay: 0.1, retry_statuses: [429]).get(path, params:)
       end
 
       # Submits an A+ Content document for review, approval, and publishing.
@@ -184,7 +184,7 @@ def post_content_document_approval_submission(content_reference_key, marketplace
           "marketplaceId" => marketplace_id,
         }.compact
 
-        retriable(delay: proc { |i| 10.0 * i }).post(path, params:)
+        retriable(delay: 0.1, retry_statuses: [429]).post(path, params:)
       end
 
       # Submits a request to suspend visible A+ Content. This neither deletes the content document nor the ASIN
@@ -201,7 +201,7 @@ def post_content_document_suspend_submission(content_reference_key, marketplace_
           "marketplaceId" => marketplace_id,
         }.compact
 
-        retriable(delay: proc { |i| 10.0 * i }).post(path, params:)
+        retriable(delay: 0.1, retry_statuses: [429]).post(path, params:)
       end
     end
   end

lib/peddler/api/application_management_2023_11_30.rb

@@ -18,7 +18,7 @@ class ApplicationManagement20231130 < API
       def rotate_application_client_secret
         path = "/applications/2023-11-30/clientSecret"
 
-        retriable(delay: proc { |i| 0.0167 * i }).post(path)
+        retriable(delay: 59.880239520958085, retry_statuses: [429]).post(path)
       end
     end
   end

lib/peddler/api/catalog_items_2020_12_01.rb

@@ -42,7 +42,7 @@ def search_catalog_items(keywords, marketplace_ids, included_data: nil, brand_na
           "locale" => locale,
         }.compact
 
-        retriable(delay: proc { |i| 2.0 * i }).get(path, params:)
+        retriable(delay: 0.5, retry_statuses: [429]).get(path, params:)
       end
 
       # Retrieves details for an item in the Amazon catalog.
@@ -63,7 +63,7 @@ def get_catalog_item(asin, marketplace_ids, included_data: nil, locale: nil)
           "locale" => locale,
         }.compact
 
-        retriable(delay: proc { |i| 2.0 * i }).get(path, params:)
+        retriable(delay: 0.5, retry_statuses: [429]).get(path, params:)
       end
     end
   end

lib/peddler/api/catalog_items_2022_04_01.rb

@@ -55,7 +55,7 @@ def search_catalog_items(
           "keywordsLocale" => keywords_locale,
         }.compact
 
-        retriable(delay: proc { |i| 2.0 * i }).get(path, params:)
+        retriable(delay: 0.5, retry_statuses: [429]).get(path, params:)
       end
 
       # Retrieves details for an item in the Amazon catalog.
@@ -76,7 +76,7 @@ def get_catalog_item(asin, marketplace_ids, included_data: nil, locale: nil)
           "locale" => locale,
         }.compact
 
-        retriable(delay: proc { |i| 2.0 * i }).get(path, params:)
+        retriable(delay: 0.5, retry_statuses: [429]).get(path, params:)
       end
     end
   end

lib/peddler/api/catalog_items_v0.rb

@@ -83,7 +83,7 @@ def list_catalog_categories(marketplace_id, asin: nil, seller_sku: nil)
           "SellerSKU" => seller_sku,
         }.compact
 
-        retriable(delay: proc { |i| 1.0 * i }).get(path, params:)
+        retriable(delay: 1.0, retry_statuses: [429]).get(path, params:)
       end
     end
   end

lib/peddler/api/data_kiosk_2023_11_15.rb

@@ -35,7 +35,7 @@ def get_queries(processing_statuses: nil, page_size: nil, created_since: nil, cr
           "paginationToken" => pagination_token,
         }.compact
 
-        retriable(delay: proc { |i| 0.0222 * i }).get(path, params:)
+        retriable(delay: 45.04504504504504, retry_statuses: [429]).get(path, params:)
       end
 
       # Creates a Data Kiosk query request.
@@ -50,7 +50,7 @@ def create_query(body)
         path = "/dataKiosk/2023-11-15/queries"
         body = body
 
-        retriable(delay: proc { |i| 0.0167 * i }).post(path, body:)
+        retriable(delay: 59.880239520958085, retry_statuses: [429]).post(path, body:)
       end
 
       # Cancels the query specified by the `queryId` parameter. Only queries with a non-terminal `processingStatus`
@@ -64,7 +64,7 @@ def create_query(body)
       def cancel_query(query_id)
         path = "/dataKiosk/2023-11-15/queries/#{query_id}"
 
-        retriable(delay: proc { |i| 0.0222 * i }).delete(path)
+        retriable(delay: 45.04504504504504, retry_statuses: [429]).delete(path)
       end
 
       # Returns query details for the query specified by the `queryId` parameter. See the `createQuery` operation for
@@ -75,7 +75,7 @@ def cancel_query(query_id)
       def get_query(query_id)
         path = "/dataKiosk/2023-11-15/queries/##{query_id}"
 
-        retriable(delay: proc { |i| 2.0 * i }).get(path)
+        retriable(delay: 0.5, retry_statuses: [429]).get(path)
       end
 
       # Returns the information required for retrieving a Data Kiosk document's contents. See the `createQuery`
@@ -86,7 +86,7 @@ def get_query(query_id)
       def get_document(document_id)
         path = "/dataKiosk/2023-11-15/documents/#{document_id}"
 
-        retriable(delay: proc { |i| 0.0167 * i }).get(path)
+        retriable(delay: 59.880239520958085, retry_statuses: [429]).get(path)
       end
     end
   end

lib/peddler/api/easy_ship_2022_03_23.rb

@@ -25,7 +25,7 @@ def list_handover_slots(list_handover_slots_request: nil)
         path = "/easyShip/2022-03-23/timeSlot"
         body = list_handover_slots_request
 
-        retriable(delay: proc { |i| 1.0 * i }).post(path, body:)
+        retriable(delay: 1.0, retry_statuses: [429]).post(path, body:)
       end
 
       # Returns information about a package, including dimensions, weight, time slot information for handover, invoice
@@ -42,7 +42,7 @@ def get_scheduled_package(amazon_order_id, marketplace_id)
           "marketplaceId" => marketplace_id,
         }.compact
 
-        retriable(delay: proc { |i| 1.0 * i }).get(path, params:)
+        retriable(delay: 1.0, retry_statuses: [429]).get(path, params:)
       end
 
       # Schedules an Easy Ship order and returns the scheduled package information. This operation does the following: *
@@ -62,7 +62,7 @@ def create_scheduled_package(create_scheduled_package_request)
         path = "/easyShip/2022-03-23/package"
         body = create_scheduled_package_request
 
-        retriable(delay: proc { |i| 1.0 * i }).post(path, body:)
+        retriable(delay: 1.0, retry_statuses: [429]).post(path, body:)
       end
 
       # Updates the time slot for handing over the package indicated by the specified `scheduledPackageId`. You can get
@@ -77,7 +77,7 @@ def update_scheduled_packages(update_scheduled_packages_request: nil)
         path = "/easyShip/2022-03-23/package"
         body = update_scheduled_packages_request
 
-        retriable(delay: proc { |i| 1.0 * i }).patch(path, body:)
+        retriable(delay: 1.0, retry_statuses: [429]).patch(path, body:)
       end
 
       # This operation automatically schedules a time slot for all the `amazonOrderId`s given as input, generating the
@@ -101,7 +101,7 @@ def create_scheduled_package_bulk(create_scheduled_packages_request)
         path = "/easyShip/2022-03-23/packages/bulk"
         body = create_scheduled_packages_request
 
-        retriable(delay: proc { |i| 1.0 * i }).post(path, body:)
+        retriable(delay: 1.0, retry_statuses: [429]).post(path, body:)
       end
     end
   end

lib/peddler/api/fba_inbound_eligibility_v1.rb

@@ -29,7 +29,7 @@ def get_item_eligibility_preview(asin, program, marketplace_ids: nil)
           "program" => program,
         }.compact
 
-        retriable(delay: proc { |i| 1.0 * i }).get(path, params:)
+        retriable(delay: 1.0, retry_statuses: [429]).get(path, params:)
       end
     end
   end

lib/peddler/api/fba_inventory_v1.rb

@@ -55,7 +55,7 @@ def get_inventory_summaries(granularity_type, granularity_id, marketplace_ids, d
           "marketplaceIds" => marketplace_ids,
         }.compact
 
-        retriable(delay: proc { |i| 2.0 * i }).get(path, params:)
+        retriable(delay: 0.5, retry_statuses: [429]).get(path, params:)
       end
 
       # Requests that Amazon create product-details in the Sandbox Inventory in the sandbox environment. This is a

lib/peddler/api/feeds_2021_06_30.rb

@@ -39,7 +39,7 @@ def get_feeds(feed_types: nil, marketplace_ids: nil, page_size: nil, processing_
           "nextToken" => next_token,
         }.compact
 
-        retriable(delay: proc { |i| 0.0222 * i }).get(path, params:)
+        retriable(delay: 45.04504504504504, retry_statuses: [429]).get(path, params:)
       end
 
       # Creates a feed. Upload the contents of the feed document before calling this operation.
@@ -50,7 +50,7 @@ def create_feed(body)
         path = "/feeds/2021-06-30/feeds"
         body = body
 
-        retriable(delay: proc { |i| 0.0083 * i }).post(path, body:)
+        retriable(delay: 120.48192771084337, retry_statuses: [429]).post(path, body:)
       end
 
       # Cancels the feed that you specify. Only feeds with `processingStatus=IN_QUEUE` can be cancelled. Cancelled feeds
@@ -64,7 +64,7 @@ def create_feed(body)
       def cancel_feed(feed_id)
         path = "/feeds/2021-06-30/feeds/#{feed_id}"
 
-        retriable(delay: proc { |i| 2.0 * i }).delete(path)
+        retriable(delay: 0.5, retry_statuses: [429]).delete(path)
       end
 
       # Returns feed details (including the `resultDocumentId`, if available) for the feed that you specify.
@@ -75,7 +75,7 @@ def cancel_feed(feed_id)
       def get_feed(feed_id)
         path = "/feeds/2021-06-30/feeds/##{feed_id}"
 
-        retriable(delay: proc { |i| 2.0 * i }).get(path)
+        retriable(delay: 0.5, retry_statuses: [429]).get(path)
       end
 
       # Creates a feed document for the feed type that you specify. This operation returns a presigned URL for uploading
@@ -89,7 +89,7 @@ def create_feed_document(body)
         path = "/feeds/2021-06-30/documents"
         body = body
 
-        retriable(delay: proc { |i| 0.5 * i }).post(path, body:)
+        retriable(delay: 2.0, retry_statuses: [429]).post(path, body:)
       end
 
       # Returns the information required for retrieving a feed document's contents.
@@ -99,7 +99,7 @@ def create_feed_document(body)
       def get_feed_document(feed_document_id)
         path = "/feeds/2021-06-30/documents/#{feed_document_id}"
 
-        retriable(delay: proc { |i| 0.0222 * i }).get(path)
+        retriable(delay: 45.04504504504504, retry_statuses: [429]).get(path)
       end
     end
   end

lib/peddler/api/finances_v0.rb

@@ -36,7 +36,7 @@ def list_financial_event_groups(max_results_per_page: nil, financial_event_group
           "NextToken" => next_token,
         }.compact
 
-        retriable(delay: proc { |i| 0.5 * i }).get(path, params:)
+        retriable(delay: 2.0, retry_statuses: [429]).get(path, params:)
       end
 
       # Returns all financial events for the specified financial event group. It may take up to 48 hours for orders to
@@ -68,7 +68,7 @@ def list_financial_events_by_group_id(event_group_id, max_results_per_page: nil,
           "NextToken" => next_token,
         }.compact
 
-        retriable(delay: proc { |i| 0.5 * i }).get(path, params:)
+        retriable(delay: 2.0, retry_statuses: [429]).get(path, params:)
       end
 
       # Returns all financial events for the specified order. It may take up to 48 hours for orders to appear in your
@@ -86,7 +86,7 @@ def list_financial_events_by_order_id(order_id, max_results_per_page: nil, next_
           "NextToken" => next_token,
         }.compact
 
-        retriable(delay: proc { |i| 0.5 * i }).get(path, params:)
+        retriable(delay: 2.0, retry_statuses: [429]).get(path, params:)
       end
 
       # Returns financial events for the specified data range. It may take up to 48 hours for orders to appear in your
@@ -114,7 +114,7 @@ def list_financial_events(max_results_per_page: nil, posted_after: nil, posted_b
           "NextToken" => next_token,
         }.compact
 
-        retriable(delay: proc { |i| 0.5 * i }).get(path, params:)
+        retriable(delay: 2.0, retry_statuses: [429]).get(path, params:)
       end
     end
   end