MPILogFilter#

class caput.util.mpitools.MPILogFilter(add_mpi_info: bool = True, level_rank0: int = logging.INFO, level_all: int = logging.WARN, comm: mpi4py.MPI.Comm | None = None)[source]#

Bases: logging.Filter

Filter log entries by MPI rank.

Also, this will optionally add MPI rank information, and add an elapsed time entry.

Parameters:

add_mpi_infobool, optional: Add MPI rank/size info to log records that don’t already have it.
level_rank0int, optional: Log level for messages from rank=0. Default is INFO.
level_allint, optional: Log level for messages from all other ranks. Default is WARN.
commMPI.Comm | None, optional: MPI Communicator to use (default None).

Methods#

filter(→ bool)

Return True if we should filter the record.