async def METHOD_NAME(user_id, corpus_ident, corp_cache_key, query, cutoff, time_limit):
    return await general.METHOD_NAME(
        TaskWrapper(get_current_job()), user_id, corpus_ident, corp_cache_key, query, cutoff, time_limit, worker)