|
@@ -8,7 +8,6 @@ import (
|
|
|
"hash/fnv"
|
|
|
"runtime"
|
|
|
"strconv"
|
|
|
- "strings"
|
|
|
"sync"
|
|
|
"sync/atomic"
|
|
|
"time"
|
|
@@ -262,10 +261,12 @@ func (l *CronTask) requestCallback(taskData *ent.CompapiAsynctask) (int, error)
|
|
|
return 0, errors.New("call api response empty")
|
|
|
}
|
|
|
|
|
|
- fstr := "mytest-svc:"
|
|
|
- if taskData.RetryCount > 0 && strings.Contains(taskData.CallbackURL, fstr) {
|
|
|
- taskData.CallbackURL = strings.Replace(taskData.CallbackURL, fstr, "0.0.0.0:", 1)
|
|
|
- }
|
|
|
+ /*
|
|
|
+ fstr := "mytest-svc:"
|
|
|
+ if taskData.RetryCount > 0 && strings.Contains(taskData.CallbackURL, fstr) {
|
|
|
+ taskData.CallbackURL = strings.Replace(taskData.CallbackURL, fstr, "0.0.0.0:", 1)
|
|
|
+ }
|
|
|
+ */
|
|
|
|
|
|
//先开启事务更新任务状态 => Callback_Done(回调完成)
|
|
|
tx, err := l.updateTaskStatusByTx(taskData.ID, Callback_Done)
|