Bulk update deprecated authenticators (#40549)

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

@@ -2,7 +2,7 @@ data:
   connectorSubtype: api
   connectorType: source
   definitionId: 6cbea164-3237-433b-9abb-36d384ee4cbf
-  dockerImageTag: 0.1.5
+  dockerImageTag: 0.1.6
   dockerRepository: airbyte/source-gridly
   githubIssueLabel: source-gridly
   icon: gridly.svg

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

@@ -3,7 +3,7 @@ requires = [ "poetry-core>=1.0.0",]
 build-backend = "poetry.core.masonry.api"
 
 [tool.poetry]
-version = "0.1.5"
+version = "0.1.6"
 name = "source-gridly"
 description = "Source implementation for Gridly."
 authors = [ "Airbyte <contact@airbyte.io>",]

airbyte-integrations/connectors/source-gridly/source_gridly/source.py

@@ -13,7 +13,7 @@
 from airbyte_cdk.sources import AbstractSource
 from airbyte_cdk.sources.streams import Stream
 from airbyte_cdk.sources.streams.http import HttpStream
-from airbyte_cdk.sources.streams.http.auth import TokenAuthenticator
+from airbyte_cdk.sources.streams.http.requests_native_auth import TokenAuthenticator
 from source_gridly.helpers import Helpers
 
 

airbyte-integrations/connectors/source-jira/integration_tests/fixtures/data_generator/generator.py

@@ -7,7 +7,7 @@
 from base64 import b64encode
 from typing import Any, List, Mapping
 
-from airbyte_cdk.sources.streams.http.auth import TokenAuthenticator
+from airbyte_cdk.sources.streams.http.requests_native_auth import TokenAuthenticator
 from streams import (
     DashboardsGenerator,
     FiltersGenerator,

airbyte-integrations/connectors/source-jira/integration_tests/fixtures/data_generator/streams.py

@@ -34,7 +34,7 @@
 
 class GeneratorMixin:
     def get_generate_headers(self):
-        headers = {"Accept": "application/json", "Content-Type": "application/json", **self.authenticator.get_auth_header()}
+        headers = {"Accept": "application/json", "Content-Type": "application/json", **self._session.auth.get_auth_header()}
         return headers
 
     def generate_record(
@@ -84,7 +84,7 @@ class FilterSharingGenerator(FilterSharing, GeneratorMixin):
     """
 
     def generate(self):
-        filters_stream = Filters(authenticator=self.authenticator, domain=self._domain)
+        filters_stream = Filters(authenticator=self._session.auth, domain=self._domain)
         for filters in filters_stream.read_records(sync_mode=SyncMode.full_refresh):
             for index in range(random.randrange(4)):
                 group_name = random.choice(["Test group 0", "Test group 1", "Test group 2"])
@@ -142,7 +142,7 @@ class IssueCommentsGenerator(IssueComments, GeneratorMixin):
     """
 
     def generate(self):
-        issues_stream = Issues(authenticator=self.authenticator, domain=self._domain)
+        issues_stream = Issues(authenticator=self._session.auth, domain=self._domain)
         for issue in issues_stream.read_records(sync_mode=SyncMode.full_refresh):
             for index in range(20):
                 payload = json.dumps(
@@ -195,7 +195,7 @@ class IssueRemoteLinksGenerator(IssueRemoteLinks, GeneratorMixin):
     """
 
     def generate(self):
-        issues_stream = Issues(authenticator=self.authenticator, domain=self._domain)
+        issues_stream = Issues(authenticator=self._session.auth, domain=self._domain)
         for issue in issues_stream.read_records(sync_mode=SyncMode.full_refresh):
             payload = json.dumps(
                 {
@@ -227,7 +227,7 @@ class IssueVotesGenerator(IssueVotes, GeneratorMixin):
     """
 
     def generate(self):
-        issues_stream = Issues(authenticator=self.authenticator, domain=self._domain)
+        issues_stream = Issues(authenticator=self._session.auth, domain=self._domain)
         for issue in issues_stream.read_records(sync_mode=SyncMode.full_refresh):
             payload = None
             self.generate_record(payload, stream_slice={"key": issue["key"]})
@@ -239,7 +239,7 @@ class IssueWatchersGenerator(IssueWatchers, GeneratorMixin):
     """
 
     def generate(self):
-        issues_stream = Issues(authenticator=self.authenticator, domain=self._domain)
+        issues_stream = Issues(authenticator=self._session.auth, domain=self._domain)
         for issue in issues_stream.read_records(sync_mode=SyncMode.full_refresh):
             payload = None
             self.generate_record(payload, stream_slice={"key": issue["key"]})
@@ -251,7 +251,7 @@ class IssueWorklogsGenerator(IssueWorklogs, GeneratorMixin):
     """
 
     def generate(self):
-        issues_stream = Issues(authenticator=self.authenticator, domain=self._domain)
+        issues_stream = Issues(authenticator=self._session.auth, domain=self._domain)
         for issue in issues_stream.read_records(sync_mode=SyncMode.full_refresh):
             for index in range(random.randrange(1, 6)):
                 payload = json.dumps(
@@ -312,7 +312,7 @@ def path(self, **kwargs) -> str:
         return "component"
 
     def generate(self):
-        projects_stream = Projects(authenticator=self.authenticator, domain=self._domain)
+        projects_stream = Projects(authenticator=self._session.auth, domain=self._domain)
         for project in projects_stream.read_records(sync_mode=SyncMode.full_refresh):
             for index in range(random.randrange(6)):
                 payload = json.dumps(
@@ -337,7 +337,7 @@ def path(self, **kwargs) -> str:
         return "version"
 
     def generate(self):
-        projects_stream = Projects(authenticator=self.authenticator, domain=self._domain)
+        projects_stream = Projects(authenticator=self._session.auth, domain=self._domain)
         for project in projects_stream.read_records(sync_mode=SyncMode.full_refresh):
             for index in range(random.randrange(6)):
                 payload = json.dumps(

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

@@ -10,7 +10,7 @@ data:
   connectorSubtype: api
   connectorType: source
   definitionId: 68e63de2-bb83-4c7e-93fa-a8a9051e3993
-  dockerImageTag: 3.0.3
+  dockerImageTag: 3.0.4
   dockerRepository: airbyte/source-jira
   documentationUrl: https://docs.airbyte.com/integrations/sources/jira
   githubIssueLabel: source-jira

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

@@ -3,7 +3,7 @@ requires = [ "poetry-core>=1.0.0",]
 build-backend = "poetry.core.masonry.api"
 
 [tool.poetry]
-version = "3.0.3"
+version = "3.0.4"
 name = "source-jira"
 description = "Source implementation for Jira."
 authors = [ "Airbyte <contact@airbyte.io>",]

airbyte-integrations/connectors/source-jira/source_jira/streams.py

@@ -223,8 +223,8 @@ class Issues(IncrementalJiraStream):
     def __init__(self, **kwargs):
         super().__init__(**kwargs)
         self._project_ids = []
-        self.issue_fields_stream = IssueFields(authenticator=self.authenticator, domain=self._domain, projects=self._projects)
-        self.projects_stream = Projects(authenticator=self.authenticator, domain=self._domain, projects=self._projects)
+        self.issue_fields_stream = IssueFields(authenticator=self._session.auth, domain=self._domain, projects=self._projects)
+        self.projects_stream = Projects(authenticator=self._session.auth, domain=self._domain, projects=self._projects)
 
     def path(self, **kwargs) -> str:
         return "search"
@@ -340,7 +340,7 @@ class IssueWorklogs(IncrementalJiraStream):
     def __init__(self, **kwargs):
         super().__init__(**kwargs)
         self.issues_stream = Issues(
-            authenticator=self.authenticator,
+            authenticator=self._session.auth,
             domain=self._domain,
             projects=self._projects,
             start_date=self._start_date,
@@ -370,7 +370,7 @@ class IssueComments(IncrementalJiraStream):
     def __init__(self, **kwargs):
         super().__init__(**kwargs)
         self.issues_stream = Issues(
-            authenticator=self.authenticator,
+            authenticator=self._session.auth,
             domain=self._domain,
             projects=self._projects,
             start_date=self._start_date,

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

@@ -7,7 +7,7 @@ data:
   connectorSubtype: api
   connectorType: source
   definitionId: 7b86879e-26c5-4ef6-a5ce-2be5c7b46d1e
-  dockerImageTag: 0.1.12
+  dockerImageTag: 0.1.13
   dockerRepository: airbyte/source-linnworks
   documentationUrl: https://docs.airbyte.com/integrations/sources/linnworks
   githubIssueLabel: source-linnworks

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

@@ -3,7 +3,7 @@ requires = [ "poetry-core>=1.0.0",]
 build-backend = "poetry.core.masonry.api"
 
 [tool.poetry]
-version = "0.1.12"
+version = "0.1.13"
 name = "source-linnworks"
 description = "Source implementation for Linnworks."
 authors = [ "Airbyte <contact@airbyte.io>",]

airbyte-integrations/connectors/source-linnworks/source_linnworks/streams.py

@@ -28,7 +28,7 @@ def __init__(self, authenticator: Union[AuthBase, HttpAuthenticator] = None, sta
 
     @property
     def url_base(self) -> str:
-        return self.authenticator.get_server()
+        return self._session.auth.get_server()
 
     def next_page_token(self, response: requests.Response) -> Optional[Mapping[str, Any]]:
         return None

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

@@ -11,7 +11,7 @@ data:
   connectorSubtype: api
   connectorType: source
   definitionId: 12928b32-bf0a-4f1e-964f-07e12e37153a
-  dockerImageTag: 3.1.4
+  dockerImageTag: 3.1.5
   dockerRepository: airbyte/source-mixpanel
   documentationUrl: https://docs.airbyte.com/integrations/sources/mixpanel
   githubIssueLabel: source-mixpanel

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

@@ -3,7 +3,7 @@ requires = ["poetry-core>=1.0.0"]
 build-backend = "poetry.core.masonry.api"
 
 [tool.poetry]
-version = "3.1.4"
+version = "3.1.5"
 name = "source-mixpanel"
 description = "Source implementation for Mixpanel."
 authors = ["Airbyte <contact@airbyte.io>"]

airbyte-integrations/connectors/source-mixpanel/unit_tests/unit_test.py

@@ -5,7 +5,6 @@
 from datetime import date, timedelta
 
 import pendulum
-from airbyte_cdk.sources.streams.http.auth import NoAuth
 from source_mixpanel.streams import Export
 
 
@@ -15,7 +14,7 @@ def test_date_slices():
 
     # test with stream_state
     stream_slices = Export(
-        authenticator=NoAuth(),
+        authenticator=None,
         start_date=date.fromisoformat("2021-07-01"),
         end_date=date.fromisoformat("2021-07-03"),
         date_window_size=1,

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

@@ -2,7 +2,7 @@ data:
   connectorSubtype: api
   connectorType: source
   definitionId: ad15c7ba-72a7-440b-af15-b9a963dc1a8a
-  dockerImageTag: 0.1.5
+  dockerImageTag: 0.1.6
   dockerRepository: airbyte/source-pardot
   githubIssueLabel: source-pardot
   icon: salesforcepardot.svg

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

@@ -3,7 +3,7 @@ requires = [ "poetry-core>=1.0.0",]
 build-backend = "poetry.core.masonry.api"
 
 [tool.poetry]
-version = "0.1.5"
+version = "0.1.6"
 name = "source-pardot"
 description = "Source implementation for Pardot."
 authors = [ "Airbyte <contact@airbyte.io>",]

airbyte-integrations/connectors/source-pardot/source_pardot/source.py

@@ -7,7 +7,7 @@
 
 from airbyte_cdk.sources import AbstractSource
 from airbyte_cdk.sources.streams import Stream
-from airbyte_cdk.sources.streams.http.auth import TokenAuthenticator
+from airbyte_cdk.sources.streams.http.requests_native_auth import TokenAuthenticator
 
 from .api import Pardot
 from .stream import Campaigns, EmailClicks, ListMembership, Lists, ProspectAccounts, Prospects, Users, VisitorActivities, Visitors, Visits

airbyte-integrations/connectors/source-python-http-tutorial/source_python_http_tutorial/source.py

@@ -10,7 +10,6 @@
 from airbyte_cdk.sources import AbstractSource
 from airbyte_cdk.sources.streams import Stream
 from airbyte_cdk.sources.streams.http import HttpStream
-from airbyte_cdk.sources.streams.http.auth import NoAuth
 
 
 class ExchangeRates(HttpStream):
@@ -106,10 +105,10 @@ def check_connection(self, logger, config) -> Tuple[bool, any]:
             return True, None
 
     def streams(self, config: Mapping[str, Any]) -> List[Stream]:
-        # NoAuth just means there is no authentication required for this API. It's only included for completeness
+        # No authentication is required for this API. It's only included for completeness
         # of the example, but if you don't need authentication, you don't need to pass an authenticator at all.
         # Other authenticators are available for API token-based auth and Oauth2.
-        auth = NoAuth()
+        auth = None
         # Parse the date from a string into a datetime object
         start_date = datetime.strptime(config["start_date"], "%Y-%m-%d")
         return [ExchangeRates(authenticator=auth, config=config, start_date=start_date)]

airbyte-integrations/connectors/source-rd-station-marketing/metadata.yaml

@@ -2,7 +2,7 @@ data:
   connectorSubtype: api
   connectorType: source
   definitionId: fb141f29-be2a-450b-a4f2-2cd203a00f84
-  dockerImageTag: 0.1.8
+  dockerImageTag: 0.1.9
   dockerRepository: airbyte/source-rd-station-marketing
   githubIssueLabel: source-rd-station-marketing
   icon: rdstation.svg

airbyte-integrations/connectors/source-rd-station-marketing/pyproject.toml

@@ -3,7 +3,7 @@ requires = [ "poetry-core>=1.0.0",]
 build-backend = "poetry.core.masonry.api"
 
 [tool.poetry]
-version = "0.1.8"
+version = "0.1.9"
 name = "source-rd-station-marketing"
 description = "Source implementation for RD Station Marketing."
 authors = [ "Airbyte <contact@airbyte.io>",]

airbyte-integrations/connectors/source-rd-station-marketing/source_rd_station_marketing/source.py

@@ -9,7 +9,7 @@
 from airbyte_cdk.models import SyncMode
 from airbyte_cdk.sources import AbstractSource
 from airbyte_cdk.sources.streams import Stream
-from airbyte_cdk.sources.streams.http.auth import Oauth2Authenticator
+from airbyte_cdk.sources.streams.http.requests_native_auth import Oauth2Authenticator
 from source_rd_station_marketing.streams import (
     AnalyticsConversions,
     AnalyticsEmails,

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

@@ -10,7 +10,7 @@ data:
   connectorSubtype: api
   connectorType: source
   definitionId: badc5925-0485-42be-8caa-b34096cb71b5
-  dockerImageTag: 0.3.7
+  dockerImageTag: 0.3.8
   dockerRepository: airbyte/source-surveymonkey
   documentationUrl: https://docs.airbyte.com/integrations/sources/surveymonkey
   githubIssueLabel: source-surveymonkey

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

@@ -3,7 +3,7 @@ requires = [ "poetry-core>=1.0.0",]
 build-backend = "poetry.core.masonry.api"
 
 [tool.poetry]
-version = "0.3.7"
+version = "0.3.8"
 name = "source-surveymonkey"
 description = "Source implementation for Surveymonkey."
 authors = [ "Airbyte <contact@airbyte.io>",]

airbyte-integrations/connectors/source-surveymonkey/unit_tests/conftest.py

@@ -8,7 +8,6 @@
 import pytest
 from airbyte_cdk.models import SyncMode
 from airbyte_cdk.sources.declarative.incremental.per_partition_cursor import StreamSlice
-from airbyte_cdk.sources.streams.http.auth import NoAuth
 from source_surveymonkey.source import SourceSurveymonkey
 
 
@@ -34,7 +33,7 @@ def read_records(stream_name, slice=StreamSlice(partition={"survey_id": "3077854
 @pytest.fixture
 def args_mock():
     return {
-        "authenticator": NoAuth(),
+        "authenticator": None,
         "start_date": pendulum.parse("2000-01-01"),
         "survey_ids": []
     }

airbyte-integrations/connectors/source-surveymonkey/unit_tests/test_for_updated_state.py

@@ -4,7 +4,7 @@
 
 import pendulum
 import pytest
-from airbyte_cdk.sources.streams.http.auth import TokenAuthenticator
+from airbyte_cdk.sources.streams.http.requests_native_auth import TokenAuthenticator
 from source_surveymonkey.streams import Surveys
 
 

airbyte-integrations/connectors/source-us-census/metadata.yaml

@@ -2,7 +2,7 @@ data:
   connectorSubtype: api
   connectorType: source
   definitionId: c4cfaeda-c757-489a-8aba-859fb08b6970
-  dockerImageTag: 0.1.7
+  dockerImageTag: 0.1.8
   dockerRepository: airbyte/source-us-census
   githubIssueLabel: source-us-census
   icon: uscensus.svg

airbyte-integrations/connectors/source-us-census/pyproject.toml

@@ -3,7 +3,7 @@ requires = [ "poetry-core>=1.0.0",]
 build-backend = "poetry.core.masonry.api"
 
 [tool.poetry]
-version = "0.1.7"
+version = "0.1.8"
 name = "source-us-census"
 description = "Source implementation for Us Census."
 authors = [ "Airbyte <contact@airbyte.io>",]

airbyte-integrations/connectors/source-us-census/source_us_census/source.py

@@ -12,7 +12,6 @@
 from airbyte_cdk.sources import AbstractSource
 from airbyte_cdk.sources.streams import Stream
 from airbyte_cdk.sources.streams.http import HttpStream
-from airbyte_cdk.sources.streams.http.auth import NoAuth
 
 
 def prepare_request_params(query_params: str, api_key: str) -> dict:
@@ -213,6 +212,6 @@ def streams(self, config: Mapping[str, Any]) -> List[Stream]:
                 query_params=config.get("query_params"),
                 query_path=config.get("query_path"),
                 api_key=config.get("api_key"),
-                authenticator=NoAuth(),
+                authenticator=None,
             )
         ]

airbyte-integrations/connectors/source-us-census/unit_tests/unit_test.py

@@ -6,7 +6,6 @@
 import pytest
 import requests
 import responses
-from airbyte_cdk.sources.streams.http.auth import NoAuth
 from source_us_census.source import UsCensusStream
 
 
@@ -16,7 +15,7 @@ def us_census_stream():
         query_params={},
         query_path="data/test",
         api_key="MY_API_KEY",
-        authenticator=NoAuth(),
+        authenticator=None,
     )