diff --git a/ingestion/src/metadata/test_suite/api/workflow.py b/ingestion/src/metadata/test_suite/api/workflow.py index e712855802b..e9fdb824f00 100644 --- a/ingestion/src/metadata/test_suite/api/workflow.py +++ b/ingestion/src/metadata/test_suite/api/workflow.py @@ -155,11 +155,23 @@ class TestSuiteWorkflow: ) ) service_connection_config = deepcopy(service_connection.__root__.config) - if ( - hasattr(service_connection_config, "supportsDatabase") - and not service_connection_config.database - ): - service_connection_config.database = table_fqn.split(".")[1] + if hasattr(service_connection_config, "supportsDatabase"): + if ( + hasattr( + service_connection_config, + "database", + ) + and not service_connection_config.database + ): + service_connection_config.database = table_fqn.split(".")[1] + if ( + hasattr( + service_connection_config, + "catalog", + ) + and not service_connection_config.catalog + ): + service_connection_config.catalog = table_fqn.split(".")[1] return service_connection_config logger.error(