Skip to content

Commit 6659759

Browse files
refactor code
1 parent 09a65f6 commit 6659759

1 file changed

Lines changed: 4 additions & 5 deletions

File tree

ingestion/src/metadata/ingestion/source/database/database_service.py

Lines changed: 4 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -753,11 +753,10 @@ def get_owner_ref(self, table_name: str) -> Optional[EntityReferenceList]:
753753
table_name=table_name,
754754
schema=self.context.get().database_schema,
755755
)
756-
if owner_name:
757-
owner_ref = self.metadata.get_reference_by_name(
758-
name=owner_name, is_owner=True
759-
)
760-
return owner_ref
756+
owner_ref = self.metadata.get_reference_by_name(
757+
name=owner_name, is_owner=True
758+
)
759+
return owner_ref
761760
except Exception as exc:
762761
logger.debug(traceback.format_exc())
763762
logger.warning(f"Error processing owner for table {table_name}: {exc}")

0 commit comments

Comments
 (0)