From 163a7c11fe4285098713d3829ea54046a6ca34e9 Mon Sep 17 00:00:00 2001 From: yanghao05 Date: Tue, 22 Apr 2025 14:57:34 +0800 Subject: [PATCH] feat: update --- backend/app/jobs/download_from_alioss.go | 4 ++++ backend/app/jobs/video_cut.go | 7 ------- 2 files changed, 4 insertions(+), 7 deletions(-) diff --git a/backend/app/jobs/download_from_alioss.go b/backend/app/jobs/download_from_alioss.go index 1bcda59..b6413d5 100644 --- a/backend/app/jobs/download_from_alioss.go +++ b/backend/app/jobs/download_from_alioss.go @@ -62,6 +62,9 @@ func (w *DownloadFromAliOSSWorker) Work(ctx context.Context, job *Job[DownloadFr } dst := filepath.Join(w.app.StoragePath, media.Path) + if w.job.Add(&RemoveDownloadedVideo{FilePath: dst}); err != nil { + log.Errorf("Error removing original file: %v", err) + } // check is path exist st, err := os.Stat(dst) @@ -105,5 +108,6 @@ func (w *DownloadFromAliOSSWorker) NextJob(hash string) error { log.Errorf("Error adding job: %v", err) return err } + return nil } diff --git a/backend/app/jobs/video_cut.go b/backend/app/jobs/video_cut.go index 76c23d5..2886a45 100644 --- a/backend/app/jobs/video_cut.go +++ b/backend/app/jobs/video_cut.go @@ -87,13 +87,6 @@ func (w *VideoCutWorker) Work(ctx context.Context, job *Job[VideoCut]) error { return JobCancel(err) } - // remove original file - if w.job.Add(&RemoveDownloadedVideo{ - FilePath: input, - }); err != nil { - log.Errorf("Error removing original file: %v", err) - } - // save to database return w.job.Add(&VideoStoreShort{ MediaHash: media.Hash,