guessSchema need to decrypt adapterDescription

Signed-off-by: huangyanfeng <[email protected]>
apache · May 11, 2024 · 737a76e · 737a76e
1 parent 7f6ee2d
commit 737a76e
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/...t/src/main/java/org/apache/streampipes/connect/management/management/GuessManagement.java b/...t/src/main/java/org/apache/streampipes/connect/management/management/GuessManagement.java
@@ -31,6 +31,7 @@
 import org.apache.streampipes.model.connect.guess.AdapterEventPreview;
 import org.apache.streampipes.model.connect.guess.GuessSchema;
 import org.apache.streampipes.model.extensions.svcdiscovery.SpServiceTag;
+import org.apache.streampipes.resource.management.secret.SecretProvider;
 import org.apache.streampipes.serializers.json.JacksonSerializer;
 import org.apache.streampipes.svcdiscovery.api.model.SpServiceUrlProvider;
 
@@ -58,6 +59,7 @@ public GuessManagement() {
 
   public GuessSchema guessSchema(AdapterDescription adapterDescription)
       throws ParseException, WorkerAdapterException, NoServiceEndpointsAvailableException, IOException {
+    SecretProvider.getDecryptionService().apply(adapterDescription);
     var workerUrl = getWorkerUrl(
         adapterDescription.getAppId(),
         adapterDescription.getDeploymentConfiguration().getDesiredServiceTags()