diff --git a/metadata-ingestion/src/datahub/emitter/rest_emitter.py b/metadata-ingestion/src/datahub/emitter/rest_emitter.py index 38550cc2128a56..b1cc367487f571 100644 --- a/metadata-ingestion/src/datahub/emitter/rest_emitter.py +++ b/metadata-ingestion/src/datahub/emitter/rest_emitter.py @@ -128,7 +128,14 @@ def emit_mce(self, mce: MetadataChangeEvent) -> None: response.raise_for_status() except HTTPError as e: - info = response.json() + try: + info = response.json() + except Exception as parse_exception: + response.raise_for_status() + raise OperationalError( + "Unable to parse response from ingestion sink", + {"message": str(parse_exception)}, + ) from e raise OperationalError( "Unable to emit metadata to DataHub GMS", info ) from e