From e2cc33581419bc5ff9c15ef011dc1a4fbf372cee Mon Sep 17 00:00:00 2001 From: Alex Bair Date: Mon, 6 Jan 2025 16:48:50 -0500 Subject: [PATCH] source-mixpanel-native: enable `minimal_cohort_members_properties` functionality --- .../source_mixpanel_native/streams/cohort_members.py | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/source-mixpanel-native/source_mixpanel_native/streams/cohort_members.py b/source-mixpanel-native/source_mixpanel_native/streams/cohort_members.py index bd1d2c682..28fd06542 100644 --- a/source-mixpanel-native/source_mixpanel_native/streams/cohort_members.py +++ b/source-mixpanel-native/source_mixpanel_native/streams/cohort_members.py @@ -31,8 +31,8 @@ def __init__( # Since we know that each result received from the Mixpanel API will be a consistent, pretty small size when the # minimal_cohort_members_properties flag is set, we can use a very large page size to page through results faster. - # if minimal_cohort_members_properties: - # page_size = 1_000_000 + if minimal_cohort_members_properties: + page_size = 1_000_000 super().__init__( page_size=page_size, @@ -58,8 +58,8 @@ def request_params( params = super().request_params(stream_state, stream_slice, next_page_token) params = {**params, "page_size": self.page_size} - # if self.minimal_cohort_members_properties: - # params['output_properties'] = '"$last_seen"' + if self.minimal_cohort_members_properties: + params['output_properties'] = '"$last_seen"' if next_page_token: params.update(next_page_token)