From 9b9bc1c76a2b0ecf1bb475482a7bf4e46809a234 Mon Sep 17 00:00:00 2001 From: Alexandros Milaios Date: Wed, 3 Jul 2024 17:20:00 +0300 Subject: [PATCH] fix: ignore pagination for sla_policies and custom roles streams --- .../source-zendesk-support/source_zendesk_support/streams.py | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/airbyte-integrations/connectors/source-zendesk-support/source_zendesk_support/streams.py b/airbyte-integrations/connectors/source-zendesk-support/source_zendesk_support/streams.py index 714999a1691f0a..769ab42b470b79 100644 --- a/airbyte-integrations/connectors/source-zendesk-support/source_zendesk_support/streams.py +++ b/airbyte-integrations/connectors/source-zendesk-support/source_zendesk_support/streams.py @@ -412,7 +412,7 @@ def next_page_token(self, response: requests.Response) -> Optional[Mapping[str, return {"page[after]": meta.get("after_cursor")} if meta.get("has_more") else None def request_params(self, next_page_token: Mapping[str, Any] = None, **kwargs) -> MutableMapping[str, Any]: - params = {"page[size]": self.page_size} + params = {"page[size]": self.page_size} if self.page_size else {} if next_page_token: params.update(next_page_token) return params @@ -837,7 +837,7 @@ class Tags(SourceZendeskSupportFullRefreshStream): class SlaPolicies(SourceZendeskSupportFullRefreshStream): """SlaPolicies stream: https://developer.zendesk.com/api-reference/ticketing/business-rules/sla_policies/""" - + page_size = None def path(self, *args, **kwargs) -> str: return "slas/policies.json" @@ -848,6 +848,7 @@ class Brands(SourceZendeskSupportFullRefreshStream): class CustomRoles(SourceZendeskSupportFullRefreshStream): """CustomRoles stream: https://developer.zendesk.com/api-reference/ticketing/account-configuration/custom_roles/#list-custom-roles""" + page_size = None class Schedules(SourceZendeskSupportFullRefreshStream):