def METHOD_NAME(
    self, partitioner: pace.util.CubedSpherePartitioner, comm: Any,
) -> "Sink":
    if self.tensorboard:
        return TensorBoardSink()
    else:
        return ZarrSink(
            pace.util.ZarrMonitor(self.name, partitioner, mpi_comm=comm)
        )