From f54e902bfed72588696425cfee255d6905916d26 Mon Sep 17 00:00:00 2001
From: Teddy <teddy.crepineau@gmail.com>
Date: Tue, 16 Sep 2025 08:01:27 +0200
Subject: [PATCH] fix: implement noop decryptConfig for external app pipeline
 generation (#23407)

---
 .../service/apps/AbstractNativeApplication.java        | 10 ++++++++--
 1 file changed, 8 insertions(+), 2 deletions(-)

diff --git a/openmetadata-service/src/main/java/org/openmetadata/service/apps/AbstractNativeApplication.java b/openmetadata-service/src/main/java/org/openmetadata/service/apps/AbstractNativeApplication.java
index 9c422462ddc..56e076a130a 100644
--- a/openmetadata-service/src/main/java/org/openmetadata/service/apps/AbstractNativeApplication.java
+++ b/openmetadata-service/src/main/java/org/openmetadata/service/apps/AbstractNativeApplication.java
@@ -182,22 +182,28 @@ public class AbstractNativeApplication implements NativeApplication {
     }
   }
 
+  protected Map<String, Object> decryptConfiguration(Map<String, Object> appConfig) {
+    return appConfig;
+  }
+
   private void updateAppConfig(
       IngestionPipelineRepository repository,
       Map<String, Object> appConfiguration,
       String updatedBy) {
+    Map<String, Object> decryptedConfig = decryptConfiguration(appConfiguration);
     String fqn = FullyQualifiedName.add(SERVICE_NAME, this.getApp().getName());
     IngestionPipeline updated = repository.findByName(fqn, Include.NON_DELETED);
     ApplicationPipeline appPipeline =
         JsonUtils.convertValue(updated.getSourceConfig().getConfig(), ApplicationPipeline.class);
     IngestionPipeline original = JsonUtils.deepCopy(updated, IngestionPipeline.class);
     updated.setSourceConfig(
-        updated.getSourceConfig().withConfig(appPipeline.withAppConfig(appConfiguration)));
+        updated.getSourceConfig().withConfig(appPipeline.withAppConfig(decryptedConfig)));
     repository.update(null, original, updated, updatedBy);
   }
 
   private void createAndBindIngestionPipeline(
       IngestionPipelineRepository ingestionPipelineRepository, Map<String, Object> config) {
+    Map<String, Object> decryptedConfig = decryptConfiguration(config);
     MetadataServiceRepository serviceEntityRepository =
         (MetadataServiceRepository) Entity.getEntityRepository(Entity.METADATA_SERVICE);
     EntityReference service =
@@ -216,7 +222,7 @@ public class AbstractNativeApplication implements NativeApplication {
                     .withConfig(
                         new ApplicationPipeline()
                             .withSourcePythonClass(this.getApp().getSourcePythonClass())
-                            .withAppConfig(config)
+                            .withAppConfig(decryptedConfig)
                             .withAppPrivateConfig(this.getApp().getPrivateConfiguration())))
             .withAirflowConfig(
                 new AirflowConfig()