Skip to content

Commit 56fd356

Browse files
committed
feat(ingest/mssql): skip inaccessible databases when configured database=null
1 parent 2634d41 commit 56fd356

File tree

1 file changed

+12
-1
lines changed
  • metadata-ingestion/src/datahub/ingestion/source/sql/mssql

1 file changed

+12
-1
lines changed

metadata-ingestion/src/datahub/ingestion/source/sql/mssql/source.py

Lines changed: 12 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1271,7 +1271,18 @@ def get_inspectors(self) -> Iterable[Inspector]:
12711271
url = self.config.get_sql_alchemy_url(
12721272
current_db=db["name"], is_odbc=self._is_odbc
12731273
)
1274-
engine = create_engine(url, **self.config.options)
1274+
try:
1275+
engine = create_engine(url, **self.config.options)
1276+
except OperationalError as e:
1277+
if re.search(r"(?i)login failed", str(e)):
1278+
logger.warning(
1279+
f"Error logging in to database {db['name']}: {e}"
1280+
)
1281+
self.report.report_warning(
1282+
"Error logging in to database", db["name"], exc=e
1283+
)
1284+
continue
1285+
raise
12751286
inspector = inspect(engine)
12761287
self.current_database = db["name"]
12771288
yield inspector

0 commit comments

Comments
 (0)