feat(source-zendesk-support): update CDK to v5 (#45187)

Signed-off-by: Artem Inzhyyants <[email protected]>

Author: artem1205

airbyte-integrations/connectors/source-zendesk-support/metadata.yaml

@@ -11,7 +11,7 @@ data:
   connectorSubtype: api
   connectorType: source
   definitionId: 79c1aa37-dae3-42ae-b333-d1c105477715
-  dockerImageTag: 4.0.2
+  dockerImageTag: 4.1.0
   dockerRepository: airbyte/source-zendesk-support
   documentationUrl: https://docs.airbyte.com/integrations/sources/zendesk-support
   githubIssueLabel: source-zendesk-support

airbyte-integrations/connectors/source-zendesk-support/poetry.lock

@@ -3,7 +3,7 @@ requires = [ "poetry-core>=1.0.0",]
 build-backend = "poetry.core.masonry.api"
 
 [tool.poetry]
-version = "4.0.2"
+version = "4.1.0"
 name = "source-zendesk-support"
 description = "Source implementation for Zendesk Support."
 authors = [ "Airbyte <[email protected]>",]
@@ -17,7 +17,7 @@ include = "source_zendesk_support"
 
 [tool.poetry.dependencies]
 python = "^3.10,<3.12"
-airbyte-cdk = "^4"
+airbyte-cdk = "^5"
 pytz = "==2024.1"
 
 [tool.poetry.scripts]

airbyte-integrations/connectors/source-zendesk-support/pyproject.toml

@@ -14,15 +14,14 @@
 import pytz
 import requests
 from airbyte_cdk import BackoffStrategy
-from airbyte_cdk.models import SyncMode
+from airbyte_cdk.models import FailureType, SyncMode
 from airbyte_cdk.sources.streams.core import StreamData, package_name_from_class
 from airbyte_cdk.sources.streams.http import HttpStream, HttpSubStream
 from airbyte_cdk.sources.streams.http.error_handlers import ErrorHandler, ErrorResolution, HttpStatusErrorHandler, ResponseAction
 from airbyte_cdk.sources.streams.http.error_handlers.default_error_mapping import DEFAULT_ERROR_MAPPING
 from airbyte_cdk.sources.utils.schema_helpers import ResourceSchemaLoader
 from airbyte_cdk.sources.utils.transform import TransformConfig, TypeTransformer
 from airbyte_cdk.utils import AirbyteTracedException
-from airbyte_protocol.models import FailureType
 
 DATETIME_FORMAT: str = "%Y-%m-%dT%H:%M:%SZ"
 LAST_END_TIME_KEY: str = "_last_end_time"

airbyte-integrations/connectors/source-zendesk-support/source_zendesk_support/streams.py

@@ -6,12 +6,12 @@
 
 import freezegun
 import pendulum
+from airbyte_cdk.models import AirbyteStateBlob
+from airbyte_cdk.models import Level as LogLevel
+from airbyte_cdk.models import SyncMode
 from airbyte_cdk.test.mock_http import HttpMocker
 from airbyte_cdk.test.mock_http.response_builder import FieldPath
 from airbyte_cdk.test.state_builder import StateBuilder
-from airbyte_protocol.models import AirbyteStateBlob
-from airbyte_protocol.models import Level as LogLevel
-from airbyte_protocol.models import SyncMode
 
 from .config import ConfigBuilder
 from .helpers import given_post_comments, given_posts, given_ticket_forms
@@ -209,7 +209,7 @@ def test_given_no_state_and_successful_sync_when_read_then_set_state_to_now(self
         assert len(output.records) == 1
 
         assert output.most_recent_state.stream_descriptor.name == "post_comment_votes"
-        assert output.most_recent_state.stream_state == AirbyteStateBlob.model_validate({"updated_at": post_comment_votes["updated_at"]})
+        assert output.most_recent_state.stream_state == AirbyteStateBlob({"updated_at": post_comment_votes["updated_at"]})
 
     @HttpMocker()
     def test_given_state_and_pagination_when_read_then_return_records(self, http_mocker):
@@ -267,4 +267,4 @@ def test_given_state_and_pagination_when_read_then_return_records(self, http_moc
         assert len(output.records) == 2
 
         assert output.most_recent_state.stream_descriptor.name == "post_comment_votes"
-        assert output.most_recent_state.stream_state == AirbyteStateBlob.model_validate({"updated_at": datetime_to_string(last_page_record_updated_at)})
+        assert output.most_recent_state.stream_state == AirbyteStateBlob({"updated_at": datetime_to_string(last_page_record_updated_at)})

airbyte-integrations/connectors/source-zendesk-support/unit_tests/integrations/test_post_comment_votes.py

@@ -6,12 +6,12 @@
 
 import freezegun
 import pendulum
+from airbyte_cdk.models import AirbyteStateBlob
+from airbyte_cdk.models import Level as LogLevel
+from airbyte_cdk.models import SyncMode
 from airbyte_cdk.test.mock_http import HttpMocker
 from airbyte_cdk.test.mock_http.response_builder import FieldPath
 from airbyte_cdk.test.state_builder import StateBuilder
-from airbyte_protocol.models import AirbyteStateBlob
-from airbyte_protocol.models import Level as LogLevel
-from airbyte_protocol.models import SyncMode
 
 from .config import ConfigBuilder
 from .helpers import given_posts, given_ticket_forms
@@ -179,7 +179,7 @@ def test_given_no_state_and_successful_sync_when_read_then_set_state_to_now(self
 
         post_comment = post_comments_record_builder.build()
         assert output.most_recent_state.stream_descriptor.name == "post_comments"
-        assert output.most_recent_state.stream_state == AirbyteStateBlob.model_validate({"updated_at": post_comment["updated_at"]})
+        assert output.most_recent_state.stream_state == AirbyteStateBlob({"updated_at": post_comment["updated_at"]})
 
     @HttpMocker()
     def test_given_state_and_pagination_when_read_then_return_records(self, http_mocker):
@@ -234,4 +234,4 @@ def test_given_state_and_pagination_when_read_then_return_records(self, http_moc
         assert len(output.records) == 2
 
         assert output.most_recent_state.stream_descriptor.name == "post_comments"
-        assert output.most_recent_state.stream_state == AirbyteStateBlob.model_validate({"updated_at": datetime_to_string(last_page_record_updated_at)})
+        assert output.most_recent_state.stream_state == AirbyteStateBlob({"updated_at": datetime_to_string(last_page_record_updated_at)})

airbyte-integrations/connectors/source-zendesk-support/unit_tests/integrations/test_post_comments.py

@@ -6,12 +6,12 @@
 
 import freezegun
 import pendulum
+from airbyte_cdk.models import AirbyteStateBlob
+from airbyte_cdk.models import Level as LogLevel
+from airbyte_cdk.models import SyncMode
 from airbyte_cdk.test.mock_http import HttpMocker
 from airbyte_cdk.test.mock_http.response_builder import FieldPath
 from airbyte_cdk.test.state_builder import StateBuilder
-from airbyte_protocol.models import AirbyteStateBlob
-from airbyte_protocol.models import Level as LogLevel
-from airbyte_protocol.models import SyncMode
 
 from .config import ConfigBuilder
 from .helpers import given_posts, given_ticket_forms
@@ -179,7 +179,7 @@ def test_given_no_state_and_successful_sync_when_read_then_set_state_to_now(self
 
         post_comment = post_comments_record_builder.build()
         assert output.most_recent_state.stream_descriptor.name == "post_votes"
-        assert output.most_recent_state.stream_state == AirbyteStateBlob.model_validate({"updated_at": post_comment["updated_at"]})
+        assert output.most_recent_state.stream_state == AirbyteStateBlob({"updated_at": post_comment["updated_at"]})
 
     @HttpMocker()
     def test_given_state_and_pagination_when_read_then_return_records(self, http_mocker):
@@ -231,4 +231,4 @@ def test_given_state_and_pagination_when_read_then_return_records(self, http_moc
         assert len(output.records) == 2
 
         assert output.most_recent_state.stream_descriptor.name == "post_votes"
-        assert output.most_recent_state.stream_state == AirbyteStateBlob.model_validate({"updated_at": datetime_to_string(last_page_record_updated_at)})
+        assert output.most_recent_state.stream_state == AirbyteStateBlob({"updated_at": datetime_to_string(last_page_record_updated_at)})

airbyte-integrations/connectors/source-zendesk-support/unit_tests/integrations/test_post_votes.py

@@ -5,10 +5,10 @@
 
 import freezegun
 import pendulum
+from airbyte_cdk.models import AirbyteStateBlob, SyncMode
 from airbyte_cdk.test.mock_http import HttpMocker
 from airbyte_cdk.test.mock_http.response_builder import FieldPath
 from airbyte_cdk.test.state_builder import StateBuilder
-from airbyte_protocol.models import AirbyteStateBlob, SyncMode
 
 from .config import ConfigBuilder
 from .helpers import given_tickets, given_tickets_with_state
@@ -56,7 +56,7 @@ def test_given_no_state_and_successful_sync_when_read_then_set_state_to_most_rec
 
         assert len(output.records) == 1
         assert output.most_recent_state.stream_descriptor.name == "ticket_metrics"
-        assert output.most_recent_state.stream_state == AirbyteStateBlob.model_validate({
+        assert output.most_recent_state.stream_state == AirbyteStateBlob({
             "generated_timestamp": ticket["generated_timestamp"]
         })
 
@@ -84,6 +84,6 @@ def test_given_state_and_successful_sync_when_read_then_return_record(self, http
 
         assert len(output.records) == 1
         assert output.most_recent_state.stream_descriptor.name == "ticket_metrics"
-        assert output.most_recent_state.stream_state == AirbyteStateBlob.model_validate({
+        assert output.most_recent_state.stream_state == AirbyteStateBlob({
             "generated_timestamp": record_cursor_value.int_timestamp
         })

airbyte-integrations/connectors/source-zendesk-support/unit_tests/integrations/test_ticket_metrics.py

@@ -6,9 +6,9 @@
 import pendulum
 from airbyte_cdk.models import AirbyteMessage
 from airbyte_cdk.models import Level as LogLevel
+from airbyte_cdk.models import SyncMode
 from airbyte_cdk.test.catalog_builder import CatalogBuilder
 from airbyte_cdk.test.entrypoint_wrapper import EntrypointOutput, read
-from airbyte_protocol.models import SyncMode
 from pendulum.datetime import DateTime
 from source_zendesk_support import SourceZendeskSupport
 

airbyte-integrations/connectors/source-zendesk-support/unit_tests/integrations/utils.py

@@ -16,8 +16,8 @@
 import pytest
 import pytz
 import requests
+from airbyte_cdk.models import SyncMode
 from airbyte_cdk.sources.streams.http.error_handlers import ResponseAction
-from airbyte_protocol.models import SyncMode
 from source_zendesk_support.source import BasicApiTokenAuthenticator, SourceZendeskSupport
 from source_zendesk_support.streams import (
     DATETIME_FORMAT,