diff options
Diffstat (limited to 'modules/indexer/issues/queue_disk.go')
| -rw-r--r-- | modules/indexer/issues/queue_disk.go | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/modules/indexer/issues/queue_disk.go b/modules/indexer/issues/queue_disk.go index be6867f9ca..cf9e6aee22 100644 --- a/modules/indexer/issues/queue_disk.go +++ b/modules/indexer/issues/queue_disk.go @@ -53,7 +53,7 @@ func (l *LevelQueue) Run() error { bs, err := l.queue.RPop() if err != nil { if err != levelqueue.ErrNotFound { - log.Error(4, "RPop: %v", err) + log.Error("RPop: %v", err) } time.Sleep(time.Millisecond * 100) continue @@ -67,7 +67,7 @@ func (l *LevelQueue) Run() error { var data IndexerData err = json.Unmarshal(bs, &data) if err != nil { - log.Error(4, "Unmarshal: %v", err) + log.Error("Unmarshal: %v", err) time.Sleep(time.Millisecond * 100) continue } @@ -77,11 +77,11 @@ func (l *LevelQueue) Run() error { if data.IsDelete { if data.ID > 0 { if err = l.indexer.Delete(data.ID); err != nil { - log.Error(4, "indexer.Delete: %v", err) + log.Error("indexer.Delete: %v", err) } } else if len(data.IDs) > 0 { if err = l.indexer.Delete(data.IDs...); err != nil { - log.Error(4, "indexer.Delete: %v", err) + log.Error("indexer.Delete: %v", err) } } time.Sleep(time.Millisecond * 10) |