From 491dc6d17250323cb90f1bca23a4b922d9cd5213 Mon Sep 17 00:00:00 2001 From: Christo Date: Tue, 21 May 2024 18:10:08 -0400 Subject: [PATCH] remove deprecated authenticator --- airbyte-integrations/connectors/source-stripe/metadata.yaml | 2 +- airbyte-integrations/connectors/source-stripe/pyproject.toml | 2 +- .../connectors/source-stripe/source_stripe/source.py | 2 +- .../connectors/source-stripe/source_stripe/streams.py | 4 ++-- 4 files changed, 5 insertions(+), 5 deletions(-) diff --git a/airbyte-integrations/connectors/source-stripe/metadata.yaml b/airbyte-integrations/connectors/source-stripe/metadata.yaml index 4b5bee52a4b6..8a322e991c8d 100644 --- 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 index 77e763f5d9e1..8ddb6b7800ae 100644 --- 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 ",] diff --git a/airbyte-integrations/connectors/source-stripe/source_stripe/source.py b/airbyte-integrations/connectors/source-stripe/source_stripe/source.py index c2698eaaf8a1..06cdc3badcae 100644 --- 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 index d8958d9453b7..d51c6fae4587 100644 --- 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, )