diff --git a/openmetadata-service/src/main/java/org/openmetadata/service/OpenMetadataApplication.java b/openmetadata-service/src/main/java/org/openmetadata/service/OpenMetadataApplication.java index 3f14e328d7f..e9aa3d573a7 100644 --- a/openmetadata-service/src/main/java/org/openmetadata/service/OpenMetadataApplication.java +++ b/openmetadata-service/src/main/java/org/openmetadata/service/OpenMetadataApplication.java @@ -149,12 +149,15 @@ public class OpenMetadataApplication extends Application())); + // as first step register all the repositories + Entity.initializeRepositories(collectionDAO); + + // Init Settings Cache after repositories + SettingsCache.initialize(catalogConfig); + // Configure the Fernet instance Fernet.getInstance().setFernetKey(catalogConfig); - // Init Settings Cache - SettingsCache.initialize(catalogConfig); - // init Secret Manager final SecretsManager secretsManager = SecretsManagerFactory.createSecretsManager( diff --git a/openmetadata-service/src/main/java/org/openmetadata/service/resources/CollectionRegistry.java b/openmetadata-service/src/main/java/org/openmetadata/service/resources/CollectionRegistry.java index 3fece14e305..03df3c51869 100644 --- a/openmetadata-service/src/main/java/org/openmetadata/service/resources/CollectionRegistry.java +++ b/openmetadata-service/src/main/java/org/openmetadata/service/resources/CollectionRegistry.java @@ -38,7 +38,6 @@ import org.openmetadata.common.utils.CommonUtil; import org.openmetadata.schema.Function; import org.openmetadata.schema.type.CollectionDescriptor; import org.openmetadata.schema.type.CollectionInfo; -import org.openmetadata.service.Entity; import org.openmetadata.service.OpenMetadataApplicationConfig; import org.openmetadata.service.jdbi3.CollectionDAO; import org.openmetadata.service.security.Authorizer; @@ -164,7 +163,6 @@ public final class CollectionRegistry { CollectionDAO daoObject, Authorizer authorizer, AuthenticatorHandler authenticatorHandler) { - Entity.initializeRepositories(daoObject); // Build list of ResourceDescriptors for (Map.Entry e : collectionMap.entrySet()) { CollectionDetails details = e.getValue(); diff --git a/openmetadata-service/src/main/java/org/openmetadata/service/resources/services/ingestionpipelines/IngestionPipelineResource.java b/openmetadata-service/src/main/java/org/openmetadata/service/resources/services/ingestionpipelines/IngestionPipelineResource.java index f8856271442..d153f534fd2 100644 --- a/openmetadata-service/src/main/java/org/openmetadata/service/resources/services/ingestionpipelines/IngestionPipelineResource.java +++ b/openmetadata-service/src/main/java/org/openmetadata/service/resources/services/ingestionpipelines/IngestionPipelineResource.java @@ -17,7 +17,6 @@ import static org.openmetadata.common.utils.CommonUtil.listOrEmpty; import static org.openmetadata.service.Entity.FIELD_OWNER; import static org.openmetadata.service.Entity.FIELD_PIPELINE_STATUS; import static org.openmetadata.service.jdbi3.IngestionPipelineRepository.validateProfileSample; -import static org.openmetadata.service.resources.services.metadata.MetadataServiceResource.OPENMETADATA_SERVICE; import io.swagger.v3.oas.annotations.ExternalDocumentation; import io.swagger.v3.oas.annotations.Hidden; @@ -61,15 +60,10 @@ import org.openmetadata.schema.api.services.ingestionPipelines.CreateIngestionPi import org.openmetadata.schema.entity.services.ingestionPipelines.IngestionPipeline; import org.openmetadata.schema.entity.services.ingestionPipelines.PipelineServiceClientResponse; import org.openmetadata.schema.entity.services.ingestionPipelines.PipelineStatus; -import org.openmetadata.schema.entity.services.ingestionPipelines.PipelineType; -import org.openmetadata.schema.metadataIngestion.MetadataToElasticSearchPipeline; -import org.openmetadata.schema.metadataIngestion.SourceConfig; import org.openmetadata.schema.services.connections.metadata.OpenMetadataConnection; import org.openmetadata.schema.type.EntityHistory; -import org.openmetadata.schema.type.EntityReference; import org.openmetadata.schema.type.Include; import org.openmetadata.schema.type.MetadataOperation; -import org.openmetadata.schema.type.ProviderType; import org.openmetadata.sdk.PipelineServiceClient; import org.openmetadata.service.Entity; import org.openmetadata.service.OpenMetadataApplicationConfig; @@ -85,7 +79,6 @@ import org.openmetadata.service.security.AuthorizationException; import org.openmetadata.service.security.Authorizer; import org.openmetadata.service.security.policyevaluator.OperationContext; import org.openmetadata.service.util.EntityUtil.Fields; -import org.openmetadata.service.util.IngestionPipelineUtils; import org.openmetadata.service.util.OpenMetadataConnectionBuilder; import org.openmetadata.service.util.ResultList; @@ -125,51 +118,6 @@ public class IngestionPipelineResource extends EntityResource {