spdl.pipeline.is_epoch_end

is_epoch_end(item: Any) bool[source]

Test whether the input item is an epoch-end sentinel value.

Custom aggregators can use this to handle epoch boundaries, for example to flush or discard partial batches.