(dolphinscheduler) branch dev updated: Update WorkflowExecuteRunnable.java (#16092)

[zi...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

zihaoxiang pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/dolphinscheduler.git


The following commit(s) were added to refs/heads/dev by this push:
     new d675c28812 Update WorkflowExecuteRunnable.java (#16092)
d675c28812 is described below

commit d675c288122d0048a6d5f14ff392dbf5799411bd
Author: changxiangshimian/changxiangshimian.github.io <14...@qq.com>
AuthorDate: Fri May 31 09:22:26 2024 +0800

    Update WorkflowExecuteRunnable.java (#16092)
    
    Corrected the following issues
    https://github.com/apache/dolphinscheduler/issues/15366
    https://github.com/apache/dolphinscheduler/issues/16010
---
 .../dolphinscheduler/server/master/runner/WorkflowExecuteRunnable.java   | 1 +
 1 file changed, 1 insertion(+)

diff --git a/dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/runner/WorkflowExecuteRunnable.java b/dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/runner/WorkflowExecuteRunnable.java
index 7c27e8c985..c35fd9991f 100644
--- a/dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/runner/WorkflowExecuteRunnable.java
+++ b/dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/runner/WorkflowExecuteRunnable.java
@@ -639,6 +639,7 @@ public class WorkflowExecuteRunnable implements IWorkflowExecuteRunnable {
         command.setProcessInstanceId(0);
         command.setProcessDefinitionVersion(workflowInstance.getProcessDefinitionVersion());
         command.setTestFlag(workflowInstance.getTestFlag());
+        command.setTenantCode(workflowInstance.getTenantCode());
         int create = commandService.createCommand(command);
         processService.saveCommandTrigger(command.getId(), workflowInstance.getId());
         return create;