Source Mixpanel: disable stream "cohort_members" on discover if no ac…

…cess (#17415) Signed-off-by: Sergey Chvalyuk <grubberr@gmail.com>
airbytehq · Sep 30, 2022 · f0f60dc · f0f60dc
1 parent d6b79b8
commit f0f60dc
Show file tree

Hide file tree

Showing 6 changed files with 10 additions and 6 deletions.
diff --git a/airbyte-config/init/src/main/resources/seed/source_definitions.yaml b/airbyte-config/init/src/main/resources/seed/source_definitions.yaml
@@ -646,7 +646,7 @@
 - name: Mixpanel
   sourceDefinitionId: 12928b32-bf0a-4f1e-964f-07e12e37153a
   dockerRepository: airbyte/source-mixpanel
-  dockerImageTag: 0.1.26
+  dockerImageTag: 0.1.27
   documentationUrl: https://docs.airbyte.io/integrations/sources/mixpanel
   icon: mixpanel.svg
   sourceType: api

diff --git a/airbyte-config/init/src/main/resources/seed/source_specs.yaml b/airbyte-config/init/src/main/resources/seed/source_specs.yaml
@@ -6560,7 +6560,7 @@
               path_in_connector_config:
               - "credentials"
               - "client_secret"
-- dockerImage: "airbyte/source-mixpanel:0.1.26"
+- dockerImage: "airbyte/source-mixpanel:0.1.27"
   spec:
     documentationUrl: "https://docs.airbyte.io/integrations/sources/mixpanel"
     connectionSpecification:

diff --git a/airbyte-integrations/connectors/source-mixpanel/Dockerfile b/airbyte-integrations/connectors/source-mixpanel/Dockerfile
@@ -13,5 +13,5 @@ ENV AIRBYTE_ENTRYPOINT "python /airbyte/integration_code/main.py"
 ENTRYPOINT ["python", "/airbyte/integration_code/main.py"]
 
 
-LABEL io.airbyte.version=0.1.26
+LABEL io.airbyte.version=0.1.27
 LABEL io.airbyte.name=airbyte/source-mixpanel
diff --git a/airbyte-integrations/connectors/source-mixpanel/source_mixpanel/source.py b/airbyte-integrations/connectors/source-mixpanel/source_mixpanel/source.py
@@ -103,13 +103,16 @@ def streams(self, config: Mapping[str, Any]) -> List[Stream]:
         streams = [
             Annotations(authenticator=auth, **config),
             Cohorts(authenticator=auth, **config),
-            CohortMembers(authenticator=auth, **config),
             Funnels(authenticator=auth, **config),
             Revenue(authenticator=auth, **config),
         ]
 
         # streams with dynamically generated schema
-        for stream in [Engage(authenticator=auth, **config), Export(authenticator=auth, **config)]:
+        for stream in [
+            CohortMembers(authenticator=auth, **config),
+            Engage(authenticator=auth, **config),
+            Export(authenticator=auth, **config),
+        ]:
             try:
                 stream.get_json_schema()
             except requests.HTTPError as e:

diff --git a/airbyte-integrations/connectors/source-mixpanel/unit_tests/test_source.py b/airbyte-integrations/connectors/source-mixpanel/unit_tests/test_source.py
@@ -72,4 +72,4 @@ def test_streams_disabled_402(requests_mock, config_raw):
     requests_mock.register_uri("GET", "https://mixpanel.com/api/2.0/engage/properties", setup_response(402, {}))
     requests_mock.register_uri("GET", "https://mixpanel.com/api/2.0/events/properties/top", setup_response(402, {}))
     streams = SourceMixpanel().streams(config_raw)
-    assert {s.name for s in streams} == {"cohort_members", "funnels", "revenue", "annotations", "cohorts"}
+    assert {s.name for s in streams} == {"funnels", "revenue", "annotations", "cohorts"}
diff --git a/docs/integrations/sources/mixpanel.md b/docs/integrations/sources/mixpanel.md
@@ -63,6 +63,7 @@ Please note, that incremental sync could return duplicated \(old records\) for t
 
 | Version | Date       | Pull Request                                             | Subject                                                                                              |
 | :------ | :--------- | :------------------------------------------------------- | :--------------------------------------------------------------------------------------------------- |
+| 0.1.27  | 2022-09-29 | [17415](https://github.com/airbytehq/airbyte/pull/17415) | Disable stream "cohort_members" on discover if not access                                            |
 | 0.1.26  | 2022-09-28 | [17304](https://github.com/airbytehq/airbyte/pull/17304) | Migrate to per-stream states.                                                                        |
 | 0.1.25  | 2022-09-27 | [17145](https://github.com/airbytehq/airbyte/pull/17145) | Disable streams "export", "engage" on discover if not access                                         |
 | 0.1.24  | 2022-09-26 | [16915](https://github.com/airbytehq/airbyte/pull/16915) | Added Service Accounts support                                                                       |