async def METHOD_NAME(user_id, corpus_name, subc_name, corp_cache_key, query, cutoff):
    return await general.METHOD_NAME(TaskWrapper(get_current_job()), user_id, corpus_name, subc_name, corp_cache_key, query, cutoff)