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

default gen time for comp time (#12256)

Browse Source
This commit is contained in:
Onkar Ravgan 2023-07-03 12:30:02 +05:30 committed by GitHub
parent 49caca5309
commit 48b98d0be8
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 11 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
ingestion/src/metadata/ingestion/source/database/dbt/metadata.py
View File

@ -312,7 +312,7 @@ class DbtSource(DbtServiceSource):
None, None,
) )
# pylint: disable=too-many-locals # pylint: disable=too-many-locals, too-many-branches
def yield_data_models(self, dbt_objects: DbtObjects) -> Iterable[DataModelLink]: def yield_data_models(self, dbt_objects: DbtObjects) -> Iterable[DataModelLink]:
""" """
Yield the data models Yield the data models
@ -330,6 +330,14 @@ class DbtSource(DbtServiceSource):
} }
self.context.data_model_links = [] self.context.data_model_links = []
self.context.dbt_tests = {} self.context.dbt_tests = {}
self.context.run_results_generate_time = None
if (
dbt_objects.dbt_run_results
and dbt_objects.dbt_run_results.metadata.generated_at
):
self.context.run_results_generate_time = (
dbt_objects.dbt_run_results.metadata.generated_at
)
for key, manifest_node in manifest_entities.items(): for key, manifest_node in manifest_entities.items():
try: try:
# If the run_results file is passed then only DBT tests will be processed # If the run_results file is passed then only DBT tests will be processed
@ -805,7 +813,8 @@ class DbtSource(DbtServiceSource):
dbt_timestamp = None dbt_timestamp = None
if dbt_test_completed_at: if dbt_test_completed_at:
dbt_timestamp = dbt_test_completed_at.timestamp() dbt_timestamp = dbt_test_completed_at.timestamp()
elif self.context.run_results_generate_time:
dbt_timestamp = self.context.run_results_generate_time.timestamp()
# Create the test case result object # Create the test case result object
test_case_result = TestCaseResult( test_case_result = TestCaseResult(
timestamp=dbt_timestamp, timestamp=dbt_timestamp,