remove: Re-execution does not require im notification and unused chan

Author: iwanghc

sqle/api/controller/v1/workflow.go

@@ -20,7 +20,6 @@ import (
 	"github.com/actiontech/sqle/sqle/errors"
 	"github.com/actiontech/sqle/sqle/log"
 	"github.com/actiontech/sqle/sqle/model"
-	"github.com/actiontech/sqle/sqle/pkg/im"
 	"github.com/actiontech/sqle/sqle/server"
 	"github.com/actiontech/sqle/sqle/utils"
 
@@ -1404,8 +1403,6 @@ func ReExecuteTaskOnWorkflowV1(c echo.Context) error {
 		return controller.JSONBaseErrorReq(c, err)
 	}
 
-	im.UpdateApprove(workflow.WorkflowId, user, model.ApproveStatusAgree, "")
-
 	return c.JSON(http.StatusOK, controller.NewBaseReq(nil))
 }
 

sqle/server/workflow.go

@@ -54,14 +54,13 @@ func ReExecuteTaskSQLs(workflow *model.Workflow, task *model.Task, execSqlIds []
 	if err != nil {
 		return err
 	}
-	workflowStatusChan := make(chan string, 1)
 	var lock sync.Mutex
 	go func() {
 		sqledServer := GetSqled()
 		task, err := sqledServer.AddTaskWaitResultWithSQLIds(string(workflow.ProjectId), strconv.Itoa(int(task.ID)), execSqlIds, ActionTypeExecute)
-		{ // NOTE: Update the workflow status before sending notifications to ensure that the notification content reflects the latest information.
+		{
 			lock.Lock()
-			updateStatus(s, workflow, l, workflowStatusChan)
+			updateStatus(s, workflow, l, nil)
 			lock.Unlock()
 		}
 		if err != nil || task.Status == model.TaskStatusExecuteFailed {