diff --git a/openmetadata-service/src/main/java/org/openmetadata/service/governance/workflows/elements/triggers/PeriodicBatchEntityTrigger.java b/openmetadata-service/src/main/java/org/openmetadata/service/governance/workflows/elements/triggers/PeriodicBatchEntityTrigger.java index 3a9eb500e80..800a614b3c6 100644 --- a/openmetadata-service/src/main/java/org/openmetadata/service/governance/workflows/elements/triggers/PeriodicBatchEntityTrigger.java +++ b/openmetadata-service/src/main/java/org/openmetadata/service/governance/workflows/elements/triggers/PeriodicBatchEntityTrigger.java @@ -163,6 +163,8 @@ public class PeriodicBatchEntityTrigger implements TriggerInterface { serviceTask.getFieldExtensions().add(searchFilterExpr); serviceTask.getFieldExtensions().add(batchSizeExpr); + serviceTask.setAsynchronousLeave(true); + return serviceTask; }