diff options
Diffstat (limited to 'services/task')
| -rw-r--r-- | services/task/task.go | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/services/task/task.go b/services/task/task.go index 376fe1dce1..3f823fc224 100644 --- a/services/task/task.go +++ b/services/task/task.go @@ -49,13 +49,14 @@ func Init() error { return nil } -func handle(data ...queue.Data) { +func handle(data ...queue.Data) []queue.Data { for _, datum := range data { task := datum.(*models.Task) if err := Run(task); err != nil { log.Error("Run task failed: %v", err) } } + return nil } // MigrateRepository add migration repository to task |