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,