Source Stripe: rename cursor to _ab_source_record_last_modified

airbytehq · Jan 22, 2024 · 5f3c614 · 5f3c614
1 parent b374a9c
commit 5f3c614
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 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.2.0
+  dockerImageTag: 6.0.0
   dockerRepository: airbyte/source-stripe
   documentationUrl: https://docs.airbyte.com/integrations/sources/stripe
   githubIssueLabel: source-stripe

diff --git a/airbyte-integrations/connectors/source-stripe/source_stripe/streams.py b/airbyte-integrations/connectors/source-stripe/source_stripe/streams.py
@@ -338,7 +338,7 @@ def event_types(self) -> Iterable[str]:
     def __init__(
         self,
         *args,
-        cursor_field: str = "updated",
+        cursor_field: str = "_ab_source_record_last_modified",
         legacy_cursor_field: Optional[str] = "created",
         event_types: Optional[List[str]] = None,
         record_extractor: Optional[IRecordExtractor] = None,
@@ -438,7 +438,7 @@ class IncrementalStripeStream(StripeStream):
     def __init__(
         self,
         *args,
-        cursor_field: str = "updated",
+        cursor_field: str = "_ab_source_record_last_modified",
         legacy_cursor_field: Optional[str] = "created",
         event_types: Optional[List[str]] = None,
         **kwargs,
@@ -727,7 +727,7 @@ def __init__(
         self,
         parent: StripeStream,
         *args,
-        cursor_field: str = "updated",
+        cursor_field: str = "_ab_source_record_last_modified",
         legacy_cursor_field: Optional[str] = "created",
         event_types: Optional[List[str]] = None,
         sub_items_attr: Optional[str] = None,