diff --git a/bootstrap/sql/migrations/native/1.7.0/postgres/schemaChanges.sql b/bootstrap/sql/migrations/native/1.7.0/postgres/schemaChanges.sql index 1e588cbf760..b38b3e6258a 100644 --- a/bootstrap/sql/migrations/native/1.7.0/postgres/schemaChanges.sql +++ b/bootstrap/sql/migrations/native/1.7.0/postgres/schemaChanges.sql @@ -48,4 +48,4 @@ CREATE INDEX IF NOT EXISTS query_cost_time_series_id_timestamp on test_case_res UPDATE workflow_definition_entity SET json = jsonb_set(json, '{trigger,type}', '"periodicBatchEntity"') - WHERE json->'trigger'->>'type' in ('periodicBatchEntityTrigger', 'periodicBatchEntityWorkflow'); + WHERE json->'trigger'->>'type' in ('periodicBatchEntityTrigger', 'periodicBatchEntityWorkflow'); \ No newline at end of file diff --git a/openmetadata-service/src/main/java/org/openmetadata/service/governance/workflows/elements/nodes/automatedTask/createAndRunIngestionPipeline/CreateIngestionPipelineImpl.java b/openmetadata-service/src/main/java/org/openmetadata/service/governance/workflows/elements/nodes/automatedTask/createAndRunIngestionPipeline/CreateIngestionPipelineImpl.java index 04e68259e73..d624a1c1e70 100644 --- a/openmetadata-service/src/main/java/org/openmetadata/service/governance/workflows/elements/nodes/automatedTask/createAndRunIngestionPipeline/CreateIngestionPipelineImpl.java +++ b/openmetadata-service/src/main/java/org/openmetadata/service/governance/workflows/elements/nodes/automatedTask/createAndRunIngestionPipeline/CreateIngestionPipelineImpl.java @@ -192,9 +192,21 @@ public class CreateIngestionPipelineImpl { return response.getCode() == 200; } + private String getPipelineName(PipelineType pipelineType) { + Map pipelineNameByType = + Map.of( + PipelineType.METADATA, "Metadata Agent", + PipelineType.USAGE, "Usage Agent", + PipelineType.LINEAGE, "Lineage Agent", + PipelineType.PROFILER, "Profiler Agent", + PipelineType.AUTO_CLASSIFICATION, "AutoClassification Agent"); + + return pipelineNameByType.get(pipelineType); + } + private IngestionPipeline getOrCreateIngestionPipeline( PipelineType pipelineType, ServiceEntityInterface service) { - String displayName = String.format("[%s] %s", service.getName(), pipelineType); + String displayName = getPipelineName(pipelineType); IngestionPipelineRepository repository = (IngestionPipelineRepository) Entity.getEntityRepository(Entity.INGESTION_PIPELINE);