feat(ingest): add connectivity check for Looker (#2902)

datahub-project · Jul 16, 2021 · dc72ecd · dc72ecd
1 parent 49de7ab
commit dc72ecd
Showing 1 changed file with 7 additions and 1 deletion.
diff --git a/metadata-ingestion/src/datahub/ingestion/source/looker.py b/metadata-ingestion/src/datahub/ingestion/source/looker.py
@@ -393,7 +393,13 @@ def _get_looker_client(self):
         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()