ColumnCache#

class coffea.processor.dask.ColumnCache(maxmem=500000000.0, maxcompressed=2000000000.0, maxdisk=10000000000.0)[source]#

Bases: WorkerPlugin, MutableMapping

dask worker plugin to cache columns of data

Attributes Summary

name

Methods Summary

setup(worker)

Run when the plugin is attached to a worker.

teardown(worker)

Run when the worker to which the plugin is attached is closed, or when the plugin is removed.

Attributes Documentation

name = 'columncache'#

Methods Documentation

setup(worker)[source]#

Run when the plugin is attached to a worker. This happens when the plugin is registered and attached to existing workers, or when a worker is created after the plugin has been registered.

teardown(worker)[source]#

Run when the worker to which the plugin is attached is closed, or when the plugin is removed.