nat.observability.processor.falsy_batch_filter_processor

Attributes

logger
FalsyT

Classes

FalsyBatchFilterProcessor	Processor that filters out falsy items from a batch.
DictBatchFilterProcessor	Processor that filters out empty dict items from a batch.
ListBatchFilterProcessor	Processor that filters out empty list items from a batch.
SetBatchFilterProcessor	Processor that filters out empty set items from a batch.

Module Contents

logger

FalsyT

class FalsyBatchFilterProcessor

Bases: nat.observability.processor.processor.Processor[list[FalsyT], list[FalsyT]]

Processor that filters out falsy items from a batch.

async process(item: list[FalsyT]) → list[FalsyT]

Filter out falsy items from a batch.

Args:

item (list[FalsyT]): The batch of items to filter.

Returns:

list[FalsyT]: The filtered batch.

class DictBatchFilterProcessor

Bases: FalsyBatchFilterProcessor[dict]

Processor that filters out empty dict items from a batch.

class ListBatchFilterProcessor

Bases: FalsyBatchFilterProcessor[list]

Processor that filters out empty list items from a batch.

class SetBatchFilterProcessor

Bases: FalsyBatchFilterProcessor[set]

Processor that filters out empty set items from a batch.