diff --git a/ingestion/src/metadata/ingestion/source/pipeline/nifi/client.py b/ingestion/src/metadata/ingestion/source/pipeline/nifi/client.py index a85229fb64be..981a58a92afa 100644 --- a/ingestion/src/metadata/ingestion/source/pipeline/nifi/client.py +++ b/ingestion/src/metadata/ingestion/source/pipeline/nifi/client.py @@ -85,6 +85,9 @@ def token(self) -> str: ) self._token = res.text + if res.status_code not in (200, 201): + raise HTTPError(res.text) + except HTTPError as err: logger.error( f"Connection error retrieving the Bearer Token to access Nifi - {err}"