Skip to content
Snippets Groups Projects
Commit 66d22923 authored by Travis Ralston's avatar Travis Ralston
Browse files

Don't start old tasks, just in case people have them in their database

parent 13908a95
No related branches found
No related tags found
No related merge requests found
...@@ -10,6 +10,7 @@ import ( ...@@ -10,6 +10,7 @@ import (
"github.com/turt2live/matrix-media-repo/database" "github.com/turt2live/matrix-media-repo/database"
"github.com/turt2live/matrix-media-repo/notifier" "github.com/turt2live/matrix-media-repo/notifier"
"github.com/turt2live/matrix-media-repo/tasks/task_runner" "github.com/turt2live/matrix-media-repo/tasks/task_runner"
"github.com/turt2live/matrix-media-repo/util"
"github.com/turt2live/matrix-media-repo/util/ids" "github.com/turt2live/matrix-media-repo/util/ids"
) )
...@@ -61,6 +62,13 @@ func beginTask(task *database.DbTask) { ...@@ -61,6 +62,13 @@ func beginTask(task *database.DbTask) {
} }
// TODO: Worker group: https://github.com/turt2live/matrix-media-repo/issues/425 // TODO: Worker group: https://github.com/turt2live/matrix-media-repo/issues/425
runnerCtx := rcontext.Initial().LogWithFields(logrus.Fields{"task_id": task.TaskId}) runnerCtx := rcontext.Initial().LogWithFields(logrus.Fields{"task_id": task.TaskId})
oneHourAgo := util.NowMillis() - (60 * 60 * 1000)
if task.StartTs < oneHourAgo {
runnerCtx.Log.Warn("Not starting task because it is more than 1 hour old.")
return
}
if task.Name == string(TaskDatastoreMigrate) { if task.Name == string(TaskDatastoreMigrate) {
go task_runner.DatastoreMigrate(runnerCtx, task) go task_runner.DatastoreMigrate(runnerCtx, task)
} else if task.Name == string(TaskExportData) { } else if task.Name == string(TaskExportData) {
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment