[inlong] branch master updated: [INLONG-5052][Manager] The workflow that failed to execute still failed, but returned success (#5053)

[dockerzhang]

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

dockerzhang pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/inlong.git


The following commit(s) were added to refs/heads/master by this push:
     new fd6e150e6 [INLONG-5052][Manager] The workflow that failed to execute 
still failed, but returned success (#5053)
fd6e150e6 is described below

commit fd6e150e6efec015f662da7bd5adab556a492706
Author: fuweng11 <76141879+fuwen...@users.noreply.github.com>
AuthorDate: Fri Jul 15 09:09:11 2022 +0800

    [INLONG-5052][Manager] The workflow that failed to execute still failed, 
but returned success (#5053)
---
 .../org/apache/inlong/manager/workflow/core/impl/TaskServiceImpl.java  | 3 +++
 1 file changed, 3 insertions(+)

diff --git 
a/inlong-manager/manager-workflow/src/main/java/org/apache/inlong/manager/workflow/core/impl/TaskServiceImpl.java
 
b/inlong-manager/manager-workflow/src/main/java/org/apache/inlong/manager/workflow/core/impl/TaskServiceImpl.java
index e34ce977b..723bb1708 100644
--- 
a/inlong-manager/manager-workflow/src/main/java/org/apache/inlong/manager/workflow/core/impl/TaskServiceImpl.java
+++ 
b/inlong-manager/manager-workflow/src/main/java/org/apache/inlong/manager/workflow/core/impl/TaskServiceImpl.java
@@ -23,6 +23,7 @@ import org.apache.inlong.manager.workflow.WorkflowContext;
 import org.apache.inlong.manager.workflow.core.ProcessorExecutor;
 import org.apache.inlong.manager.workflow.core.TaskService;
 import org.apache.inlong.manager.workflow.core.WorkflowContextBuilder;
+import org.apache.inlong.manager.workflow.definition.ServiceTask;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 
@@ -67,6 +68,8 @@ public class TaskServiceImpl implements TaskService {
     public WorkflowContext complete(Integer taskId, String remark, String 
operator) {
         WorkflowContext context = workflowContextBuilder
                 .buildContextForTask(taskId, WorkflowAction.COMPLETE, remark, 
operator);
+        ServiceTask serviceTask = (ServiceTask) 
context.getActionContext().getTask();
+        serviceTask.initListeners(context);
         
processorExecutor.executeComplete(context.getActionContext().getTask(), 
context);
         return context;
     }