diff --git a/internal/manager/persistence/task_scheduler.go b/internal/manager/persistence/task_scheduler.go index 9953a597..b8227100 100644 --- a/internal/manager/persistence/task_scheduler.go +++ b/internal/manager/persistence/task_scheduler.go @@ -14,8 +14,8 @@ import ( var ( schedulableTaskStatuses = []api.TaskStatus{api.TaskStatusQueued, api.TaskStatusSoftFailed, api.TaskStatusActive} - completedTaskStatuses = []api.TaskStatus{api.TaskStatusCompleted} schedulableJobStatuses = []api.JobStatus{api.JobStatusActive, api.JobStatusQueued, api.JobStatusRequeued} + // completedTaskStatuses = []api.TaskStatus{api.TaskStatusCompleted} ) // ScheduleTask finds a task to execute by the given worker. diff --git a/internal/worker/command_blender.go b/internal/worker/command_blender.go index e53756c3..76fdbe7a 100644 --- a/internal/worker/command_blender.go +++ b/internal/worker/command_blender.go @@ -10,7 +10,6 @@ import ( "fmt" "io" "os/exec" - "time" "github.com/google/shlex" "github.com/rs/zerolog" @@ -22,8 +21,6 @@ import ( // Effectively this determines the maximum line length that can be handled. const StdoutBufferSize = 40 * 1024 -const timeFormat = time.RFC3339Nano - type BlenderParameters struct { exe string // Expansion of `{blender}`: executable path + its CLI parameters defined by the Manager. argsBefore []string // Additional CLI arguments defined by the job compiler script, to go before the blend file name.