fix(archive): remove queue deletion

Zibbp · Oct 11, 2023 · ad5c8ba · ad5c8ba
1 parent 2c26480
commit ad5c8ba
Showing 1 changed file with 0 additions and 6 deletions.
diff --git 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")
 	}