Class WorkSpace

distributed.diskutils.WorkSpace

An on-disk workspace that tracks disposable work directories inside it. If a process crashes or another event left stale directories behind, this will be detected and the directories purged.

Declaration

class WorkSpace

source link

Documentation

Methods

▷ def __init__(self, base_dir)
source link
▶ def new_work_dir(self, **kwargs)
Create and return a new WorkDir in this WorkSpace. Either the *prefix* or *name* parameter should be given (*prefix* is preferred as it avoids potential collisions)
source link
Parameters
- prefix : str
```
The prefix of the temporary subdirectory name for the workdir
```
- name : str
```
The subdirectory name for the workdir
```

Reexports

Imported in distributed.worker.
Imported in distributed.tests.test_diskutils.

Distributed

Class WorkSpace

Declaration

Documentation

Methods

Parameters

Reexports