From 1a44c0c9c373fb8d9c7b8d94f011572de3e3ad0a Mon Sep 17 00:00:00 2001 From: Alexander Date: Wed, 11 Sep 2024 09:10:31 +0200 Subject: [PATCH] fix(spot): don't miss 'processed' status after trimming without transcoding --- backend/pkg/spot/transcoder/transcoder.go | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/backend/pkg/spot/transcoder/transcoder.go b/backend/pkg/spot/transcoder/transcoder.go index f1008b8c5..de8df0005 100644 --- a/backend/pkg/spot/transcoder/transcoder.go +++ b/backend/pkg/spot/transcoder/transcoder.go @@ -102,6 +102,9 @@ func (t *transcoderImpl) failedTask(task *Task, err error) { } func (t *transcoderImpl) doneTask(task *Task) { + if err := t.spots.SetStatus(task.SpotID, "processed"); err != nil { + t.log.Error(context.Background(), "Error updating spot status: %v", err) + } if err := t.tasks.Done(task); err != nil { t.log.Error(context.Background(), "Error marking task as done: %v", err) } @@ -167,9 +170,6 @@ func (t *transcoderImpl) transcode(payload interface{}) { return } - if err := t.spots.SetStatus(task.SpotID, "processed"); err != nil { - t.log.Error(context.Background(), "Error updating spot status: %v", err) - } t.doneTask(task) t.log.Info(context.Background(), "Transcoded spot %d, have to upload chunks to S3", task.SpotID)