From 30fcda995ead45a34bb7d539fd05a8f1e0604459 Mon Sep 17 00:00:00 2001
From: amtoaer <amtoaer@gmail.com>
Date: Sat, 25 Nov 2023 13:24:04 +0800
Subject: [PATCH] =?UTF-8?q?fix:=20=E7=AD=9B=E9=80=89=E6=B7=BB=E5=8A=A0?=
 =?UTF-8?q?=E7=B1=BB=E5=9E=8B=E6=9D=A1=E4=BB=B6=EF=BC=8C=E6=97=A5=E5=BF=97?=
 =?UTF-8?q?=E7=BB=9F=E4=B8=80=E4=BB=A5=E5=A4=A7=E5=86=99=E5=AD=97=E6=AF=8D?=
 =?UTF-8?q?=E5=BC=80=E5=A4=B4?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 processor.py | 9 ++++++---
 1 file changed, 6 insertions(+), 3 deletions(-)

diff --git a/processor.py b/processor.py
index 9ccfe80..a93d7ce 100644
--- a/processor.py
+++ b/processor.py
@@ -119,7 +119,7 @@ async def process_favorite(favorite_id: int) -> None:
         favorite_id, page=1, credential=credential
     )
     logger.info(
-        "start to process favorite {}: {}",
+        "Start to process favorite {}: {}",
         favorite_id,
         favorite_video_list["info"]["title"],
     )
@@ -155,7 +155,10 @@ async def process_favorite(favorite_id: int) -> None:
         if not (continue_flag and favorite_video_list["has_more"]):
             break
     all_unprocessed_items = await FavoriteItem.filter(
-        favorite_list=fav_list, status=MediaStatus.NORMAL, downloaded=False
+        favorite_list=fav_list,
+        type=MediaType.VIDEO,
+        status=MediaStatus.NORMAL,
+        downloaded=False,
     ).prefetch_related("upper")
     await asyncio.gather(
         *[process_video(item) for item in all_unprocessed_items],
@@ -165,7 +168,7 @@ async def process_favorite(favorite_id: int) -> None:
 
 @concurrent_decorator(4)
 async def process_video(fav_item: FavoriteItem) -> None:
-    logger.info("start to process video {}", fav_item.name)
+    logger.info("Start to process video {} {}", fav_item.bvid, fav_item.name)
     if fav_item.type != MediaType.VIDEO:
         logger.warning("Media {} is not a video, skipped.", fav_item.name)
         return