def get_friends_ids_batch(user_ids: List[int]) -> List[List[int]]:
job = group([tasks.get_friends_ids_batch.s(chunk) for chunk in
chunks(user_ids, 75)])
result = job.apply_async().join()
full_result = []
for list_ in result:
full_result.extend(list_)
return full_result
评论列表
文章目录