Fix pagination issue while setting is_resumable properly (#45101)

Author: maxi297

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

@@ -10,7 +10,7 @@ data:
   connectorSubtype: api
   connectorType: source
   definitionId: e094cb9a-26de-4645-8761-65c0c425d1de
-  dockerImageTag: 5.5.2
+  dockerImageTag: 5.5.3
   dockerRepository: airbyte/source-stripe
   documentationUrl: https://docs.airbyte.com/integrations/sources/stripe
   erdUrl: https://dbdocs.io/airbyteio/source-stripe?view=relationships

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.5.2"
+version = "5.5.3"
 name = "source-stripe"
 description = "Source implementation for Stripe."
 authors = [ "Airbyte <[email protected]>",]

airbyte-integrations/connectors/source-stripe/source_stripe/streams.py

@@ -93,6 +93,7 @@ def extract_records(
 
 
 class StripeStream(HttpStream, ABC):
+    is_resumable = False
     url_base = "https://api.stripe.com/v1/"
     DEFAULT_SLICE_RANGE = 365
     transformer = TypeTransformer(TransformConfig.DefaultSchemaNormalization)
@@ -234,6 +235,7 @@ def get_parent_stream(self, stream_state: Mapping[str, Any]) -> StripeStream:
 
 
 class CreatedCursorIncrementalStripeStream(StripeStream):
+    is_resumable = True
     # Stripe returns most recently created objects first, so we don't want to persist state until the entire stream has been read
     state_checkpoint_interval = math.inf
 
@@ -337,6 +339,7 @@ def path(self, **kwargs):
 
 
 class UpdatedCursorIncrementalStripeStream(StripeStream):
+    is_resumable = True
     """
     `CreatedCursorIncrementalStripeStream` does not provide a way to read updated data since given date because the API does not allow to do this.
     It only returns newly created entities since given date. So to have all the updated data as well we need to make use of the Events API,
@@ -452,6 +455,7 @@ def get_parent_stream(self, stream_state: Mapping[str, Any]) -> StripeStream:
 
 
 class IncrementalStripeStream(StripeStream):
+    is_resumable = True
     """
     This class combines both normal incremental sync and event based sync. It uses common endpoints for sliced data syncs in
     the full refresh sync mode and initial incremental sync. For incremental syncs with a state, event based sync comes into action.
@@ -720,6 +724,7 @@ def get_parent_stream(self, stream_state: Mapping[str, Any]) -> StripeStream:
 
 
 class UpdatedCursorIncrementalStripeLazySubStream(StripeStream, ABC):
+    is_resumable = True
     """
     This stream uses StripeLazySubStream under the hood to run full refresh or initial incremental syncs.
     In case of subsequent incremental syncs, it uses the UpdatedCursorIncrementalStripeStream class.
@@ -793,6 +798,7 @@ def read_records(
 
 
 class ParentIncrementalStipeSubStream(StripeSubStream):
+    is_resumable = True
     """
     This stream differs from others in that it runs parent stream in exactly same sync mode it is run itself to generate stream slices.
     It also uses regular /v1 API endpoints to sync data no matter what the sync mode is. This means that the event-based API can only

docs/integrations/sources/stripe.md

@@ -236,6 +236,7 @@ Each record is marked with `is_deleted` flag when the appropriate event happens
 
 | Version | Date       | Pull Request                                              | Subject                                                                                                                                                                                                                       |
 |:--------|:-----------| :-------------------------------------------------------- |:------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------|
+| 5.5.3   | 2024-09-03 | [45101](https://github.com/airbytehq/airbyte/pull/45101) | Fix regression followoing pagination issue fix                                                                                                                                                                                |
 | 5.5.2   | 2024-08-28 | [44862](https://github.com/airbytehq/airbyte/pull/44862) | Fix RFR pagination issue                                                                                                                                                                                                      |
 | 5.5.1   | 2024-08-10 | [43105](https://github.com/airbytehq/airbyte/pull/43105) | Update dependencies                                                                                                                                                                                                           |
 | 5.5.0   | 2024-08-08 | [43302](https://github.com/airbytehq/airbyte/pull/43302) | Fix problem with state not updating and upgrade cdk 4