🐛Source Klaviyo: add error handler for 5XX status codes (#38010)

Author: Anton Karpets

airbyte-integrations/connectors/source-klaviyo/metadata.yaml

@@ -8,7 +8,7 @@ data:
   definitionId: 95e8cffd-b8c4-4039-968e-d32fb4a69bde
   connectorBuildOptions:
     baseImage: docker.io/airbyte/python-connector-base:1.2.0@sha256:c22a9d97464b69d6ef01898edf3f8612dc11614f05a84984451dde195f337db9
-  dockerImageTag: 2.6.0
+  dockerImageTag: 2.6.1
   dockerRepository: airbyte/source-klaviyo
   githubIssueLabel: source-klaviyo
   icon: klaviyo.svg

airbyte-integrations/connectors/source-klaviyo/pyproject.toml

@@ -3,7 +3,7 @@ requires = [ "poetry-core>=1.0.0",]
 build-backend = "poetry.core.masonry.api"
 
 [tool.poetry]
-version = "2.6.0"
+version = "2.6.1"
 name = "source-klaviyo"
 description = "Source implementation for Klaviyo."
 authors = [ "Airbyte <[email protected]>",]

airbyte-integrations/connectors/source-klaviyo/source_klaviyo/manifest.yaml

@@ -18,18 +18,23 @@ definitions:
     authenticator: "#/definitions/authenticator"
     http_method: GET
     error_handler:
-      type: DefaultErrorHandler
-      backoff_strategies:
-        - type: WaitTimeFromHeader
-          header: "Retry-After"
-      response_filters:
-        - type: HttpResponseFilter
-          action: FAIL
-          http_codes: [401, 403]
-          error_message: Please provide a valid API key and make sure it has permissions to read specified streams.
-        - type: HttpResponseFilter
-          action: RETRY
-          http_codes: [429]
+      type: CompositeErrorHandler
+      error_handlers:
+        - type: DefaultErrorHandler
+          backoff_strategies:
+            - type: WaitTimeFromHeader
+              header: "Retry-After"
+          response_filters:
+            - type: HttpResponseFilter
+              action: RETRY
+              http_codes: [429]
+        - type: DefaultErrorHandler # adding this DefaultErrorHandler for 5XX error codes
+        - type: DefaultErrorHandler
+          response_filters:
+            - type: HttpResponseFilter
+              action: FAIL
+              http_codes: [401, 403]
+              error_message: Please provide a valid API key and make sure it has permissions to read specified streams.
     request_headers:
       Accept: "application/json"
       Revision: "2023-10-15"

docs/integrations/sources/klaviyo.md

@@ -69,6 +69,7 @@ Stream `Lists Detailed` contains field `profile_count` in addition to info from
 
 | Version  | Date       | Pull Request                                               | Subject                                                                                                                       |
 |:---------|:-----------|:-----------------------------------------------------------|:------------------------------------------------------------------------------------------------------------------------------|
+| `2.6.1`  | 2024-05-07 | [38010](https://github.com/airbytehq/airbyte/pull/38010)   | Add error handler for `5XX` status codes                                                                                      |
 | `2.6.0`  | 2024-04-19 | [37370](https://github.com/airbytehq/airbyte/pull/37370)   | Add streams `campaigns_detailed` and `lists_detailed`                                                                         |
 | `2.5.0`  | 2024-04-15 | [36264](https://github.com/airbytehq/airbyte/pull/36264)   | Migrate to low-code                                                                                                           |
 | `2.4.0`  | 2024-04-11 | [36989](https://github.com/airbytehq/airbyte/pull/36989)   | Update `Campaigns` schema                                                                                                     |