From dc72ecd5a4ceb4df7f045f7424c048af6da0ba15 Mon Sep 17 00:00:00 2001 From: Kevin Hu <6051736+kevinhu@users.noreply.github.com> Date: Fri, 16 Jul 2021 11:58:24 -0700 Subject: [PATCH] feat(ingest): add connectivity check for Looker (#2902) --- metadata-ingestion/src/datahub/ingestion/source/looker.py | 8 +++++++- 1 file changed, 7 insertions(+), 1 deletion(-) diff --git a/metadata-ingestion/src/datahub/ingestion/source/looker.py b/metadata-ingestion/src/datahub/ingestion/source/looker.py index ee56616519..5de3738da7 100644 --- a/metadata-ingestion/src/datahub/ingestion/source/looker.py +++ b/metadata-ingestion/src/datahub/ingestion/source/looker.py @@ -393,7 +393,13 @@ class LookerDashboardSource(Source): os.environ["LOOKERSDK_CLIENT_SECRET"] = self.source_config.client_secret os.environ["LOOKERSDK_BASE_URL"] = self.source_config.base_url - return looker_sdk.init31() + client = looker_sdk.init31() + + # try authenticating current user to check connectivity + # (since it's possible to initialize an invalid client without any complaints) + client.me() + + return client def get_workunits(self) -> Iterable[MetadataWorkUnit]: client = self._get_looker_client()