diff --git a/metadata-ingestion/src/datahub/ingestion/source/dbt/dbt_cloud.py b/metadata-ingestion/src/datahub/ingestion/source/dbt/dbt_cloud.py index 2c5a4b7af88361..820d85b2cfb51d 100644 --- a/metadata-ingestion/src/datahub/ingestion/source/dbt/dbt_cloud.py +++ b/metadata-ingestion/src/datahub/ingestion/source/dbt/dbt_cloud.py @@ -375,7 +375,7 @@ def _parse_into_dbt_node(self, node: Dict) -> DBTNode: max_loaded_at = None columns = [] - if "columns" in node: + if "columns" in node and node["columns"] is not None: # columns will be empty for ephemeral models columns = [ self._parse_into_dbt_column(column) diff --git a/metadata-ingestion/src/datahub/ingestion/source/tableau.py b/metadata-ingestion/src/datahub/ingestion/source/tableau.py index 6fbc56c57d4f1f..6d04cc0e2d1f5f 100644 --- a/metadata-ingestion/src/datahub/ingestion/source/tableau.py +++ b/metadata-ingestion/src/datahub/ingestion/source/tableau.py @@ -20,7 +20,7 @@ import tableauserverclient as TSC from pydantic import root_validator, validator from pydantic.fields import Field -from requests.adapters import ConnectionError, HTTPAdapter +from requests.adapters import HTTPAdapter from tableauserverclient import ( PersonalAccessTokenAuth, Server, @@ -572,11 +572,11 @@ def close(self) -> None: try: if self.server is not None: self.server.auth.sign_out() - except ConnectionError as err: + except Exception as ex: logger.warning( "During graceful closing of Tableau source a sign-out call was tried but ended up with" - " a ConnectionError (%s). Continuing closing of the source", - err, + " an Exception (%s). Continuing closing of the source", + ex, ) self.server = None super().close()