mirror of
https://github.com/terorie/od-database-crawler.git
synced 2025-12-14 15:49:02 +00:00
Resume log messages
This commit is contained in:
@@ -72,6 +72,9 @@ func ResumeTasks() (tasks []*OD, err error) {
|
|||||||
}
|
}
|
||||||
|
|
||||||
func resumeQueue(id uint64) (od *OD, err error) {
|
func resumeQueue(id uint64) (od *OD, err error) {
|
||||||
|
logrus.WithField("id", id).
|
||||||
|
Info("Found unfinished")
|
||||||
|
|
||||||
fPath := filepath.Join("queue", strconv.FormatUint(id, 10))
|
fPath := filepath.Join("queue", strconv.FormatUint(id, 10))
|
||||||
|
|
||||||
// Try to find pause file
|
// Try to find pause file
|
||||||
@@ -111,6 +114,9 @@ func resumeQueue(id uint64) (od *OD, err error) {
|
|||||||
|
|
||||||
od.WCtx.Queue = bq
|
od.WCtx.Queue = bq
|
||||||
|
|
||||||
|
logrus.WithField("id", id).
|
||||||
|
Info("Resuming task")
|
||||||
|
|
||||||
return od, nil
|
return od, nil
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user