From c2d099eca17d50e1224b8001beef6703b511908a Mon Sep 17 00:00:00 2001
From: IceS2 <pjt1991@gmail.com>
Date: Fri, 4 Apr 2025 16:35:16 +0200
Subject: [PATCH] Testing (#20632)

---
 .../CreateAndRunIngestionPipelineTask.java                 | 3 +++
 .../elements/nodes/automatedTask/runApp/RunAppTask.java    | 1 +
 .../workflows/flowable/builders/ServiceTaskBuilder.java    | 7 +++++++
 3 files changed, 11 insertions(+)

diff --git a/openmetadata-service/src/main/java/org/openmetadata/service/governance/workflows/elements/nodes/automatedTask/createAndRunIngestionPipeline/CreateAndRunIngestionPipelineTask.java b/openmetadata-service/src/main/java/org/openmetadata/service/governance/workflows/elements/nodes/automatedTask/createAndRunIngestionPipeline/CreateAndRunIngestionPipelineTask.java
index bde433e8f63..47322354cd9 100644
--- a/openmetadata-service/src/main/java/org/openmetadata/service/governance/workflows/elements/nodes/automatedTask/createAndRunIngestionPipeline/CreateAndRunIngestionPipelineTask.java
+++ b/openmetadata-service/src/main/java/org/openmetadata/service/governance/workflows/elements/nodes/automatedTask/createAndRunIngestionPipeline/CreateAndRunIngestionPipelineTask.java
@@ -138,6 +138,7 @@ public class CreateAndRunIngestionPipelineTask implements NodeInterface {
         .addFieldExtension(inputNamespaceMapExpr)
         .addFieldExtension(pipelineServiceClientExpr)
         .setAsync(true)
+        .exclusive(true)
         .build();
   }
 
@@ -181,6 +182,8 @@ public class CreateAndRunIngestionPipelineTask implements NodeInterface {
         .addFieldExtension(ingestionPipelineMapperExpr)
         .addFieldExtension(pipelineServiceClientExpr)
         .addFieldExtension(inputNamespaceMapExpr)
+        .setAsync(true)
+        .exclusive(true)
         .build();
   }
 
diff --git a/openmetadata-service/src/main/java/org/openmetadata/service/governance/workflows/elements/nodes/automatedTask/runApp/RunAppTask.java b/openmetadata-service/src/main/java/org/openmetadata/service/governance/workflows/elements/nodes/automatedTask/runApp/RunAppTask.java
index e6afb52cdaa..c5779562e56 100644
--- a/openmetadata-service/src/main/java/org/openmetadata/service/governance/workflows/elements/nodes/automatedTask/runApp/RunAppTask.java
+++ b/openmetadata-service/src/main/java/org/openmetadata/service/governance/workflows/elements/nodes/automatedTask/runApp/RunAppTask.java
@@ -106,6 +106,7 @@ public class RunAppTask implements NodeInterface {
         .addFieldExtension(inputNamespaceMapExpr)
         .addFieldExtension(pipelineServiceClientExpr)
         .setAsync(true)
+        .exclusive(true)
         .build();
   }
 
diff --git a/openmetadata-service/src/main/java/org/openmetadata/service/governance/workflows/flowable/builders/ServiceTaskBuilder.java b/openmetadata-service/src/main/java/org/openmetadata/service/governance/workflows/flowable/builders/ServiceTaskBuilder.java
index 33927f4ceb6..fdb7d62093e 100644
--- a/openmetadata-service/src/main/java/org/openmetadata/service/governance/workflows/flowable/builders/ServiceTaskBuilder.java
+++ b/openmetadata-service/src/main/java/org/openmetadata/service/governance/workflows/flowable/builders/ServiceTaskBuilder.java
@@ -9,6 +9,7 @@ public class ServiceTaskBuilder extends FlowableElementBuilder<ServiceTaskBuilde
   private String implementation;
   private String implementationType = "class";
   private boolean async = false;
+  private boolean exclusive = false;
   private final List<FieldExtension> fieldExtensions = new ArrayList<>();
 
   public ServiceTaskBuilder implementation(String implementation) {
@@ -31,6 +32,11 @@ public class ServiceTaskBuilder extends FlowableElementBuilder<ServiceTaskBuilde
     return this;
   }
 
+  public ServiceTaskBuilder exclusive(boolean exclusive) {
+    this.exclusive = exclusive;
+    return this;
+  }
+
   @Override
   public ServiceTask build() {
     ServiceTask serviceTask = new ServiceTask();
@@ -39,6 +45,7 @@ public class ServiceTaskBuilder extends FlowableElementBuilder<ServiceTaskBuilde
     serviceTask.setImplementationType(implementationType);
     serviceTask.setImplementation(implementation);
     serviceTask.setAsynchronous(async);
+    serviceTask.setExclusive(exclusive);
 
     for (FieldExtension fieldExtension : fieldExtensions) {
       serviceTask.getFieldExtensions().add(fieldExtension);