diff --git a/airbyte-integrations/connectors/source-facebook-marketing/source_facebook_marketing/api.py b/airbyte-integrations/connectors/source-facebook-marketing/source_facebook_marketing/api.py index aa9625f6dcd4..65d703b67b26 100644 --- a/airbyte-integrations/connectors/source-facebook-marketing/source_facebook_marketing/api.py +++ b/airbyte-integrations/connectors/source-facebook-marketing/source_facebook_marketing/api.py @@ -224,5 +224,6 @@ def _find_account(account_id: str) -> AdAccount: ) raise AirbyteTracedException( message=message, + internal_message=message, failure_type=FailureType.config_error, ) from exc diff --git a/airbyte-integrations/connectors/source-facebook-marketing/source_facebook_marketing/source.py b/airbyte-integrations/connectors/source-facebook-marketing/source_facebook_marketing/source.py index 1159d8fefb4d..fb0f79ac14f9 100644 --- a/airbyte-integrations/connectors/source-facebook-marketing/source_facebook_marketing/source.py +++ b/airbyte-integrations/connectors/source-facebook-marketing/source_facebook_marketing/source.py @@ -254,6 +254,7 @@ def get_custom_insights_streams(self, api: API, config: ConnectorConfig) -> List ) raise AirbyteTracedException( message=message, + internal_message=message, failure_type=FailureType.config_error, ) stream = AdsInsights( diff --git a/airbyte-integrations/connectors/source-facebook-marketing/source_facebook_marketing/streams/base_insight_streams.py b/airbyte-integrations/connectors/source-facebook-marketing/source_facebook_marketing/streams/base_insight_streams.py index 8e93929c9c33..ffb58d39034c 100644 --- a/airbyte-integrations/connectors/source-facebook-marketing/source_facebook_marketing/streams/base_insight_streams.py +++ b/airbyte-integrations/connectors/source-facebook-marketing/source_facebook_marketing/streams/base_insight_streams.py @@ -124,9 +124,11 @@ def read_records( for obj in job.get_result(): yield obj.export_all_data() except FacebookBadObjectError as e: + message = f"API error occurs on Facebook side during job: {job}, wrong (empty) response received with errors: {e} " + f"Please try again later" raise AirbyteTracedException( - message=f"API error occurs on Facebook side during job: {job}, wrong (empty) response received with errors: {e} " - f"Please try again later", + message=message, + internal_message=message, failure_type=FailureType.system_error, ) from e