diff --git a/airbyte-config/init/src/main/resources/seed/source_definitions.yaml b/airbyte-config/init/src/main/resources/seed/source_definitions.yaml index 008bf9440e0e..2b81cddfbc62 100644 --- a/airbyte-config/init/src/main/resources/seed/source_definitions.yaml +++ b/airbyte-config/init/src/main/resources/seed/source_definitions.yaml @@ -1135,7 +1135,7 @@ - name: Pardot sourceDefinitionId: ad15c7ba-72a7-440b-af15-b9a963dc1a8a dockerRepository: airbyte/source-pardot - dockerImageTag: 0.1.0 + dockerImageTag: 0.1.1 documentationUrl: https://docs.airbyte.com/integrations/sources/pardot sourceType: api releaseStage: alpha diff --git a/airbyte-config/init/src/main/resources/seed/source_specs.yaml b/airbyte-config/init/src/main/resources/seed/source_specs.yaml index 7551ad070b9f..cc06f66f94f4 100644 --- a/airbyte-config/init/src/main/resources/seed/source_specs.yaml +++ b/airbyte-config/init/src/main/resources/seed/source_specs.yaml @@ -10504,9 +10504,9 @@ supportsNormalization: false supportsDBT: false supported_destination_sync_modes: [] -- dockerImage: "airbyte/source-pardot:0.1.0" +- dockerImage: "airbyte/source-pardot:0.1.1" spec: - documentationUrl: "https://docsurl.com" + documentationUrl: "https://docs.airbyte.com/integrations/sources/pardot" connectionSpecification: $schema: "http://json-schema.org/draft-07/schema#" title: "Pardot Spec" diff --git a/airbyte-integrations/connectors/source-pardot/Dockerfile b/airbyte-integrations/connectors/source-pardot/Dockerfile index f3d48734a32f..0ee99bc33f02 100644 --- a/airbyte-integrations/connectors/source-pardot/Dockerfile +++ b/airbyte-integrations/connectors/source-pardot/Dockerfile @@ -34,5 +34,5 @@ COPY source_pardot ./source_pardot ENV AIRBYTE_ENTRYPOINT "python /airbyte/integration_code/main.py" ENTRYPOINT ["python", "/airbyte/integration_code/main.py"] -LABEL io.airbyte.version=0.1.0 +LABEL io.airbyte.version=0.1.1 LABEL io.airbyte.name=airbyte/source-pardot diff --git a/airbyte-integrations/connectors/source-pardot/source_pardot/source.py b/airbyte-integrations/connectors/source-pardot/source_pardot/source.py index afaa30be3e97..1dec8d9c0bc7 100644 --- a/airbyte-integrations/connectors/source-pardot/source_pardot/source.py +++ b/airbyte-integrations/connectors/source-pardot/source_pardot/source.py @@ -34,8 +34,6 @@ def streams(self, config: Mapping[str, Any]) -> List[Stream]: auth = TokenAuthenticator(pardot.access_token) args = {"authenticator": auth, "config": config} - visitors = Visitors(**args) - return [ EmailClicks(**args), Campaigns(**args), @@ -45,6 +43,6 @@ def streams(self, config: Mapping[str, Any]) -> List[Stream]: Prospects(**args), Users(**args), VisitorActivities(**args), - visitors, - Visits(parent_stream=visitors, **args), + Visitors(**args), + Visits(parent_stream=Visitors(**args), **args), ] diff --git a/airbyte-integrations/connectors/source-pardot/source_pardot/spec.json b/airbyte-integrations/connectors/source-pardot/source_pardot/spec.json index da48d19ec2f7..273e439d409a 100644 --- a/airbyte-integrations/connectors/source-pardot/source_pardot/spec.json +++ b/airbyte-integrations/connectors/source-pardot/source_pardot/spec.json @@ -1,5 +1,5 @@ { - "documentationUrl": "https://docsurl.com", + "documentationUrl": "https://docs.airbyte.com/integrations/sources/pardot", "connectionSpecification": { "$schema": "http://json-schema.org/draft-07/schema#", "title": "Pardot Spec", diff --git a/airbyte-integrations/connectors/source-pardot/source_pardot/stream.py b/airbyte-integrations/connectors/source-pardot/source_pardot/stream.py index 3d59ee30358f..0baaaf17cee6 100644 --- a/airbyte-integrations/connectors/source-pardot/source_pardot/stream.py +++ b/airbyte-integrations/connectors/source-pardot/source_pardot/stream.py @@ -159,7 +159,7 @@ class Visitors(PardotUpdatedAtReplicationStream): def stream_slices( self, sync_mode: SyncMode, cursor_field: List[str] = None, stream_state: Mapping[str, Any] = None ) -> Iterable[Optional[Mapping[str, Any]]]: - slices = super().stream_slices(sync_mode, cursor_field=cursor_field, stream_state=stream_state) + slices = super().stream_slices(sync_mode=sync_mode, cursor_field=cursor_field, stream_state=stream_state) return slices diff --git a/airbyte-integrations/connectors/source-pardot/unit_tests/test_source.py b/airbyte-integrations/connectors/source-pardot/unit_tests/test_source.py deleted file mode 100644 index 9e7c7931a02f..000000000000 --- a/airbyte-integrations/connectors/source-pardot/unit_tests/test_source.py +++ /dev/null @@ -1,13 +0,0 @@ -# -# Copyright (c) 2022 Airbyte, Inc., all rights reserved. -# - -from unittest.mock import MagicMock - -from source_pardot.source import SourcePardot - - -def test_check_connection(mocker, config): - source = SourcePardot() - logger_mock = MagicMock() - assert source.check_connection(logger_mock, config) == (True, None)