diff --git a/catalog-rest-service/src/main/java/org/openmetadata/catalog/jdbi3/TypeRepository.java b/catalog-rest-service/src/main/java/org/openmetadata/catalog/jdbi3/TypeRepository.java index 260a2938f06..28edd37cbf0 100644 --- a/catalog-rest-service/src/main/java/org/openmetadata/catalog/jdbi3/TypeRepository.java +++ b/catalog-rest-service/src/main/java/org/openmetadata/catalog/jdbi3/TypeRepository.java @@ -72,6 +72,10 @@ public class TypeRepository extends EntityRepository { updateTypeMap(type); } + public void addToRegistry(Type type) { + updateTypeMap(type); + } + @Override public void storeRelationships(Type type) { // Nothing to do diff --git a/catalog-rest-service/src/main/java/org/openmetadata/catalog/resources/types/TypeResource.java b/catalog-rest-service/src/main/java/org/openmetadata/catalog/resources/types/TypeResource.java index 0e987b70624..67e23f18002 100644 --- a/catalog-rest-service/src/main/java/org/openmetadata/catalog/resources/types/TypeResource.java +++ b/catalog-rest-service/src/main/java/org/openmetadata/catalog/resources/types/TypeResource.java @@ -114,6 +114,7 @@ public class TypeResource extends EntityResource { LOG.debug("Creating entity that does not exist ", e); } this.dao.createOrUpdate(null, type); + this.dao.addToRegistry(type); } catch (IOException e) { LOG.error("Error loading type {}", type.getName(), e); }