|
@@ -3,6 +3,7 @@ package internal
|
|
import (
|
|
import (
|
|
"context"
|
|
"context"
|
|
"encoding/json"
|
|
"encoding/json"
|
|
|
|
+ "fmt"
|
|
"github.com/gogf/gf/container/gmap"
|
|
"github.com/gogf/gf/container/gmap"
|
|
"github.com/gogf/gf/v2/os/gcron"
|
|
"github.com/gogf/gf/v2/os/gcron"
|
|
"sparrow/pkg/rule"
|
|
"sparrow/pkg/rule"
|
|
@@ -51,7 +52,11 @@ func (t *TaskSchedule) AddMessageHandle(msg *rule.TaskLifecycleMessage) error {
|
|
func (t *TaskSchedule) RemoveMessageHandle(msg *rule.TaskLifecycleMessage) error {
|
|
func (t *TaskSchedule) RemoveMessageHandle(msg *rule.TaskLifecycleMessage) error {
|
|
|
|
|
|
gcron.Remove(msg.TaskId)
|
|
gcron.Remove(msg.TaskId)
|
|
- _ = t.tasks.Remove(msg.TaskId)
|
|
|
|
|
|
+ err := t.tasks.Remove(msg.TaskId)
|
|
|
|
+ if err != nil {
|
|
|
|
+ server.Log.Errorf("remove taskid :%s error:%s", msg.TaskId, err)
|
|
|
|
+ }
|
|
|
|
+ fmt.Println("111111111111111111")
|
|
server.Log.Debugf("RemoveMessageHandle :%s", msg.TaskId)
|
|
server.Log.Debugf("RemoveMessageHandle :%s", msg.TaskId)
|
|
return nil
|
|
return nil
|
|
}
|
|
}
|