async def METHOD_NAME(worker: AbstractBgClient, pquery: PqueryFormArgs, raw_queries, subcpath, user_id, collator_locale):
    path = _create_cache_path(pquery)
    if await aiofiles.os.path.exists(path):
        async with aiofiles.open(path, 'r') as fr:
            csv_reader = aiocsv.AsyncReader(fr)
            return [item async for item in csv_reader]
    else:
        ans = await f(worker, pquery, raw_queries, subcpath, user_id, collator_locale)
        num_lines = ans[0][1]
        async with aiofiles.open(path, 'w') as fw:
            csv_writer = aiocsv.AsyncWriter(fw)
            await csv_writer.writerow(('__total__', num_lines))
            await csv_writer.writerows(ans[1:])
        return ans[1:]