yujunjun/OpenMetadata
1
0
Fork 0
mirror of https://github.com/open-metadata/OpenMetadata.git synced 2025-10-12 01:08:18 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fix ReRun by actually setting the OpenMetadataConnection properly (#20810)

Browse Source
This commit is contained in:
IceS2 2025-04-14 14:43:53 +02:00 committed by GitHub
parent 334485f211
commit 5239c09f17
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 8 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -42,11 +42,13 @@ import org.openmetadata.schema.metadataIngestion.PipelineServiceMetadataPipeline
import org.openmetadata.schema.metadataIngestion.SearchServiceMetadataPipeline; import org.openmetadata.schema.metadataIngestion.SearchServiceMetadataPipeline;
import org.openmetadata.schema.metadataIngestion.SourceConfig; import org.openmetadata.schema.metadataIngestion.SourceConfig;
import org.openmetadata.schema.metadataIngestion.StorageServiceMetadataPipeline; import org.openmetadata.schema.metadataIngestion.StorageServiceMetadataPipeline;
import org.openmetadata.schema.services.connections.metadata.OpenMetadataConnection;
import org.openmetadata.sdk.PipelineServiceClientInterface; import org.openmetadata.sdk.PipelineServiceClientInterface;
import org.openmetadata.service.Entity; import org.openmetadata.service.Entity;
import org.openmetadata.service.jdbi3.IngestionPipelineRepository; import org.openmetadata.service.jdbi3.IngestionPipelineRepository;
import org.openmetadata.service.resources.services.ingestionpipelines.IngestionPipelineMapper; import org.openmetadata.service.resources.services.ingestionpipelines.IngestionPipelineMapper;
import org.openmetadata.service.util.JsonUtils; import org.openmetadata.service.util.JsonUtils;
import org.openmetadata.service.util.OpenMetadataConnectionBuilder;
@Slf4j @Slf4j
public class CreateIngestionPipelineImpl { public class CreateIngestionPipelineImpl {
@ -262,7 +264,12 @@ public class CreateIngestionPipelineImpl {
JsonUtils.readOrConvertValue(ingestionPipelineStr, IngestionPipeline.class); JsonUtils.readOrConvertValue(ingestionPipelineStr, IngestionPipeline.class);
if (ingestionPipeline.getPipelineType().equals(pipelineType) if (ingestionPipeline.getPipelineType().equals(pipelineType)
&& ingestionPipeline.getDisplayName().equals(displayName)) { && ingestionPipeline.getDisplayName().equals(displayName)) {
return ingestionPipeline.withService(service.getEntityReference()); OpenMetadataConnection openMetadataServerConnection =
new OpenMetadataConnectionBuilder(repository.getOpenMetadataApplicationConfig())
.build();
return ingestionPipeline
.withService(service.getEntityReference())
.withOpenMetadataServerConnection(openMetadataServerConnection);
} }
} }
return null; return null;