yujunjun/OpenMetadata
1
0
Fork 0
mirror of https://github.com/open-metadata/OpenMetadata.git synced 2025-08-15 04:26:59 +00:00
Code Issues Packages Projects Releases Wiki Activity

MINOR: Update DayOneWorkflow Agent Names (#20473)

Browse Source 
* Update DayOneWorkflow Agent Names

* Migrations for CollateAI DisplayName Update

* Remove wrong migrations
This commit is contained in:
IceS2 2025-03-28 14:01:42 +01:00 committed by GitHub
parent 162244a127
commit c9182016db
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
2 changed files with 14 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
bootstrap/sql/migrations/native/1.7.0/postgres/schemaChanges.sql
View File

@ -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');

14
openmetadata-service/src/main/java/org/openmetadata/service/governance/workflows/elements/nodes/automatedTask/createAndRunIngestionPipeline/CreateIngestionPipelineImpl.java
View File

@ -192,9 +192,21 @@ public class CreateIngestionPipelineImpl {
return response.getCode() == 200;
}
private String getPipelineName(PipelineType pipelineType) {
Map<PipelineType, String> 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);