From ad5c8babc8436ee264a4ee957b401633d784fd18 Mon Sep 17 00:00:00 2001
From: Isaac <zibbp@zibbp.net>
Date: Wed, 11 Oct 2023 22:28:33 +0000
Subject: [PATCH] fix(archive): remove queue deletion

---
 internal/archive/archive.go | 6 ------
 1 file changed, 6 deletions(-)

diff --git a/internal/archive/archive.go b/internal/archive/archive.go
index a673d10f..a3212079 100644
--- a/internal/archive/archive.go
+++ b/internal/archive/archive.go
@@ -629,12 +629,6 @@ func (s *Service) TaskVodSaveLiveInfo(ch *ent.Channel, v *ent.Vod, q *ent.Queue,
 	}
 
 	if len(stream.Data) == 0 {
-		log.Error().Msg("stream data is empty")
-		// delete queue item
-		err := database.DB().Client.Queue.DeleteOne(q).Exec(context.Background())
-		if err != nil {
-			log.Error().Err(err).Msg("error deleting queue item")
-		}
 		return fmt.Errorf("stream data is empty")
 	}