diff --git a/metadata-ingestion/src/datahub/ingestion/source/sql/mssql.py b/metadata-ingestion/src/datahub/ingestion/source/sql/mssql.py index a8fc4d0bb413bd..1c8af307f5d5e8 100644 --- a/metadata-ingestion/src/datahub/ingestion/source/sql/mssql.py +++ b/metadata-ingestion/src/datahub/ingestion/source/sql/mssql.py @@ -122,7 +122,7 @@ def __init__(self, config: SQLServerConfig, ctx: PipelineContext): super().__init__(config, ctx, "mssql") # Cache the table and column descriptions self.config: SQLServerConfig = config - self.current_database: Optional[str] = None + self.current_database = None self.table_descriptions: Dict[str, str] = {} self.column_descriptions: Dict[str, str] = {} for inspector in self.get_inspectors(): @@ -262,5 +262,5 @@ def get_identifier( return f"{self.config.database_alias}.{regular}" return f"{self.config.database}.{regular}" if self.current_database: - return f"{self.current_database.lower()}.{regular}" + return f"{self.current_database}.{regular}" return regular