去除BaseTask.run中的recover
This commit is contained in:
@@ -388,12 +388,6 @@ func (t *BaseTask) MarshalJSON() ([]byte, error) {
|
|||||||
func (t *BaseTask) run(taskHandler func()) {
|
func (t *BaseTask) run(taskHandler func()) {
|
||||||
if t.GetStatus() == TaskStatusBegin {
|
if t.GetStatus() == TaskStatusBegin {
|
||||||
utils.CallFuncAsync(func() {
|
utils.CallFuncAsync(func() {
|
||||||
defer func() {
|
|
||||||
if r := recover(); r != nil {
|
|
||||||
globals.SugarLogger.Errorf("panic in BaseTask.run task:%s, task detail:%s, r:%v", t.Name, utils.Format4Output(t, false), r)
|
|
||||||
}
|
|
||||||
}()
|
|
||||||
|
|
||||||
taskHandler()
|
taskHandler()
|
||||||
|
|
||||||
task := t
|
task := t
|
||||||
|
|||||||
Reference in New Issue
Block a user