remove deprecated authenticator

airbytehq · May 21, 2024 · 491dc6d · 491dc6d
1 parent 73a44d0
commit 491dc6d
Show file tree

Hide file tree

Showing 4 changed files with 5 additions and 5 deletions.
diff --git a/airbyte-integrations/connectors/source-stripe/metadata.yaml b/airbyte-integrations/connectors/source-stripe/metadata.yaml
@@ -10,7 +10,7 @@ data:
   connectorSubtype: api
   connectorType: source
   definitionId: e094cb9a-26de-4645-8761-65c0c425d1de
-  dockerImageTag: 5.3.7
+  dockerImageTag: 5.3.8
   dockerRepository: airbyte/source-stripe
   documentationUrl: https://docs.airbyte.com/integrations/sources/stripe
   githubIssueLabel: source-stripe

diff --git a/airbyte-integrations/connectors/source-stripe/pyproject.toml b/airbyte-integrations/connectors/source-stripe/pyproject.toml
@@ -3,7 +3,7 @@ requires = [ "poetry-core>=1.0.0",]
 build-backend = "poetry.core.masonry.api"
 
 [tool.poetry]
-version = "5.3.7"
+version = "5.3.8"
 name = "source-stripe"
 description = "Source implementation for Stripe."
 authors = [ "Airbyte <contact@airbyte.io>",]

diff --git a/airbyte-integrations/connectors/source-stripe/source_stripe/source.py b/airbyte-integrations/connectors/source-stripe/source_stripe/source.py
@@ -22,7 +22,7 @@
 from airbyte_cdk.sources.streams.concurrent.adapters import StreamFacade
 from airbyte_cdk.sources.streams.concurrent.cursor import ConcurrentCursor, CursorField, FinalStateCursor
 from airbyte_cdk.sources.streams.concurrent.state_converters.datetime_stream_state_converter import EpochValueConcurrentStreamStateConverter
-from airbyte_cdk.sources.streams.http.auth import TokenAuthenticator
+from airbyte_cdk.sources.streams.http.requests_native_auth import TokenAuthenticator
 from airbyte_cdk.utils.traced_exception import AirbyteTracedException
 from airbyte_protocol.models import SyncMode
 from source_stripe.streams import (

diff --git a/airbyte-integrations/connectors/source-stripe/source_stripe/streams.py b/airbyte-integrations/connectors/source-stripe/source_stripe/streams.py
@@ -356,7 +356,7 @@ def __init__(
         # as each event holds the latest value of a record.
         # `start_date_max_days_from_now` represents the events API limitation.
         self.events_stream = Events(
-            authenticator=self.authenticator,
+            authenticator=kwargs.get("authenticator"),
             lookback_window_days=0,
             start_date_max_days_from_now=30,
             account_id=self.account_id,
@@ -506,7 +506,7 @@ def __init__(self, *args, **kwargs):
             path="customers",
             use_cache=USE_CACHE,
             event_types=["customer.created", "customer.updated", "customer.deleted"],
-            authenticator=self.authenticator,
+            authenticator=kwargs.get("authenticator"),
             account_id=self.account_id,
             start_date=self.start_date,
         )