🎉 Source Stripe: Add missing invoices event types for incremental…

… sync (#39393)
airbytehq · Jun 11, 2024 · 41299b1 · 41299b1
1 parent e06a95d
commit 41299b1
Show file tree

Hide file tree

Showing 4 changed files with 12 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.4.0
+  dockerImageTag: 5.4.1
   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.4.0"
+version = "5.4.1"
 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
@@ -232,17 +232,20 @@ def streams(self, config: MutableMapping[str, Any]) -> List[Stream]:
             use_cache=USE_CACHE,
             event_types=[
                 "invoice.created",
+                "invoice.deleted",
                 "invoice.finalization_failed",
                 "invoice.finalized",
                 "invoice.marked_uncollectible",
+                "invoice.overdue",
                 "invoice.paid",
                 "invoice.payment_action_required",
                 "invoice.payment_failed",
                 "invoice.payment_succeeded",
                 "invoice.sent",
+                "invoice.upcoming",
                 "invoice.updated",
                 "invoice.voided",
-                "invoice.deleted",
+                "invoice.will_be_due",
             ],
             **args,
         )
@@ -373,7 +376,11 @@ def streams(self, config: MutableMapping[str, Any]) -> List[Stream]:
                 name="invoice_items",
                 path="invoiceitems",
                 legacy_cursor_field="date",
-                event_types=["invoiceitem.created", "invoiceitem.updated", "invoiceitem.deleted"],
+                event_types=[
+                    "invoiceitem.created",
+                    "invoiceitem.updated",
+                    "invoiceitem.deleted",
+                ],
                 **args,
             ),
             IncrementalStripeStream(

diff --git a/docs/integrations/sources/stripe.md b/docs/integrations/sources/stripe.md
@@ -225,6 +225,7 @@ Each record is marked with `is_deleted` flag when the appropriate event happens
 
 | Version | Date       | Pull Request                                              | Subject                                                                                                                                                                                                                       |
 | :------ | :--------- | :-------------------------------------------------------- | :---------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------- |
+| 5.4.1   | 2024-06-11 | [39393](https://github.com/airbytehq/airbyte/pull/39393)  | Added missing `event types` (incremental sync) for `Invoices` stream                                                              |
 | 5.4.0   | 2024-06-05 | [39138](https://github.com/airbytehq/airbyte/pull/39138)  | Fixed the `Refunds` stream missing data for the `incremental` sync                                                             |
 | 5.3.9   | 2024-05-22 | [38550](https://github.com/airbytehq/airbyte/pull/38550)  | Update authenticator package                                                             |
 | 5.3.8   | 2024-05-15 | [38248](https://github.com/airbytehq/airbyte/pull/38248)  | Replace AirbyteLogger with logging.Logger |