|
@@ -293,7 +293,7 @@ class UpdateRootSourceIdAndUpdateTimeTask(Const):
|
|
|
self.pool = pool
|
|
|
self.log_client = log_client
|
|
|
|
|
|
- async def get_article_list(self):
|
|
|
+ async def get_article_list(self) -> list[dict]:
|
|
|
query = """select ContentUrl, wx_sn from official_articles_v2 where publish_timestamp in %s;"""
|
|
|
article_list = await self.pool.async_fetch(
|
|
|
query=query, db_name="piaoquan_crawler", params=(tuple([0, -1]),)
|