Searched refs:gather_from_workers (Results 1 – 4 of 4) sorted by relevance
| /dports/devel/py-distributed/distributed-2021.11.2/distributed/ |
| H A D | utils_comm.py | 20 async def gather_from_workers(who_has, rpc, close=True, serializers=None, who=None): function
|
| H A D | client.py | 94 gather_from_workers,
1914 data2, missing_keys, missing_workers = await gather_from_workers(
|
| H A D | worker.py | 91 from .utils_comm import gather_from_workers, pack_data, retry_operation
1368 result, missing_keys, missing_workers = await gather_from_workers(
|
| H A D | scheduler.py | 95 from .utils_comm import gather_from_workers, retry_operation, scatter_to_workers
5825 data, missing_keys, missing_workers = await gather_from_workers(
|