coffea.processor.dask

helpers for tuning dask behavior for coffea

Functions

get_worker()	Get the worker currently running this task
register_columncache(client)

Classes

Buffer(fast, ~zict.common.VT], slow, ...)	Buffer one dictionary on top of another
ColumnCache([maxmem, maxcompressed, maxdisk])	dask worker plugin to cache columns of data
File(directory[, memmap])	Mutable Mapping interface to a directory
Func(dump, load, d)	Buffer a MutableMapping with a pair of input/output functions
LRU(n, d, ~zict.common.VT], *, on_evict, ...)	Evict Least Recently Used Elements.
Lock	alias of lock
MutableMapping()	A MutableMapping is a generic container for associating key/value pairs.
WorkerPlugin()	Interface to extend the Worker

Class Inheritance Diagram