nat.observability.processor.callback_processor#
Attributes#
Classes#
Abstract base class for processors that support done callbacks. |
Module Contents#
- InputT#
- OutputT#
- class CallbackProcessor#
Bases:
nat.observability.processor.processor.Processor[InputT,OutputT]Abstract base class for processors that support done callbacks.
Processors inheriting from this class can register callbacks that are invoked when items are ready for further processing or export.
- abstractmethod set_done_callback(
- callback: collections.abc.Callable[[Any], collections.abc.Awaitable[None]],
Set a callback function to be invoked when items are processed.
- Args:
callback (Callable[[Any], Awaitable[None]]): Function to call with processed items