|
@@ -70,12 +70,12 @@ func (t *TaskSchedule) UpdateMessageHandle(msg *rule.TaskLifecycleMessage) error
|
|
|
if err := NewTaskExecutor(task.Actions).Do(); err != nil {
|
|
|
server.Log.Errorf("do taskid :%s error:%s", task.TaskId, err.Error())
|
|
|
}
|
|
|
- }, task.TaskId)
|
|
|
+ }, msg.TaskId)
|
|
|
if err != nil {
|
|
|
return err
|
|
|
}
|
|
|
|
|
|
- t.tasks.Set(task.TaskId, entity)
|
|
|
+ t.tasks.Set(msg.TaskId, entity)
|
|
|
server.Log.Debugf("UpdateMessageHandle :%s", msg.TaskId)
|
|
|
return nil
|
|
|
}
|