🐛 Source Mixpanel: add handler for 402 error (#27252)
* added handler for 402 error * added changelog * fixed CAT, updated logging * changed stream in check_connection * refactored tests * added check for all streams to avoid 402 error * added check for all stream for right permissions * upadated expected records * updated streams method * added get_json_schema to streams method * refactored check_connection method
This commit is contained in:
Daryna Ishchenko
@@ -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.34
|
||||
LABEL io.airbyte.version=0.1.35
|
||||
LABEL io.airbyte.name=airbyte/source-mixpanel
|
||||
|
||||
@@ -1,5 +1,12 @@
|
||||
{"stream": "funnels", "data": {"funnel_id": 8901755, "name": "Onboarding funnel", "date": "2023-06-02", "steps": [{"count": 0, "avg_time": null, "avg_time_from_start": null, "event": "Viewed Home Page", "goal": "Viewed Home Page", "step_label": "Viewed Home Page", "overall_conv_ratio": 1, "step_conv_ratio": 1}, {"count": 0, "avg_time": null, "avg_time_from_start": null, "event": "Signed Up", "goal": "Signed Up", "step_label": "Signed Up", "overall_conv_ratio": 0, "step_conv_ratio": 0}, {"count": 0, "avg_time": null, "avg_time_from_start": null, "event": "Onboarding - Action Performed", "goal": "Onboarding - Action Performed", "step_label": "Onboarding - Action Performed", "selector": "(string(properties[\"action\"], \"undefined\") == \"Set a name for your workspace\")", "selector_params": {"step_label": "Onboarding - Action Performed", "bool_op": "and", "property_filter_params_list": [{"filter": {"operator": "==", "operand": ["Set a name for your workspace"]}, "property": {"name": "action", "source": "properties", "type": "string"}, "selected_property_type": "string", "type": "string"}]}, "overall_conv_ratio": 0, "step_conv_ratio": 0}, {"count": 0, "avg_time": null, "avg_time_from_start": null, "event": "Onboarding - Action Performed", "goal": "Onboarding - Action Performed", "step_label": "Onboarding - Action Performed", "selector": "(string(properties[\"action\"], \"undefined\") == \"Invite your team to your workspace\")", "selector_params": {"step_label": "Onboarding - Action Performed", "bool_op": "and", "property_filter_params_list": [{"filter": {"operator": "==", "operand": ["Invite your team to your workspace"]}, "property": {"name": "action", "source": "properties", "type": "string"}, "selected_property_type": "string", "type": "string"}]}, "overall_conv_ratio": 0, "step_conv_ratio": 0}, {"count": 0, "avg_time": null, "avg_time_from_start": null, "event": "Onboarding - Action Performed", "goal": "Onboarding - Action Performed", "step_label": "Onboarding - Action Performed", "selector": "(string(properties[\"action\"], \"undefined\") == \"Enter the website you want to unblock\")", "selector_params": {"step_label": "Onboarding - Action Performed", "bool_op": "and", "property_filter_params_list": [{"filter": {"operator": "==", "operand": ["Enter the website you want to unblock"]}, "property": {"name": "action", "source": "properties", "type": "string"}, "selected_property_type": "string", "type": "string"}]}, "overall_conv_ratio": 0, "step_conv_ratio": 0}, {"count": 0, "avg_time": null, "avg_time_from_start": null, "event": "Onboarding - Action Performed", "goal": "Onboarding - Action Performed", "step_label": "Onboarding - Action Performed", "selector": "(string(properties[\"action\"], \"undefined\") == \"Install Dataline on your website\")", "selector_params": {"step_label": "Onboarding - Action Performed", "bool_op": "and", "property_filter_params_list": [{"filter": {"operator": "==", "operand": ["Install Dataline on your website"]}, "property": {"name": "action", "source": "properties", "type": "string"}, "selected_property_type": "string", "type": "string"}]}, "overall_conv_ratio": 0, "step_conv_ratio": 0}], "analysis": {"completion": 0, "starting_amount": 0, "steps": 6, "worst": 1}}, "emitted_at": 1686595087241}
|
||||
{"stream": "engage", "data": {"distinct_id": "22885b19-781a-44cd-a8d9-ce46970a3fd6", "browser": "Chrome", "browser_version": "81.0.4044.138", "city": "San Francisco", "country_code": "US", "email": "john+test5@dataline.io", "first_name": "John", "last_name": "Laflur", "name": "John Laflur", "region": "California", "timezone": "America/Los_Angeles", "id": "22885b19-781a-44cd-a8d9-ce46970a3fd6", "last_seen": "2020-05-19T17:53:14"}, "emitted_at": 1686595088617}
|
||||
{"stream": "cohorts", "data": {"id": 1343181, "project_id": 2117889, "name": "Users in California", "description": "Users in California description", "data_group_id": null, "count": 45, "is_visible": 1, "created": "2021-07-01 22:02:05"}, "emitted_at": 1686595090896}
|
||||
{"stream": "cohort_members", "data": {"distinct_id": "44b3e80b-894c-480e-9cc0-20cb27784e48", "browser": "Chrome", "browser_version": "85.0.4183.121", "city": "Laguna Niguel", "country_code": "US", "email": "alec@brev.dev", "first_name": "Alec", "last_name": "Fong", "name": "Alec Fong", "region": "California", "timezone": "America/Los_Angeles", "id": "0e2a7bf1-47c5-4c98-b4eb-52859d98adc7", "unblocked": "true", "last_seen": "2020-10-13T22:03:01", "cohort_id": 1343181}, "emitted_at": 1686595093527}
|
||||
{"stream": "revenue", "data": {"date": "2023-06-02", "amount": 0.0, "count": 121, "paid_count": 0}, "emitted_at": 1686595094576}
|
||||
{"stream": "funnels", "data": {"funnel_id": 36152117, "name": "test", "date": "2023-06-13", "steps": [{"count": 0, "avg_time": null, "avg_time_from_start": null, "event": "Purchase", "goal": "Purchase", "step_label": "Purchase", "overall_conv_ratio": 1, "step_conv_ratio": 1}, {"count": 0, "avg_time": null, "avg_time_from_start": null, "event": "$custom_event:1305068", "goal": "$custom_event:1305068", "step_label": "111", "custom_event": true, "custom_event_id": 1305068, "overall_conv_ratio": 0, "step_conv_ratio": 0}], "analysis": {"completion": 0, "starting_amount": 0, "steps": 2, "worst": 1}}, "emitted_at": 1684508037955}
|
||||
{"stream": "funnels", "data": {"funnel_id": 36152117, "name": "test", "date": "2023-06-10", "steps": [{"count": 0, "avg_time": null, "avg_time_from_start": null, "event": "Purchase", "goal": "Purchase", "step_label": "Purchase", "overall_conv_ratio": 1, "step_conv_ratio": 1}, {"count": 0, "avg_time": null, "avg_time_from_start": null, "event": "$custom_event:1305068", "goal": "$custom_event:1305068", "step_label": "111", "custom_event": true, "custom_event_id": 1305068, "overall_conv_ratio": 0, "step_conv_ratio": 0}], "analysis": {"completion": 0, "starting_amount": 0, "steps": 2, "worst": 1} }, "emitted_at": 1684508037956}
|
||||
{"stream": "funnels", "data": {"funnel_id": 36152117, "name": "test", "date": "2023-06-09", "steps": [{"count": 0, "avg_time": null, "avg_time_from_start": null, "event": "Purchase", "goal": "Purchase", "step_label": "Purchase", "overall_conv_ratio": 1, "step_conv_ratio": 1}, {"count": 0, "avg_time": null, "avg_time_from_start": null, "event": "$custom_event:1305068", "goal": "$custom_event:1305068", "step_label": "111", "custom_event": true, "custom_event_id": 1305068, "overall_conv_ratio": 0, "step_conv_ratio": 0}], "analysis": {"completion": 0, "starting_amount": 0, "steps": 2, "worst": 1}}, "emitted_at": 1684508037956}
|
||||
{"stream": "engage", "data": {"distinct_id": "123@gmail.com", "email": "123@gmail.com", "name": "123", "123": "123456", "last_seen": "2023-01-01T00:00:00"}, "emitted_at": 1684508042343}
|
||||
{"stream": "engage", "data": {"distinct_id": "integration-test@airbyte.io", "name": "Integration Test1", "test": "test", "email": "integration-test@airbyte.io", "last_seen": "2023-01-01T00:00:00"}, "emitted_at": 1684508042345}
|
||||
{"stream": "engage", "data": {"distinct_id": "integration-test.db4415.mp-service-account", "name": "test", "test": "test", "last_seen": "2023-01-01T00:00:00"}, "emitted_at": 1684508042346}
|
||||
{"stream": "cohorts", "data": {"id": 1478097, "project_id": 2529987, "name": "Cohort1", "description": "", "data_group_id": null, "count": 2, "is_visible": 1, "created": "2021-09-14 15:57:43"}, "emitted_at": 1684508052373}
|
||||
{"stream": "cohort_members", "data": {"distinct_id": "integration-test@airbyte.io", "name": "Integration Test1", "test": "test", "email": "integration-test@airbyte.io", "last_seen": "2023-01-01T00:00:00", "cohort_id": 1478097}, "emitted_at": 1684508059432}
|
||||
{"stream": "cohort_members", "data": {"distinct_id": "integration-test.db4415.mp-service-account", "name": "test", "test": "test", "last_seen": "2023-01-01T00:00:00", "cohort_id": 1478097}, "emitted_at": 1684508059434}
|
||||
{"stream": "revenue", "data": {"date": "2023-06-11", "amount": 0.0, "count": 3, "paid_count": 0}, "emitted_at": 1684508063120}
|
||||
{"stream": "revenue", "data": {"date": "2023-06-12", "amount": 0.0, "count": 3, "paid_count": 0}, "emitted_at": 1684508063121}
|
||||
{"stream": "revenue", "data": {"date": "2023-06-13", "amount": 0.0, "count": 3, "paid_count": 0}, "emitted_at": 1684508063121}
|
||||
@@ -6,7 +6,7 @@ data:
|
||||
connectorSubtype: api
|
||||
connectorType: source
|
||||
definitionId: 12928b32-bf0a-4f1e-964f-07e12e37153a
|
||||
dockerImageTag: 0.1.34
|
||||
dockerImageTag: 0.1.35
|
||||
dockerRepository: airbyte/source-mixpanel
|
||||
githubIssueLabel: source-mixpanel
|
||||
icon: mixpanel.svg
|
||||
|
||||
@@ -237,9 +237,6 @@
|
||||
"URL": {
|
||||
"type": ["null", "string"]
|
||||
},
|
||||
"insert_id": {
|
||||
"type": ["null", "string"]
|
||||
},
|
||||
"mp_api_timestamp_ms": {
|
||||
"type": ["null", "string"]
|
||||
},
|
||||
|
||||
@@ -13,7 +13,7 @@ from airbyte_cdk.sources import AbstractSource
|
||||
from airbyte_cdk.sources.streams import Stream
|
||||
from airbyte_cdk.sources.streams.http.auth import BasicHttpAuthenticator, TokenAuthenticator
|
||||
|
||||
from .streams import Annotations, CohortMembers, Cohorts, Engage, Export, Funnels, FunnelsList, Revenue
|
||||
from .streams import Annotations, CohortMembers, Cohorts, Engage, Export, Funnels, Revenue
|
||||
from .testing import adapt_streams_if_testing, adapt_validate_if_testing
|
||||
from .utils import read_full_refresh
|
||||
|
||||
@@ -79,16 +79,31 @@ class SourceMixpanel(AbstractSource):
|
||||
try:
|
||||
config = self._validate_and_transform(config)
|
||||
auth = self.get_authenticator(config)
|
||||
FunnelsList.max_retries = 0
|
||||
funnels = FunnelsList(authenticator=auth, **config)
|
||||
funnels.reqs_per_hour_limit = 0
|
||||
next(read_full_refresh(funnels), None)
|
||||
except requests.HTTPError as e:
|
||||
return False, e.response.json()["error"]
|
||||
except Exception as e:
|
||||
return False, e
|
||||
|
||||
return True, None
|
||||
# https://github.com/airbytehq/airbyte/pull/27252#discussion_r1228356872
|
||||
# temporary solution, testing access for all streams to avoid 402 error
|
||||
streams = [Annotations, Cohorts, Engage, Export, Revenue]
|
||||
connected = False
|
||||
reason = None
|
||||
for stream_class in streams:
|
||||
try:
|
||||
stream = stream_class(authenticator=auth, **config)
|
||||
next(read_full_refresh(stream), None)
|
||||
connected = True
|
||||
break
|
||||
except requests.HTTPError as e:
|
||||
reason = e.response.json()["error"]
|
||||
if e.response.status_code == 402:
|
||||
logger.info(f"Stream {stream_class.__name__}: {e.response.json()['error']}")
|
||||
else:
|
||||
return connected, reason
|
||||
except Exception as e:
|
||||
return connected, e
|
||||
|
||||
reason = None if connected else reason
|
||||
return connected, reason
|
||||
|
||||
@adapt_streams_if_testing
|
||||
def streams(self, config: Mapping[str, Any]) -> List[Stream]:
|
||||
@@ -100,20 +115,18 @@ class SourceMixpanel(AbstractSource):
|
||||
logger.info(f"Using start_date: {config['start_date']}, end_date: {config['end_date']}")
|
||||
|
||||
auth = self.get_authenticator(config)
|
||||
streams = [
|
||||
streams = []
|
||||
for stream in [
|
||||
Annotations(authenticator=auth, **config),
|
||||
Cohorts(authenticator=auth, **config),
|
||||
Funnels(authenticator=auth, **config),
|
||||
Revenue(authenticator=auth, **config),
|
||||
]
|
||||
|
||||
# streams with dynamically generated schema
|
||||
for stream in [
|
||||
CohortMembers(authenticator=auth, **config),
|
||||
Engage(authenticator=auth, **config),
|
||||
Export(authenticator=auth, **config),
|
||||
]:
|
||||
try:
|
||||
next(read_full_refresh(stream), None)
|
||||
stream.get_json_schema()
|
||||
except requests.HTTPError as e:
|
||||
if e.response.status_code != 402:
|
||||
|
||||
@@ -106,6 +106,12 @@ class MixpanelStream(HttpStream, ABC):
|
||||
self.retries += 1
|
||||
return 2**self.retries * 60
|
||||
|
||||
def should_retry(self, response: requests.Response) -> bool:
|
||||
if response.status_code == 402:
|
||||
self.logger.warning(f"Unable to perform a request. Payment Required: {response.json()['error']}")
|
||||
return False
|
||||
return super().should_retry(response)
|
||||
|
||||
def get_stream_params(self) -> Mapping[str, Any]:
|
||||
"""
|
||||
Fetch required parameters in a given stream. Used to create sub-streams
|
||||
|
||||
@@ -8,7 +8,7 @@ import pytest
|
||||
from airbyte_cdk import AirbyteLogger
|
||||
from airbyte_cdk.models import AirbyteConnectionStatus, Status
|
||||
from source_mixpanel.source import SourceMixpanel, TokenAuthenticatorBase64
|
||||
from source_mixpanel.streams import FunnelsList
|
||||
from source_mixpanel.streams import Annotations, Cohorts, Engage, Export, Revenue
|
||||
|
||||
from .utils import command_check, get_url_to_mock, setup_response
|
||||
|
||||
@@ -18,16 +18,15 @@ logger = AirbyteLogger()
|
||||
@pytest.fixture
|
||||
def check_connection_url(config):
|
||||
auth = TokenAuthenticatorBase64(token=config["api_secret"])
|
||||
funnel_list = FunnelsList(authenticator=auth, **config)
|
||||
return get_url_to_mock(funnel_list)
|
||||
annotations = Annotations(authenticator=auth, **config)
|
||||
return get_url_to_mock(annotations)
|
||||
|
||||
|
||||
@pytest.mark.parametrize(
|
||||
"response_code,expect_success,response_json",
|
||||
[
|
||||
(200, True, {}),
|
||||
(400, False, {"error": "Request error"}),
|
||||
(500, False, {"error": "Server error"}),
|
||||
(400, False, {"error": "Request error"})
|
||||
],
|
||||
)
|
||||
def test_check_connection(requests_mock, check_connection_url, config_raw, response_code, expect_success, response_json):
|
||||
@@ -39,6 +38,28 @@ def test_check_connection(requests_mock, check_connection_url, config_raw, respo
|
||||
assert error == expected_error
|
||||
|
||||
|
||||
def test_check_connection_all_streams_402_error(requests_mock, check_connection_url, config_raw, config):
|
||||
auth = TokenAuthenticatorBase64(token=config["api_secret"])
|
||||
requests_mock.register_uri("GET", get_url_to_mock(Cohorts(authenticator=auth, **config)), setup_response(402, {"error": "Payment required"}))
|
||||
requests_mock.register_uri("GET", get_url_to_mock(Annotations(authenticator=auth, **config)), setup_response(402, {"error": "Payment required"}))
|
||||
requests_mock.register_uri("POST", get_url_to_mock(Engage(authenticator=auth, **config)), setup_response(402, {"error": "Payment required"}))
|
||||
requests_mock.register_uri("GET", get_url_to_mock(Export(authenticator=auth, **config)), setup_response(402, {"error": "Payment required"}))
|
||||
requests_mock.register_uri("GET", get_url_to_mock(Revenue(authenticator=auth, **config)), setup_response(402, {"error": "Payment required"}))
|
||||
|
||||
ok, error = SourceMixpanel().check_connection(logger, config_raw)
|
||||
assert ok is False and error == "Payment required"
|
||||
|
||||
|
||||
def test_check_connection_402_error_on_first_stream(requests_mock, check_connection_url, config, config_raw):
|
||||
auth = TokenAuthenticatorBase64(token=config["api_secret"])
|
||||
requests_mock.register_uri("GET", get_url_to_mock(Cohorts(authenticator=auth, **config)), setup_response(200, {}))
|
||||
requests_mock.register_uri("GET", get_url_to_mock(Annotations(authenticator=auth, **config)), setup_response(402, {"error": "Payment required"}))
|
||||
|
||||
ok, error = SourceMixpanel().check_connection(logger, config_raw)
|
||||
assert ok is True
|
||||
assert error is None
|
||||
|
||||
|
||||
def test_check_connection_bad_config():
|
||||
config = {}
|
||||
source = SourceMixpanel()
|
||||
@@ -52,8 +73,22 @@ def test_check_connection_incomplete(config_raw):
|
||||
|
||||
|
||||
def test_streams(requests_mock, config_raw):
|
||||
requests_mock.register_uri("POST", "https://mixpanel.com/api/2.0/engage?page_size=1000", setup_response(200, {}))
|
||||
requests_mock.register_uri("GET", "https://mixpanel.com/api/2.0/engage/properties", setup_response(200, {}))
|
||||
requests_mock.register_uri("GET", "https://mixpanel.com/api/2.0/events/properties/top", setup_response(200, {}))
|
||||
requests_mock.register_uri("GET", "https://mixpanel.com/api/2.0/events/properties/top", setup_response(200, {}))
|
||||
requests_mock.register_uri("GET", "https://mixpanel.com/api/2.0/annotations", setup_response(200, {}))
|
||||
requests_mock.register_uri("GET", "https://mixpanel.com/api/2.0/cohorts/list", setup_response(200, {"id": 123}))
|
||||
requests_mock.register_uri("GET", "https://mixpanel.com/api/2.0/engage/revenue", setup_response(200, {}))
|
||||
requests_mock.register_uri("GET", "https://mixpanel.com/api/2.0/funnels", setup_response(200, {}))
|
||||
requests_mock.register_uri(
|
||||
"GET", "https://mixpanel.com/api/2.0/funnels/list", setup_response(200, {"funnel_id": 123, "name": "name"})
|
||||
)
|
||||
requests_mock.register_uri(
|
||||
"GET", "https://data.mixpanel.com/api/2.0/export",
|
||||
setup_response(200, {"event": "some event", "properties": {"event": 124, "time": 124124}})
|
||||
)
|
||||
|
||||
streams = SourceMixpanel().streams(config_raw)
|
||||
assert len(streams) == 7
|
||||
|
||||
@@ -61,15 +96,32 @@ def test_streams(requests_mock, config_raw):
|
||||
def test_streams_string_date(requests_mock, config_raw):
|
||||
requests_mock.register_uri("GET", "https://mixpanel.com/api/2.0/engage/properties", setup_response(200, {}))
|
||||
requests_mock.register_uri("GET", "https://mixpanel.com/api/2.0/events/properties/top", setup_response(200, {}))
|
||||
requests_mock.register_uri("GET", "https://mixpanel.com/api/2.0/annotations", setup_response(200, {}))
|
||||
requests_mock.register_uri("GET", "https://mixpanel.com/api/2.0/cohorts/list", setup_response(200, {"id": 123}))
|
||||
requests_mock.register_uri("GET", "https://mixpanel.com/api/2.0/engage/revenue", setup_response(200, {}))
|
||||
requests_mock.register_uri("POST", "https://mixpanel.com/api/2.0/engage", setup_response(200, {}))
|
||||
requests_mock.register_uri("GET", "https://mixpanel.com/api/2.0/funnels/list", setup_response(402, {"error": "Payment required"}))
|
||||
requests_mock.register_uri(
|
||||
"GET", "https://data.mixpanel.com/api/2.0/export",
|
||||
setup_response(200, {"event": "some event", "properties": {"event": 124, "time": 124124}})
|
||||
)
|
||||
config = copy.deepcopy(config_raw)
|
||||
config["start_date"] = "2020-01-01"
|
||||
config["end_date"] = "2020-01-02"
|
||||
streams = SourceMixpanel().streams(config)
|
||||
assert len(streams) == 7
|
||||
assert len(streams) == 6
|
||||
|
||||
|
||||
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, {}))
|
||||
json_response = {"error": "Your plan does not allow API calls. Upgrade at mixpanel.com/pricing"}
|
||||
requests_mock.register_uri("POST", "https://mixpanel.com/api/2.0/engage?page_size=1000", setup_response(200, {}))
|
||||
requests_mock.register_uri("GET", "https://mixpanel.com/api/2.0/engage/properties", setup_response(200, {}))
|
||||
requests_mock.register_uri("GET", "https://mixpanel.com/api/2.0/events/properties/top", setup_response(200, {}))
|
||||
requests_mock.register_uri("GET", "https://mixpanel.com/api/2.0/events/properties/top", setup_response(200, {}))
|
||||
requests_mock.register_uri("GET", "https://mixpanel.com/api/2.0/annotations", setup_response(200, {}))
|
||||
requests_mock.register_uri("GET", "https://mixpanel.com/api/2.0/cohorts/list", setup_response(402, json_response))
|
||||
requests_mock.register_uri("GET", "https://mixpanel.com/api/2.0/engage/revenue", setup_response(200, {}))
|
||||
requests_mock.register_uri("GET", "https://mixpanel.com/api/2.0/funnels/list", setup_response(402, json_response))
|
||||
requests_mock.register_uri("GET", "https://data.mixpanel.com/api/2.0/export?from_date=2017-01-20&to_date=2017-02-18", setup_response(402, json_response))
|
||||
streams = SourceMixpanel().streams(config_raw)
|
||||
assert {s.name for s in streams} == {"funnels", "revenue", "annotations", "cohorts"}
|
||||
assert {s.name for s in streams} == {'annotations', 'engage', 'revenue'}
|
||||
|
||||
@@ -468,3 +468,20 @@ def test_export_iter_dicts(config):
|
||||
assert list(stream.iter_dicts([record_string, record_string[:2], record_string[2:], record_string])) == [record, record, record]
|
||||
# drop record parts because they are not standing nearby
|
||||
assert list(stream.iter_dicts([record_string, record_string[:2], record_string, record_string[2:]])) == [record, record]
|
||||
|
||||
|
||||
@pytest.mark.parametrize(
|
||||
("http_status_code", "should_retry", "log_message"),
|
||||
[
|
||||
(402, False, "Unable to perform a request. Payment Required: "),
|
||||
],
|
||||
)
|
||||
def test_should_retry_payment_required(http_status_code, should_retry, log_message, config, caplog):
|
||||
response_mock = MagicMock()
|
||||
response_mock.status_code = http_status_code
|
||||
response_mock.json = MagicMock(return_value={"error": "Your plan does not allow API calls. Upgrade at mixpanel.com/pricing"})
|
||||
streams = [Annotations, CohortMembers, Cohorts, Engage, EngageSchema, Export, ExportSchema, Funnels, FunnelsList, Revenue]
|
||||
for stream_class in streams:
|
||||
stream = stream_class(authenticator=MagicMock(), **config)
|
||||
assert stream.should_retry(response_mock) == should_retry
|
||||
assert log_message in caplog.text
|
||||
|
||||
@@ -50,7 +50,8 @@ Syncing huge date windows may take longer due to Mixpanel's low API rate-limits
|
||||
|
||||
| Version | Date | Pull Request | Subject |
|
||||
|:--------|:-----------|:---------------------------------------------------------|:------------------------------------------------------------------------------------------------------------|
|
||||
| 0.1.34 | 2022-05-15 | [21837](https://github.com/airbytehq/airbyte/pull/21837) | Add "insert_id" field to "export" stream schema |
|
||||
| 0.1.35 | 2022-06-12 | [27252](https://github.com/airbytehq/airbyte/pull/27252) | Add should_retry False for 402 error |
|
||||
| 0.1.34 | 2022-05-15 | [21837](https://github.com/airbytehq/airbyte/pull/21837) | Add "insert_id" field to "export" stream schema |
|
||||
| 0.1.33 | 2023-04-25 | [25543](https://github.com/airbytehq/airbyte/pull/25543) | Set should_retry for 104 error in stream export |
|
||||
| 0.1.32 | 2023-04-11 | [25056](https://github.com/airbytehq/airbyte/pull/25056) | Set HttpAvailabilityStrategy, add exponential backoff, streams export and annotations add undeclared fields |
|
||||
| 0.1.31 | 2023-02-13 | [22936](https://github.com/airbytehq/airbyte/pull/22936) | Specified date formatting in specification |
|
||||
|
||||
Reference in New Issue
Block a user