diff --git a/backend/modules/integrations/usecase/module.go b/backend/modules/integrations/usecase/module.go index b1507e7a5..25327802b 100644 --- a/backend/modules/integrations/usecase/module.go +++ b/backend/modules/integrations/usecase/module.go @@ -167,7 +167,7 @@ func (u *moduleUsecase) Create(ctx context.Context, req dto.CreateModuleRequest) } if _,err:= u.opensearch.Create(ctx,os_dto.CreateIndexPatternRequest{ - PatternModule: &req.ModuleName, + PatternModule: &req.DataType, });err!=nil{ //opensearch insertion fails, rolling back database if err:=u.repo.Delete(ctx,m.ID);err!=nil{ diff --git a/backend/pkg/constants/custom_integrations.go b/backend/pkg/constants/custom_integrations.go index b6386cbde..749bab07e 100644 --- a/backend/pkg/constants/custom_integrations.go +++ b/backend/pkg/constants/custom_integrations.go @@ -1,5 +1,5 @@ package constants const( - CUSTOM_INDEX_PREFIX = "custom"; + CUSTOM_INDEX_PREFIX = "v11-log"; )