LongArticleTaskServer/applications/utils/async_mysql_utils.py

from typing import List, Dict


async def get_top_article_title_list(pool) -> List[Dict]:
    query = f"""
        select distinct title, source_id
        from datastat_sort_strategy
        where produce_plan_name = %s and source_id is not null;
    """
    return await pool.async_fetch(query=query, params=("TOP100",))


async def get():
    pass