yujunjun/OpenMetadata
1
0
Fork 0
mirror of https://github.com/open-metadata/OpenMetadata.git synced 2025-09-26 01:15:08 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fix: DBT root config error handled (#7446)

Browse Source 
* Fix: DBT root config error handled

* Fix: DBT root config error handled

* Fix: Py-test

* Fix: Change based on comments
This commit is contained in:
Milan Bariya 2022-09-15 18:26:05 +05:30 committed by GitHub
parent 86ebb2025f
commit 8502bf8e49
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 14 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
ingestion/src/metadata/ingestion/source/database/database_service.py
View File

@ -231,11 +231,20 @@ class DatabaseServiceSource(DBTMixin, TopologyRunnerMixin, Source, ABC):
context = create_source_context(topology)
def __init__(self):
dbt_details = get_dbt_details(self.source_config.dbtConfigSource)
self.dbt_catalog = dbt_details[0] if dbt_details else None
self.dbt_manifest = dbt_details[1] if dbt_details else None
self.dbt_run_results = dbt_details[2] if dbt_details else None
self.data_models = {}
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 = {}
else:
dbt_details = get_dbt_details(self.source_config.dbtConfigSource)
if dbt_details:
self.dbt_catalog = dbt_details[0] if len(dbt_details) == 3 else None
self.dbt_manifest = dbt_details[1] if len(dbt_details) == 3 else None
self.dbt_run_results = dbt_details[2] if len(dbt_details) == 3 else None
self.data_models = {}
def prepare(self):
self._parse_data_model()