diff --git a/kb_pipeline/platforms/bilibili.py b/kb_pipeline/platforms/bilibili.py index e91acca..fc45196 100644 --- a/kb_pipeline/platforms/bilibili.py +++ b/kb_pipeline/platforms/bilibili.py @@ -170,9 +170,11 @@ class BilibiliAdapter(PlatformAdapter): ValueError: If content_type is not supported """ if content_type == "video": - return self._extractor.extract_video_metadata(content_id) + # Call async method directly to avoid nested asyncio.run() + return await self._extractor._extract_video_async(content_id) elif content_type == "article": - return self._extractor.extract_article_metadata(content_id) + # Call async method directly to avoid nested asyncio.run() + return await self._extractor._extract_article_async(content_id) else: raise ValueError(f"Unsupported content type: {content_type}")