Module local

distributed.deploy.local

Classes

class LocalCluster
Create local Scheduler and Workers

Functions

▷ def close_clusters() @atexit.register
@atexit.register
def close_clusters()
source link
▶ def nprocesses_nthreads(n=CPU_COUNT)
The default breakdown of processes and threads for a given number of cores
source link
Parameters
- n : int
```
Number of available cores
```
Returns
- nprocesses, nthreads
Examples
```
>>> nprocesses_nthreads(4)
(4, 1)
>>> nprocesses_nthreads(32)
(8, 4)
```
Reexports
- Imported in distributed.deploy.tests.test_local.