🐛 Source Pardot: failed while syncing Visitors stream

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

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,
+            Visitors(**args),
             Visits(parent_stream=visitors, **args),
         ]

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",

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