vk.py 文件源码

def get_mutual_friends_ids_batch(user_ids: List[int],
                                 my_id: int) -> Dict[int, List[int]]:
    job = group(
        [tasks.get_mutual_friends_ids_batch.s(chunk, my_id) for chunk in
         chunks(user_ids, 75)])

    result = job.apply_async().join()

    full_result = {int(key): value for dictionary in result for key, value in
                   dictionary.items()}

    return full_result