diff options
Diffstat (limited to 'services/mirror/mirror.go')
| -rw-r--r-- | services/mirror/mirror.go | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/services/mirror/mirror.go b/services/mirror/mirror.go index 2643200174..6f285ec467 100644 --- a/services/mirror/mirror.go +++ b/services/mirror/mirror.go @@ -130,11 +130,12 @@ func Update(ctx context.Context, pullLimit, pushLimit int) error { return nil } -func queueHandle(data ...queue.Data) { +func queueHandle(data ...queue.Data) []queue.Data { for _, datum := range data { req := datum.(*SyncRequest) doMirrorSync(graceful.GetManager().ShutdownContext(), req) } + return nil } // InitSyncMirrors initializes a go routine to sync the mirrors |