blender/flamenco
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Manager: remove task scheduler SQL debug logs

Browse Source
This commit is contained in:
Sybren A. Stüvel 2022-02-28 12:07:23 +01:00
parent b5b7b228ed
commit fab988295d
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
internal/manager/persistence/task_scheduler.go
View File

@ -89,7 +89,7 @@ func (db *DB) ScheduleTask(ctx context.Context, w *Worker) (*Task, error) {
func findTaskForWorker(tx *gorm.DB, w *Worker) (*Task, error) { func findTaskForWorker(tx *gorm.DB, w *Worker) (*Task, error) {
task := Task{} task := Task{}
findTaskResult := tx.Debug(). findTaskResult := tx.
Model(&task). Model(&task).
Joins("left join jobs on tasks.job_id = jobs.id"). Joins("left join jobs on tasks.job_id = jobs.id").
Joins("left join task_dependencies on tasks.id = task_dependencies.task_id"). Joins("left join task_dependencies on tasks.id = task_dependencies.task_id").
@ -116,5 +116,5 @@ func findTaskForWorker(tx *gorm.DB, w *Worker) (*Task, error) {
func assignTaskToWorker(tx *gorm.DB, w *Worker, t *Task) error { func assignTaskToWorker(tx *gorm.DB, w *Worker, t *Task) error {
// Without the Select() call, Gorm will try and also store task.Job in the // Without the Select() call, Gorm will try and also store task.Job in the
// jobs database, which is not what we want. // jobs database, which is not what we want.
return tx.Debug().Model(t).Select("worker_id").Updates(Task{WorkerID: &w.ID}).Error return tx.Model(t).Select("worker_id").Updates(Task{WorkerID: &w.ID}).Error
} }