diff --git a/workflow-engine-core/src/main/java/cn/axzo/workflow/core/service/impl/BpmnProcessActivityServiceImpl.java b/workflow-engine-core/src/main/java/cn/axzo/workflow/core/service/impl/BpmnProcessActivityServiceImpl.java
index 3a456d5ba..36bee1a63 100644
--- a/workflow-engine-core/src/main/java/cn/axzo/workflow/core/service/impl/BpmnProcessActivityServiceImpl.java
+++ b/workflow-engine-core/src/main/java/cn/axzo/workflow/core/service/impl/BpmnProcessActivityServiceImpl.java
@@ -9,6 +9,7 @@ import cn.axzo.workflow.core.service.BpmnProcessActivityService;
 import cn.axzo.workflow.core.service.ExtAxHiTaskInstService;
 import cn.hutool.json.JSONUtil;
 import lombok.extern.slf4j.Slf4j;
+import org.flowable.common.engine.impl.interceptor.Command;
 import org.flowable.common.engine.impl.interceptor.CommandExecutor;
 import org.flowable.engine.RuntimeService;
 import org.flowable.engine.runtime.Execution;
@@ -43,6 +44,7 @@ public class BpmnProcessActivityServiceImpl implements BpmnProcessActivityServic
     private static final String JOB_TRIGGER_ASYNC_NAME = "asyncTrigger";
     private static final String JOB_ASSIGNEE_ASYNC_NAME = "asyncSetAssignee";
 
+    @Override
     public void executeAsyncJob(JobEntity job) {
         if (job == null) {
             log.error("job is null");
@@ -74,7 +76,11 @@ public class BpmnProcessActivityServiceImpl implements BpmnProcessActivityServic
 
     @Override
     public void triggerAsync(String executionId) {
-        validateAndStartAsyncJob(executionId, executionId, JOB_TRIGGER_ASYNC_NAME);
+        processEngineConfiguration.getCommandExecutor().execute((Command<Void>) commandContext -> {
+            validateAndStartAsyncJob(executionId, executionId, JOB_TRIGGER_ASYNC_NAME);
+            return null;
+        });
+
     }
 
     @Override