From 72ab4ad7ec70bb8eb45dce94414f1d4d009eff6c Mon Sep 17 00:00:00 2001 From: Rogee Date: Tue, 6 May 2025 10:57:29 +0800 Subject: [PATCH] feat: update job cancel logic --- backend/app/jobs/video_store_short.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/backend/app/jobs/video_store_short.go b/backend/app/jobs/video_store_short.go index 0e64f21..5911265 100644 --- a/backend/app/jobs/video_store_short.go +++ b/backend/app/jobs/video_store_short.go @@ -103,7 +103,7 @@ func (w *VideoStoreShortWorker) Work(ctx context.Context, job *Job[VideoStoreSho // upload to oss if err := w.oss.Upload(ctx, job.Args.FilePath, filePath, ali.WithInternal(true)); err != nil { log.Errorf("Error uploading file to OSS: %v", err) - return JobCancel(err) + return err } if err := models.Medias.Create(ctx, mediaModel); err != nil {