-
Notifications
You must be signed in to change notification settings - Fork 4.5k
Source-Stripe: Updating CBT to use invoices and customer parents #58633
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. Weβll occasionally send you account related emails.
Already on GitHub? Sign in to your account
base: master
Are you sure you want to change the base?
Source-Stripe: Updating CBT to use invoices and customer parents #58633
Conversation
@ericvanbenschoten-dv01 is attempting to deploy a commit to the Airbyte Growth Team on Vercel. A member of the Team first needs to authorize it. |
@@ -308,6 +308,8 @@ definitions: | |||
$parameters: | |||
request_parameters: | |||
types[]: '{{["customer.created", "customer.updated", "customer.deleted"]}}' | |||
cursor_field: updated | |||
lookback_window_days: 1 |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
How does this work with incremental streams?
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Removed and using CustomStateMigrations class to roll back the cursors
|
||
class CustomerIdPartitionRouter(SubstreamPartitionRouter): | ||
def stream_slices(self) -> Iterable[StreamSlice]: # type: ignore | ||
parent_slices = list(super().stream_slices()) |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
I thought you had to iterate through each of the substream partition configs
6c1afa3
to
9f7607e
Compare
state_migrations: | ||
- type: CustomStateMigration | ||
class_name: source_stripe.components.CustomerBalanceStateMigration |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
get_updated_state has been deprecating using the CustomStateMigration to rollback cursors: https://docs.airbyte.com/platform/connector-development/config-based/understanding-the-yaml-file/reference#/definitions/CustomStateMigration
e5b6d30
to
d5018ae
Compare
What
How
Review guide
User Impact
Can this PR be safely reverted and rolled back?