yujunjun/OpenMetadata
1
0
Fork 0
mirror of https://github.com/open-metadata/OpenMetadata.git synced 2025-09-27 01:45:32 +00:00
Code Issues Packages Projects Releases Wiki Activity

MINOR: Enable Log streaming for ingestion pipelines (#23551)

Browse Source
This commit is contained in:
Mayur Singal 2025-09-25 14:35:18 +05:30 committed by GitHub
parent 8eaf4f585d
commit 787d27f3f7
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 3 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
openmetadata-service/src/main/java/org/openmetadata/service/resources/services/ingestionpipelines/IngestionPipelineResource.java
View File

@ -1181,6 +1181,9 @@ public class IngestionPipelineResource
decryptOrNullify(securityContext, ingestionPipeline, true); decryptOrNullify(securityContext, ingestionPipeline, true);
ServiceEntityInterface service = ServiceEntityInterface service =
Entity.getEntity(ingestionPipeline.getService(), "", Include.NON_DELETED); Entity.getEntity(ingestionPipeline.getService(), "", Include.NON_DELETED);
if (repository.isS3LogStorageEnabled()) {
ingestionPipeline.setEnableStreamableLogs(true);
}
PipelineServiceClientResponse status = PipelineServiceClientResponse status =
pipelineServiceClient.deployPipeline(ingestionPipeline, service); pipelineServiceClient.deployPipeline(ingestionPipeline, service);
if (status.getCode() == 200) { if (status.getCode() == 200) {