- must receive all result in task.go
This commit is contained in:
@@ -142,7 +142,6 @@ func RunTask(taskName string, worker WorkFunc, resultHandler ResultHandlerFunc,
|
|||||||
if err2, ok := result.(error); ok {
|
if err2, ok := result.(error); ok {
|
||||||
taskResult = nil
|
taskResult = nil
|
||||||
taskErr = err2
|
taskErr = err2
|
||||||
break
|
|
||||||
} else if result != nil {
|
} else if result != nil {
|
||||||
resultList := result.([]interface{})
|
resultList := result.([]interface{})
|
||||||
taskResult = append(taskResult, resultList...)
|
taskResult = append(taskResult, resultList...)
|
||||||
|
|||||||
Reference in New Issue
Block a user