diff --git a/tap_klaviyo/streams.py b/tap_klaviyo/streams.py index eb49bc6..6526982 100644 --- a/tap_klaviyo/streams.py +++ b/tap_klaviyo/streams.py @@ -50,3 +50,11 @@ class ListMembersStream(KlaviyoStream): primary_keys = ["id"] replication_key = "joined_group_at" parent_stream_type = ListsStream + +class ReviewsStream(KlaviyoStream): + """Define custom stream.""" + + name = "reviews" + path = "/reviews" + primary_keys = ["id"] + replication_key = "updated" diff --git a/tap_klaviyo/tap.py b/tap_klaviyo/tap.py index a6979e1..540766d 100644 --- a/tap_klaviyo/tap.py +++ b/tap_klaviyo/tap.py @@ -11,6 +11,7 @@ ListMembersStream, ListsStream, MetricsStream, + ReviewsStream, ) STREAM_TYPES = [ @@ -19,6 +20,7 @@ MetricsStream, EventsStream, ListMembersStream, + ReviewsStream, ]