Skip to content

Commit 0507927

Browse files
committed
Fix unittest
1 parent b4cc156 commit 0507927

File tree

2 files changed

+4
-4
lines changed
  • airbyte-integrations/connectors/source-facebook-marketing

2 files changed

+4
-4
lines changed

airbyte-integrations/connectors/source-facebook-marketing/source_facebook_marketing/streams/common.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -38,7 +38,7 @@ def should_retry_api_error(exc):
3838
call_rate_limit_error = exc.api_error_code() in FACEBOOK_RATE_LIMIT_ERROR_CODES
3939
batch_timeout_error = exc.http_status() == http.client.BAD_REQUEST and exc.api_error_code() == FACEBOOK_BATCH_ERROR_CODE
4040
unknown_error = exc.api_error_subcode() == FACEBOOK_UNKNOWN_ERROR_CODE
41-
connection_reset_error = exc.api_error_subcode() == FACEBOOK_CONNECTION_RESET_ERROR_CODE
41+
connection_reset_error = exc.api_error_code() == FACEBOOK_CONNECTION_RESET_ERROR_CODE
4242
return any((exc.api_transient_error(), unknown_error, call_rate_limit_error, batch_timeout_error, connection_reset_error))
4343
return True
4444

airbyte-integrations/connectors/source-facebook-marketing/unit_tests/test_client.py

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -165,8 +165,8 @@ def test_connection_reset_error(self, requests_mock, api, account_id):
165165

166166
responses = [{"json": {"error": {"code": 104}}}]
167167

168-
requests_mock.register_uri("POST", FacebookSession.GRAPH + f"/{FB_API_VERSION}/act_{account_id}/insights", responses)
168+
requests_mock.register_uri("GET", FacebookSession.GRAPH + f"/{FB_API_VERSION}/act_{account_id}/insights", responses)
169169

170170
with pytest.raises(FacebookRequestError):
171-
stream = AdsInsights(api=api, start_date=datetime.now(), end_date=datetime.now(), buffer_days=28, days_per_job=7)
172-
list(stream.stream_slices(stream_state={}))
171+
stream = AdsInsights(api=api, start_date=datetime.now(), end_date=datetime.now())
172+
list(stream.stream_slices(stream_state={}, sync_mode=None))

0 commit comments

Comments
 (0)