[dolphinscheduler] branch dev updated: [Fix-14714][master] package task instance before put into cache (#14718)

[zihaoxiang]

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 7c37a7f9fe [Fix-14714][master] package task instance before put into 
cache (#14718)
7c37a7f9fe is described below

commit 7c37a7f9feb9df0f3c92ccab4dfdb67e25d1bfae
Author: eye-gu <734164...@qq.com>
AuthorDate: Wed Aug 9 13:41:28 2023 +0800

    [Fix-14714][master] package task instance before put into cache (#14718)
    
    Co-authored-by: eye <eye...@aloudata.com>
    Co-authored-by: xiangzihao <460888...@qq.com>
---
 .../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 389834d25d..4d32ebbff3 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
@@ -849,6 +849,7 @@ public class WorkflowExecuteRunnable implements 
IWorkflowExecuteRunnable {
                         }
                     }
 
+                    processService.packageTaskInstance(task, workflowInstance);
                     validTaskMap.put(task.getTaskCode(), task.getId());
                     taskInstanceMap.put(task.getId(), task);
                     taskCodeInstanceMap.put(task.getTaskCode(), task);