yujunjun/OpenMetadata
1
0
Fork 0
mirror of https://github.com/open-metadata/OpenMetadata.git synced 2026-01-06 04:26:57 +00:00
Code Issues Packages Projects Releases Wiki Activity

Add Check for Null destinations (#20717)

Browse Source
This commit is contained in:
Mohit Yadav 2025-04-09 12:02:43 +05:30 committed by GitHub
parent 7c5ba41630
commit 4aa070f04e
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 11 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
openmetadata-service/src/main/java/org/openmetadata/service/migration/utils/v140/MigrationUtil.java
View File

@ -57,15 +57,17 @@ public class MigrationUtil {
JSONObject jsonObj = new JSONObject(eventSubscription);
// Read array detination if exist and check subscription type if Generic then change to
// Webhook
JSONArray destination = jsonObj.getJSONArray("destinations");
if (destination != null && !destination.isEmpty()) {
for (Object value : destination) {
JSONObject destinationObj = (JSONObject) value;
if (destinationObj.getString("type").equals("Generic")) {
destinationObj.put("type", "Webhook");
collectionDAO
.eventSubscriptionDAO()
.update(JsonUtils.readValue(jsonObj.toString(), EventSubscription.class));
if (jsonObj.keySet().contains("destinations")) {
JSONArray destination = jsonObj.getJSONArray("destinations");
if (destination != null && !destination.isEmpty()) {
for (Object value : destination) {
JSONObject destinationObj = (JSONObject) value;
if (destinationObj.getString("type").equals("Generic")) {
destinationObj.put("type", "Webhook");
collectionDAO
.eventSubscriptionDAO()
.update(JsonUtils.readValue(jsonObj.toString(), EventSubscription.class));
}
}
}
}