multi_logging

bigmultipipe.multi_logging(level, meta, message)

Implements logging on a per-process basis in BigMultiPipe pipeline post-processing routines

Parameters

levelstr

Log message level (e.g., “debug”, “info”, “warn, “error”)

metadict

The meta channel of a BigMultiPipe pipeline

messagestr

Log message

Examples

>>> def post_process_error_example(data, bmp_meta=None, **kwargs):
>>>     multi_logging('warning', pipe_meta, 'Example log message')