Fix trino deleted tables & catalog as required (#4914)

* Catalog as required for SQLAlchemy * Use catalog properly for db name
2025-07-23 17:30:35 +00:00 · 2022-05-12 19:41:43 +02:00 · 2022-05-12 19:41:43 +02:00 · ab50264ffa
commit ab50264ffa
parent a611338692
2 changed files with 2 additions and 2 deletions
--- a/catalog-rest-service/src/main/resources/json/schema/entity/services/connections/database/trinoConnection.json
+++ b/catalog-rest-service/src/main/resources/json/schema/entity/services/connections/database/trinoConnection.json
@ -92,5 +92,5 @@
    }
  },
  "additionalProperties": false,
-  "required": ["hostPort", "username"]
+  "required": ["hostPort", "username", "catalog"]
 }
--- a/ingestion/src/metadata/ingestion/source/trino.py
+++ b/ingestion/src/metadata/ingestion/source/trino.py
@ -104,7 +104,7 @@ class TrinoSource(SQLSource):
                schema_fqdn = get_fqdn(
                    DatabaseSchema,
                    self.config.serviceName,
-                    self.service_connection.database,
+                    self.service_connection.catalog,
                    schema,
                )
                yield from self.delete_tables(schema_fqdn)