SimpleCheckpointer#

class coffea.processor.SimpleCheckpointer(checkpoint_dir: str, verbose: bool = False, overwrite: bool = True)[source]#

Bases: CheckpointerABC

Methods Summary

filepath(metadata, processor_instance)

load(metadata, processor_instance)

save(output, metadata, processor_instance)

Methods Documentation

filepath(metadata: Any, processor_instance: ProcessorABC) → str[source]#
load(metadata: Any, processor_instance: ProcessorABC) → Accumulatable | None[source]#
save(output: Accumulatable, metadata: Any, processor_instance: ProcessorABC) → None[source]#