From 787d27f3f79e920be3850f311c310407c3afb82c Mon Sep 17 00:00:00 2001
From: Mayur Singal <39544459+ulixius9@users.noreply.github.com>
Date: Thu, 25 Sep 2025 14:35:18 +0530
Subject: [PATCH] MINOR: Enable Log streaming for ingestion pipelines (#23551)

---
 .../services/ingestionpipelines/IngestionPipelineResource.java | 3 +++
 1 file changed, 3 insertions(+)

diff --git a/openmetadata-service/src/main/java/org/openmetadata/service/resources/services/ingestionpipelines/IngestionPipelineResource.java b/openmetadata-service/src/main/java/org/openmetadata/service/resources/services/ingestionpipelines/IngestionPipelineResource.java
index 58d4aefc860..cc375d713d4 100644
--- a/openmetadata-service/src/main/java/org/openmetadata/service/resources/services/ingestionpipelines/IngestionPipelineResource.java
+++ b/openmetadata-service/src/main/java/org/openmetadata/service/resources/services/ingestionpipelines/IngestionPipelineResource.java
@@ -1181,6 +1181,9 @@ public class IngestionPipelineResource
     decryptOrNullify(securityContext, ingestionPipeline, true);
     ServiceEntityInterface service =
         Entity.getEntity(ingestionPipeline.getService(), "", Include.NON_DELETED);
+    if (repository.isS3LogStorageEnabled()) {
+      ingestionPipeline.setEnableStreamableLogs(true);
+    }
     PipelineServiceClientResponse status =
         pipelineServiceClient.deployPipeline(ingestionPipeline, service);
     if (status.getCode() == 200) {