From 1c78e835d9a39fefed7d07ba3cbec9ff091474e2 Mon Sep 17 00:00:00 2001
From: Milan Bariya <52292922+MilanBariya@users.noreply.github.com>
Date: Mon, 26 Sep 2022 19:42:22 +0530
Subject: [PATCH] =?UTF-8?q?Fix:=20Error=20initializing=20ingest:=20?=
 =?UTF-8?q?=E2=80=98RedshiftSource=E2=80=99=20object=20has=20no=20attribut?=
 =?UTF-8?q?e=20=E2=80=98dbt=5Fmanifest=E2=80=99=20(#7723)?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../source/database/database_service.py         | 17 ++++++++++-------
 1 file changed, 10 insertions(+), 7 deletions(-)

diff --git a/ingestion/src/metadata/ingestion/source/database/database_service.py b/ingestion/src/metadata/ingestion/source/database/database_service.py
index 95c431ad1f1..28363f22186 100644
--- a/ingestion/src/metadata/ingestion/source/database/database_service.py
+++ b/ingestion/src/metadata/ingestion/source/database/database_service.py
@@ -235,13 +235,16 @@ class DatabaseServiceSource(DBTMixin, TopologyRunnerMixin, Source, ABC):
     dbt_tests = {}
 
     def __init__(self):
-        if hasattr(self.source_config.dbtConfigSource, "dbtSecurityConfig"):
-            if self.source_config.dbtConfigSource.dbtSecurityConfig is None:
-                logger.info("dbtConfigSource is not configured")
-                self.dbt_catalog = None
-                self.dbt_manifest = None
-                self.dbt_run_results = None
-                self.data_models = {}
+
+        if (
+            hasattr(self.source_config.dbtConfigSource, "dbtSecurityConfig")
+            and self.source_config.dbtConfigSource.dbtSecurityConfig is None
+        ):
+            logger.info("dbtConfigSource is not configured")
+            self.dbt_catalog = None
+            self.dbt_manifest = None
+            self.dbt_run_results = None
+            self.data_models = {}
         else:
             dbt_details = get_dbt_details(self.source_config.dbtConfigSource)
             if dbt_details: